1. 創建集群節點

2. 創建集群操作對象

3. 關閉集群

4. 例子

4.1. 新建一個名為JedisCluster的Java項目, 拷入相關jar包, 并添加到build path

4.2. 代碼

package com.redis.cluster;import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.TreeSet; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisCluster; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig;/*** Jedis集群操作*/ public class UseJedisCluster {public static void main(String[] args) {// 創建集群節點對象Set<HostAndPort> nodes = new HashSet<HostAndPort>();nodes.add(new HostAndPort("192.168.25.133", 6379));nodes.add(new HostAndPort("192.168.25.135", 6379));nodes.add(new HostAndPort("192.168.25.137", 6379));nodes.add(new HostAndPort("192.168.25.138", 6379));nodes.add(new HostAndPort("192.168.25.139", 6379));nodes.add(new HostAndPort("192.168.25.140", 6379));// 創建集群操作對象JedisCluster cluster = new JedisCluster(nodes, 2000, 2000, 5, "lyw123456", new JedisPoolConfig());Map<String, JedisPool> clusterNodes = cluster.getClusterNodes();// 獲取集群的所有keySet<String> keys = new TreeSet<String>();for(String node : clusterNodes.keySet()){Jedis jedis = clusterNodes.get(node).getResource();keys.addAll(jedis.keys("*"));}// 遍歷所有keyfor (String key : keys) {System.out.println(key + " = " + cluster.get(key));}// 關閉集群操作cluster.close();} }

4.3. 運行結果

總結

以上是生活随笔為你收集整理的025_Jedis集群的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。