Redis Cluster集群搭建后,客户端的连接研究(Spring/Jedis)(待实践)

说明:无论是否已经搭建好集群,还是使用什么样的客户端去连接,都是必须把全部IP列表集成进去,然后随机往其中一个IP写。

这样做的好处:

1、随机IP写入之后,Redis Cluster代理层会自动根据分片写入其中一台,随机IP只是减缓一个IP时的巨大流量问题。

2、对于写死的IP问题,可以通过动态配置文件或者接口,观察IP更新或者节点增加时,重新实例化,原有业务不影响,因为对象本身到GC时也代表当前业务已经完成。

下面是基于Spring和Jedis实现的集群,同时后端采用就是Redis Cluster原生集群。

当然,也可以自己手写这些客户端等。

原理还待研究,到底是不是只要写上了这些IP,客户端就全部保持着这些连接,然后有助于判断哪个不可用。

还有一种想法是通过HAProxy来聚合出一个IP,然后将这些IP都添加进去,不过没测试过这种方式对Redis Cluster模式会不会有影响。

我猜测客户端需要全部IP都写上,是由于其支持-MOVED 6918 127.0.0.1:7004这样的命令,去取数据。应该是客户端实现了这些协议。

而如果是基于Redis Cluster模式的,我猜测应该不能再前面使用HAProxy的代理去聚合IP。

关于这种模式的理解,参考:http://www.searu.org/30194.html,说到:当集群处于稳定状态时,所有客户端最终都会保存有一个哈希槽至节点的映射记录,使得集群非常高效: 客户端可以直接向正确的节点发送命令请求, 无须转向、代理或者其他任何可能发生单点故障(single point failure)的实体(entiy)。

这种应该就是不用代理软件去实现的原因。

下面是基于Spring+Jedis的配置:

在Spring配置文件中添加Jedis配置。(三主三从,9001-9003是主,9004-9006是从)

    <!-- 配置redis客户端集群版 -->
    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
        <constructor-arg>
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.XX.XX"/>
                    <constructor-arg name="port" value="9001"/> 
                </bean>                                         
                <bean class="redis.clients.jedis.HostAndPort">  
                    <constructor-arg name="host" value="XXXXXXX"/>
                    <constructor-arg name="port" value="9002"/> 
                </bean>                                         
                <bean class="redis.clients.jedis.HostAndPort">  
                    <constructor-arg name="host" value="XXXXXXX"/>
                    <constructor-arg name="port" value="9003"/> 
                </bean>                                         
                <bean class="redis.clients.jedis.HostAndPort">  
                    <constructor-arg name="host" value="XXXXXXX"/>
                    <constructor-arg name="port" value="9004"/> 
                </bean>                                         
                <bean class="redis.clients.jedis.HostAndPort">  
                    <constructor-arg name="host" value="XXXXXXX"/>
                    <constructor-arg name="port" value="9005"/> 
                </bean>                                         
                <bean class="redis.clients.jedis.HostAndPort">  
                    <constructor-arg name="host" value="XXXXXXX"/>
                    <constructor-arg name="port" value="9006"/>
                </bean>
            </set>
        </constructor-arg>
    </bean>

<bean id="jedisClientCluster" class="com.dianshang.rest.component.impl.JedisClientCluster"/>

封装Redis的一些常用操作(存储String 类型,获取String类型,设置过期时间,删除hash数据等等)

/**  
 * redis操作工具类  
 * @author xiao  
 *  
 */  
public class JedisClientCluster implements JedisClient{  
      
    //注入jedisCluster  
    @Autowired  
    private JedisCluster jedisCluster;  
  
    /**  
     * 设置String数据类型  
     *   
     * @param key  
     * @param value  
     * @return  
     */  
    @Override  
    public String set(String key, String value) {  
        return jedisCluster.set(key, value);  
    }  
  
    /**  
     * 获取String数据类型  
     *   
     * @param key  
     * @return  
     */  
    @Override  
    public String get(String key) {  
        return jedisCluster.get(key);  
    }  
      
    /**  
     * 设置hash数据类型  
     *   
     * @param key  
     * @param item  
     * @param value  
     * @return  
     */  
    @Override  
    public Long hset(String key, String item, String value) {  
        return jedisCluster.hset(key, item, value);  
    }  
      
    /**  
     * 获取hash数据类型  
     *   
     * @param key  
     * @param item  
     * @return  
     */  
    @Override  
    public String hget(String key, String item) {  
        return jedisCluster.hget(key, item);  
    }  
      
    /**  
     * 删除hash数据  
     * @param key  
     * @param item  
     * @return  
     */  
    @Override  
    public Long incr(String key) {  
        return jedisCluster.incr(key);  
    }  
      
    /**  
     * 加一操作  
     *   
     * @param key  
     * @return  
     */  
    @Override  
    public Long decr(String key) {  
        return jedisCluster.decr(key);  
    }  
      
    /**  
     * 减一操作  
     *   
     * @param key  
     * @return  
     */  
    @Override  
    public Long expire(String key, int second) {  
        return jedisCluster.expire(key, second);  
    }  
      
    /**  
     * 设置key的过期时间  
     *   
     * @param key  
     * @param second  
     * @return  
     */  
    @Override  
    public Long ttl(String key) {  
        return jedisCluster.ttl(key);  
    }  
      
    /**  
     * 判断key是否过期  
     *   
     * @param key  
     * @return  
     */  
    @Override  
    public Long hdel(String key, String item) {  
         return jedisCluster.hdel(key, item);  
    }  
  
}  

测试:

@Test  
public void testJedisClientSpring() throws Exception {  
    //创建一个spring容器  
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml");  
    //从容器中获得JedisClient对象  
    JedisClient jedisClient = applicationContext.getBean(JedisClient.class);  
    //jedisClient操作redis  
    jedisClient.set("cliet1", "1000");  
    String string = jedisClient.get("cliet1");  
    System.out.println(string);  
}  

参考:

http://blog.csdn.net/u010539352/article/details/51778242(以上内容部分转自此篇文章)

http://blog.csdn.net/younger_z/article/details/51366791

http://m635674608.iteye.com/blog/2292236

https://www.2cto.com/kf/201609/551965.html

http://www.sojson.com/blog/203.html

原文地址:https://www.cnblogs.com/EasonJim/p/7630049.html