@ -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;
@ -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) {