diff --git a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisCluster.java b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisCluster.java
index c9d5713a7..dd7de359d 100644
--- a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisCluster.java
+++ b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisCluster.java
@@ -1976,4 +1976,14 @@ public class JedisCluster extends BinaryJedisCluster implements JedisClusterComm
       }
     }.run(key);
   }
+
+  //暴露出Client, 方便上层解耦
+  public Client getClient() {
+
+    Jedis jedis = this.connectionHandler.getConnection();
+    if (jedis != null) {
+      return jedis.getClient();
+    }
+    return null;
+  }
 }
diff --git a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
index ac1cc4a76..ef2973500 100644
--- a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
+++ b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
@@ -21,6 +21,14 @@ public abstract class JedisPubSub {
   private int subscribedChannels = 0;
   private volatile Client client;
 
+  public JedisPubSub() {
+
+  }
+
+  public JedisPubSub(Client client) {
+    this.client = client;
+  }
+
   public void onMessage(String channel, String message) {
   }