Memcached 完全基于分布式集群,而 Redis 是 Master-Slave ,如果想把 Reids ,做成集群模式,无外乎多做几套 Master-Slave ,每套 Master-Slave 完成各自的容灾处理,通过 Client 工具,完成一致性哈希。( PS : Memcached 是在 Server 端完成 Sharding , Redis 只能依靠各个 Client 做 Sharding 。 可能会在 Redis 3.0 系列支持 Server 端 Sharding 。 )
shared一致性哈希采用以下方案:
-
Redis服务器节点划分:将每台服务器节点采用hash算法划分为160个虚拟节点(可以配置划分权重)
-
将划分虚拟节点采用TreeMap存储
-
对每个Redis服务器的物理连接采用LinkedHashMap存储
-
对Key or KeyTag 采用同样的hash算法,然后从TreeMap获取大于等于键hash值得节点,取最邻近节点存储;当key的hash值大于虚拟节点hash值得最大值时,存入第一个虚拟节点
sharded采用的hash算法:MD5 和 MurmurHash两种;默认采用64位的MurmurHash算法;有兴趣的可以研究下,MurmurHash是一种高效,低碰撞的hash算法;参考地址:
保留前面的 JedisPoolConfig ,新增两个Redis的IP(redis1.ip,redis2.ip),完成两个 JedisShardInfo 实例 ,并将其丢进List中:
JedisShardInfo jedisShardInfo1 = new JedisShardInfo( bundle.getString("redis1.ip"), Integer.valueOf(bundle .getString("redis.port")));JedisShardInfo jedisShardInfo2 = new JedisShardInfo( bundle.getString("redis2.ip"), Integer.valueOf(bundle .getString("redis.port"))); Listlist = new LinkedList (); list.add(jedisShardInfo1); list.add(jedisShardInfo2);
初始化 ShardedJedisPool 代替 JedisPool:
ShardedJedisPool pool = new ShardedJedisPool(config, list);
改由ShardedJedis,获取Jedis对象:
// 从池中获取一个Jedis对象ShardedJedis jedis = pool.getResource();String keys = "name";String value = "snowolf";// 删数据jedis.del(keys);// 存数据 jedis.set(keys, value); // 取数据 String v = jedis.get(keys); System.out.println(v); // 释放对象池 pool.returnResource(jedis);
通过以上方式,向redis进行set操作的key-value,会通过hash而均匀的分配到pool里的redis机器中。