使用Jedis连接集群Redis(支持Redis复杂操作)

来源:转载


Jedis-2.7.2 版本虽然支持连接集群 Redis,但是仅仅支持 String 字符串的存储,并不支持 Map、Set、List,在这里分享一个能够支持复杂操作的方法。

import java.util.Set;import org.apache.commons.pool2.impl.GenericObjectPoolConfig;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisClusterCommand;import redis.clients.jedis.JedisClusterConnectionHandler;import redis.clients.jedis.JedisSlotBasedConnectionHandler;public class BinaryJedisCluster { private int maxRedirections; private JedisClusterConnectionHandler connectionHandler; public BinaryJedisCluster(Set<HostAndPort> nodes, int timeout, int maxRedirections) { this(nodes, timeout, maxRedirections, new GenericObjectPoolConfig()); } public BinaryJedisCluster(Set<HostAndPort> jedisClusterNode, int timeout, int maxRedirections, final GenericObjectPoolConfig poolConfig) { this.connectionHandler = new JedisSlotBasedConnectionHandler(jedisClusterNode, poolConfig, timeout); this.maxRedirections = maxRedirections; } public String set(final String key, final String value) { return new JedisClusterCommand<String>(connectionHandler, maxRedirections) { @Override public String execute(Jedis connection) { return connection.set(key, value); } }.run(key); } public String get(final String key) { return new JedisClusterCommand<String>(connectionHandler, maxRedirections) { @Override public String execute(Jedis connection) { return connection.get(key); } }.run(key); }}

(注:这是简化版的,具体代码并非原创,就不贴了。)

Map、Set、List 等类似 String,在 execute 方法中通过 Jedis 直接操作 Redis 即可。


在与 Spring 结合使用时,可以通过继承 InitializingBean 来实现初始化注入。

 private BinaryJedisCluster jc; @Override public void afterPropertiesSet() throws Exception { Set<HostAndPort> set = new HashSet<HostAndPort>(); set.add(new HostAndPort(host,port)); ... jc = new BinaryJedisCluster(set, 5000, 6); }



分享给朋友:
您可能感兴趣的文章:
随机阅读: