Browse Source

Merge pull request #425 in CORE/base-third from ~FENG/base-third:release/10.0 to release/10.0

* commit 'a28e8da37d086d70aa98183a97f0e2c008b0d2d9':
  KERNEL-3881  状态服务器+集群锁相关代码解耦,脱离依赖redis
  KERNEL-3881 状态服务器+集群锁相关代码解耦,脱离依赖redis
release/10.0
Feng 4 years ago
parent
commit
4ccebbbfa9
  1. 12
      fine-jedis/src/com/fr/third/redis/clients/jedis/JedisCluster.java
  2. 10
      fine-jedis/src/com/fr/third/redis/clients/jedis/JedisPubSub.java

12
fine-jedis/src/com/fr/third/redis/clients/jedis/JedisCluster.java

@ -1976,4 +1976,14 @@ public class JedisCluster extends BinaryJedisCluster implements JedisClusterComm
} }
}.run(key); }.run(key);
} }
}
//暴露出Client, 方便上层解耦
public Client getClient() {
Jedis jedis = this.connectionHandler.getConnection();
if (jedis != null) {
return jedis.getClient();
}
return null;
}
}

10
fine-jedis/src/com/fr/third/redis/clients/jedis/JedisPubSub.java

@ -21,6 +21,14 @@ public abstract class JedisPubSub {
private int subscribedChannels = 0; private int subscribedChannels = 0;
private volatile Client client; private volatile Client client;
public JedisPubSub() {
}
public JedisPubSub(Client client) {
this.client = client;
}
public void onMessage(String channel, String message) { public void onMessage(String channel, String message) {
} }
@ -176,4 +184,4 @@ public abstract class JedisPubSub {
public int getSubscribedChannels() { public int getSubscribedChannels() {
return subscribedChannels; return subscribedChannels;
} }
} }
Loading…
Cancel
Save