diff --git a/src/main/java/io/jboot/components/cache/caredis/JbootCaredisCacheImpl.java b/src/main/java/io/jboot/components/cache/caredis/JbootCaredisCacheImpl.java
index 3f2e41c9355697a2f58888192d983bbbbe0bd877..c02bf1bd22dad9f19150d3b9c9b05ac16bd1b26b 100644
--- a/src/main/java/io/jboot/components/cache/caredis/JbootCaredisCacheImpl.java
+++ b/src/main/java/io/jboot/components/cache/caredis/JbootCaredisCacheImpl.java
@@ -49,30 +49,32 @@ public class JbootCaredisCacheImpl extends JbootCacheBase {
     private String clientId;
 
     private Cache<String, List> keysCache = Caffeine.newBuilder()
-            .expireAfterAccess(10, TimeUnit.MINUTES)
-            .expireAfterWrite(10, TimeUnit.MINUTES)
-            .build();
+        .expireAfterAccess(10, TimeUnit.MINUTES)
+        .expireAfterWrite(10, TimeUnit.MINUTES)
+        .build();
 
 
     public JbootCaredisCacheImpl(JbootCacheConfig config) {
         super(config);
         this.caffeineCacheImpl = new CaffeineCacheImpl(config);
-        this.redisCacheImpl = new JbootRedisCacheImpl(config);
+
         this.clientId = StrUtil.uuid();
         this.serializer = Jboot.getSerializer();
 
-        //在某些场景下，多个应用使用同一个 redis 实例，此时可以通过配置 cacheSyncMqChannel 来解决缓存冲突的问题
-        if (StrUtil.isNotBlank(config.getCacheSyncMqChannel())){
-            this.channel = config.getCacheSyncMqChannel();
-        }
-
-        this.redis = redisCacheImpl.getRedis();
-        this.redis.subscribe(new BinaryJedisPubSub() {
-            @Override
-            public void onMessage(byte[] channel, byte[] message) {
-                JbootCaredisCacheImpl.this.onMessage((String) serializer.deserialize(channel), serializer.deserialize(message));
+        if(!config.isUseFirstLevelOnly()) {
+            //在某些场景下，多个应用使用同一个 redis 实例，此时可以通过配置 cacheSyncMqChannel 来解决缓存冲突的问题
+            if (StrUtil.isNotBlank(config.getCacheSyncMqChannel())) {
+                this.channel = config.getCacheSyncMqChannel();
             }
-        }, serializer.serialize(channel));
+            this.redisCacheImpl = new JbootRedisCacheImpl(config);
+            this.redis = redisCacheImpl.getRedis();
+            this.redis.subscribe(new BinaryJedisPubSub() {
+                @Override
+                public void onMessage(byte[] channel, byte[] message) {
+                    JbootCaredisCacheImpl.this.onMessage((String) serializer.deserialize(channel), serializer.deserialize(message));
+                }
+            }, serializer.serialize(channel));
+        }
     }
 
 
@@ -241,8 +243,11 @@ public class JbootCaredisCacheImpl extends JbootCacheBase {
 
     private void publishMessage(int action, String cacheName, Object key) {
         clearKeysCache(cacheName);
-        JbootCaredisMessage message = new JbootCaredisMessage(clientId, action, cacheName, key);
-        redis.publish(serializer.serialize(channel), serializer.serialize(message));
+        if(!config.isUseFirstLevelOnly()){
+            JbootCaredisMessage message = new JbootCaredisMessage(clientId, action, cacheName, key);
+            redis.publish(serializer.serialize(channel), serializer.serialize(message));
+        }
+
     }
 
     private void clearKeysCache(String cacheName) {