Redis在數(shù)據(jù)容災(zāi)處理方面可以通過服務(wù)器端配置Master-Slave模式來實現(xiàn)，而在分布式集群方面目前只能通過客戶端工具來實現(xiàn)一致性哈希分布存儲羊始，即key分片存儲。Redis可能會在3.0版本支持服務(wù)器端的分布存儲。Redis只能依靠各個Client做Sharding幌缝■眨可能會在Redis 3.0系列支持Server端Sharding滞磺。
Redis是Master-Slave，如果 想把Reids莱褒，做成集群模式击困，無外乎多做幾套Master-Slave，每套Master-Slave完成各自的容災(zāi)處理广凸，通過Client工具阅茶，完成一致性哈希。
jedis源碼中ShardedJedis實現(xiàn)sharding
一個JedisShardInfo類谅海，里面包含了jedis服務(wù)器的一些信息
最重要的是它的父類中有一個weight字段脸哀，作為本jedis服務(wù)器的權(quán)值。
這個類還有一個繼承自父類的方法createResource扭吁，用來生成該類對應(yīng)的Jedis對象.在構(gòu)造ShardedJedis的時候傳入一個JedisShardInfo的list列表撞蜂。然后ShardedJedis的父類的父類及Sharede就會對這個list進(jìn)行一些操作
public static final int DEFAULT_WEIGHT = 1;
private TreeMap<Long, S> nodes;
private final Hashing algo;
private final Map<ShardInfo<R>, R> resources = new LinkedHashMap<ShardInfo<R>, R>();
Sharded中的三個字段盲镶，nodes是用來模擬一致性哈希算法用的；algo是用來對字符串產(chǎn)生哈希值的hash函數(shù)谅摄，這里默認(rèn)的是 murmurhash徒河，這個算法的隨機(jī)分布特征表現(xiàn)比較好；resources這個map是用來存儲JedisShardInfo與其對應(yīng)的Jedis類 之間的映射關(guān)系送漠。
在上面提到的對list的操作：
private void initialize(List<S> shards) {
nodes = new TreeMap<Long, S>();
for (int i = 0; i != shards.size(); ++i) {
final S shardInfo = shards.get(i);
if (shardInfo.getName() == null)
for (int n = 0; n < 160 * shardInfo.getWeight(); n++) {
nodes.put(this.algo.hash("SHARD-" + i + "-NODE-" + n), shardInfo);
}
else {
for (int n = 0; n < 160 * shardInfo.getWeight(); n++) {
nodes.put(this.algo.hash(shardInfo.getName() + "*" + shardInfo.getWeight() + n), shardInfo);
}
}
resources.put(shardInfo, shardInfo.createResource());
}
}
if-else塊 完成虛擬節(jié)點 到真實節(jié)點的映射
resources.put(shardInfo, shardInfo.createResource()) 完成真實節(jié)點 到具體Jedis實例的映射
在for循環(huán)中顽照，遍歷主機(jī)列表（shards.get(i)），之后對每個主機(jī)按照單權(quán)重160的比例計算shard值闽寡，將shard值和主機(jī)信息（shardInfo）放到nodes中代兵，將主機(jī)信息（shardInfo）和其對應(yīng)的鏈接資源（Jedis）映射放入到resources中。
Weight是權(quán)重爷狈，用于調(diào)節(jié)單個主機(jī)被映射值個數(shù)植影，如果weight為1，那么當(dāng)前主機(jī)將被映射為160個值涎永，weight為2思币，當(dāng)前主機(jī)將被映射為320個值，因此weight為2的節(jié)點被訪問到的概率就會高一些羡微。
遍歷list中的每一個shardInfo谷饿，將其權(quán)重weight*160生成n，然后用名字或者編號來生成n個哈希值（這個是為了保證哈希算法的平衡 性而生成的虛擬節(jié)點）妈倔，然后將其和本shardInfo的對應(yīng)關(guān)系存儲到treemap里面（這是在模擬一致性哈希算法中將虛擬節(jié)點映射到環(huán)上的操作）博投， 最后將shardInfo與對應(yīng)的Jedis類的映射關(guān)系存儲到resources里面。
- 在使用ShardedJedis進(jìn)行操作的時候盯蝴，每個方法都要先獲得key經(jīng)過hash后對應(yīng)的Jedis對象毅哗，才能執(zhí)行對應(yīng)的方法，這個Jedis對象獲取步驟如下：
1捧挺、首先根據(jù)傳入的key按照hash算法（默認(rèn)為murmurhash）取得其value虑绵，然后用這個value到treemap中找key大于前面生成的value值的第一個鍵值對，這個鍵值對的value既是對應(yīng)的shardedInfo
public S getShardInfo(byte[] key) {
SortedMap<Long, S> tail = nodes.tailMap(algo.hash(key));
if (tail.isEmpty()) {
return nodes.get(nodes.firstKey());
}
return tail.get(tail.firstKey());
}
2闽烙、根據(jù)得到的shardedInfo從resources中取得對應(yīng)的Jedis對象
Feature速覽
- 所有數(shù)據(jù)都在內(nèi)存中蒸殿。
- 五種數(shù)據(jù)結(jié)構(gòu)：String / Hash / List / Set / Ordered Set。
- 數(shù)據(jù)過期時間支持鸣峭。
- 不完全的事務(wù)支持宏所。
- 服務(wù)端腳本：使用Lua Script編寫，類似存儲過程的作用摊溶。
- PubSub：撈過界的消息一對多發(fā)布訂閱功能爬骤，起碼Redis-Sentinel使用了它。
- 持久化：支持定期導(dǎo)出內(nèi)存的Snapshot 與 記錄寫操作日志的Append Only File兩種模式莫换。
- Replication：Master-Slave模式霞玄，Master可連接多個只讀Slave骤铃，暫無專門的Geographic Replication支持。
- Fail-Over：Redis-Sentinel節(jié)點負(fù)責(zé)監(jiān)控Master節(jié)點坷剧，在master失效時提升slave惰爬，- 獨立的仲裁節(jié)點模式有效防止腦裂。
- Sharding：開發(fā)中的Redis-Cluser惫企。
- 動態(tài)配置：所有參數(shù)可用命令行動態(tài)配置不需重啟撕瞧，并重新寫回配置文件中，對云上的大規(guī)模部署非常合適狞尔。
