使用redis-trib.rb,這是redis安裝自帶的集群,采用服務器碎片化的方式。Jedis使用JedisCluster類來訪問。
對jedis tape使用客戶端shardedJedispool類。
Twemproxy由代理分段,連接代理可以使用Jedis類(單鏈接)和JedisPool類(多鏈接)。
以下是JedisCluster的壹個示例:
JedisCluster集群;
public void init() {
//加載redis配置文件
resource bundle bundle = resource bundle . get bundle(" redis ");
if (bundle == null) {
拋出新的IllegalArgumentException("[redis . properties]未找到!");
}
//創建jedis池配置實例
JedisPoolConfig config = new JedisPoolConfig();
//設置池CI值
config . setmaxtotal(integer . value of(bundle . getstring(" redis . pool . max active ")。trim()));
config . setmaxidle(integer . value of(bundle . getstring(" redis . pool . maxidle ")。trim()));
config . setmaxwaitmillis(long . value of(bundle . getstring(" redis . pool . max wait ")。trim()));
config . settestonborrow(boolean . value of(bundle . getstring(" redis . pool . testonborrow ")。trim()));
config . settestonreturn(boolean . value of(bundle . getstring(" redis . pool . testonreturn ")。trim()));
設置& ltHostAndPort & gthps = new HashSet<。HostAndPort & gt();
hps.add(新HostAndPort(" 192.168.242 . 133 ",4001));
hps.add(新HostAndPort(" 192.168.242 . 133 ",4002));
hps.add(新HostAndPort(" 192.168.242 . 133 ",4003));
hps.add(新HostAndPort(" 192.168.242 . 133 ",4004));
cluster =新的JedisCluster(hps,2000,5);
}
公共無效測試(){
//這裏可以使用cluster進行各種redis操作(類似於Jedis類的接口)。
cluster.set("key "," value ");
}
如果妳還想知道什麽,請給我留言。