redis分布式

Memcached 完全基于分布式集群,而 Redis 是 Master-Slave ,如果想把 Reids ,做成集群模式,无外乎多做几套 Master-Slave ,每套 Master-Slave 完成各自的容灾处理,通过 Client 工具,完成一致性哈希。( PS : Memcached 是在 Server 端完成 Sharding , Redis 只能依靠各个 Client 做 Sharding 。 可能会在 Redis 3.0 系列支持 Server 端 Sharding 。 )

   shared一致性哈希采用以下方案:

  1. Redis服务器节点划分:将每台服务器节点采用hash算法划分为160个虚拟节点(可以配置划分权重)

  2. 将划分虚拟节点采用TreeMap存储

  3. 对每个Redis服务器的物理连接采用LinkedHashMap存储

  4. 对Key or KeyTag 采用同样的hash算法,然后从TreeMap获取大于等于键hash值得节点,取最邻近节点存储;当key的hash值大于虚拟节点hash值得最大值时,存入第一个虚拟节点

sharded采用的hash算法:MD5 和 MurmurHash两种;默认采用64位的MurmurHash算法;有兴趣的可以研究下,MurmurHash是一种高效,低碰撞的hash算法;参考地址:  

http://blog.csdn.net/yfkiss/article/details/7337382

https://sites.google.com/site/murmurhash/  

   保留前面的 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")));
List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();
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机器中。

原文地址:https://www.cnblogs.com/qypx520/p/5867837.html