java代码连接redis集群代码，需要密码

迷南。 2024-04-18 20:57 59阅读 0赞

1，早前百度的代码

public static void main(String[] args) {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        // 最大连接数
        poolConfig.setMaxTotal(100);
        // 最大空闲数
        poolConfig.setMaxIdle(10);
        // 最大允许等待时间，如果超过这个时间还未获取到连接，则会报JedisException异常：
        // Could not get a resource from the pool
        poolConfig.setMaxWaitMillis(10000);
    
        JedisShardInfo jedisShardInfo1 = new JedisShardInfo("172.10.1.120", 9000);
        JedisShardInfo jedisShardInfo2 = new JedisShardInfo("172.10.1.121", 9001);
        JedisShardInfo jedisShardInfo3 = new JedisShardInfo("172.10.1.122", 9002);
        jedisShardInfo1.setPassword("xxxx");
        jedisShardInfo2.setPassword("xxxx");
        jedisShardInfo3.setPassword("xxxx");
        List<JedisShardInfo> list2 = new LinkedList<JedisShardInfo>();
        list2.add(jedisShardInfo1);
        list2.add(jedisShardInfo2);
        list2.add(jedisShardInfo3);
    
        ShardedJedisPool pool2 = new ShardedJedisPool(poolConfig, list2);
    
        ShardedJedis jedis2 = pool2.getResource();
    
        String name = jedis2.get("test_tmp");
        System.out.println(name);
        jedis2.set("test_tmp", "18");
        System.out.println(jedis2.get("test_tmp"));
    
        try {
            jedis2.close();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

2，修正，上面的代码验证之后有问题，redis集群里面运行不行，后代码为：

>     package com.dianyou.redis;
>     
>     import com.dianyou.constaints.Resources;
>     import org.apache.storm.shade.org.eclipse.jetty.util.ConcurrentHashSet;
>     import org.slf4j.LoggerFactory;
>     import redis.clients.jedis.HostAndPort;
>     import redis.clients.jedis.JedisCluster;
>     import redis.clients.jedis.JedisPoolConfig;
>     
>     import java.util.LinkedHashSet;
>     import java.util.Map;
>     import java.util.Properties;
>     import java.util.Set;
>     import java.util.concurrent.ConcurrentHashMap;
>     
>     
>     public class RedisConnUtil {
>     
>     
>         /**
>          * todo 集群版本
>          */
>         private static org.slf4j.Logger logger = LoggerFactory.getLogger(RedisConnUtil.class);
>         private static JedisCluster jedisCluster = null;
>         private static Properties redisPro = Resources.redisPro;
>     
>     
>         public synchronized static JedisCluster getJedisCluster() throws Exception{
>     
>     
>             String serverip = redisPro.getProperty("serverip").trim();
>             String password = redisPro.getProperty("password").trim();
>             JedisPoolConfig poolConfig = new JedisPoolConfig();
>             // 最大连接数
>             poolConfig.setMaxTotal(300);
>             // 最大空闲数
>             poolConfig.setMaxIdle(10);
>             // 最大允许等待时间，如果超过这个时间还未获取到连接，则会报JedisException异常：
>             poolConfig.setMaxWaitMillis(5000);
>             Set<HostAndPort> nodes = new LinkedHashSet<HostAndPort>();
>             String[] serveripArray = serverip.split(",");
>             for (String str : serveripArray) {
>                 String ip = str.split(":")[0];
>                 int port = Integer.parseInt(str.split(":")[1]);
>                 nodes.add(new HostAndPort(ip, port));
>             }
>             // 只有当jedisCluster为空时才实例化
>             if (jedisCluster == null) {
>                 jedisCluster = new JedisCluster(nodes, 3000, 3000, 5, password, poolConfig);
>             }
>     
>     
>             return jedisCluster;
>         }
>     
>         public static JedisCluster getJedis() {
>             try {
>                 if (jedisCluster == null) {
>                     jedisCluster = getJedisCluster();
>                 }
>             } catch (Exception ex) {
>                 ex.printStackTrace();
>                 logger.error("##### redis失去连接..........");
>                 jedisCluster = null;
>     
>             }
>              return jedisCluster;
>         }
>     
>         public static Map<String, String> hgetAll(String key) {
>             Map<String, String> resultMap = new ConcurrentHashMap<>();
>             JedisCluster jedis = null;
>             try {
>                 jedis = getJedis();
>                 if (jedis != null) {
>                     resultMap = jedis.hgetAll(key);
>                 } else {
>                     return null;
>                 }
>     
>             } catch (Exception ex) {
>                 ex.printStackTrace();
>                 logger.error("redis jedis对象为null..........");
>             }
>             return resultMap;
>         }
>     
>     
>         public static Set<String> getBlockSet(String key) {
>             Set<String> blockSet = new ConcurrentHashSet<>();
>             JedisCluster jedis = null;
>             try {
>                 jedis = getJedis();
>                 if (jedis != null) {
>                     blockSet = jedis.smembers(key);
>                 } else {
>                     return null;
>                 }
>     
>             } catch (Exception ex) {
>                 logger.error("redis jedis对象为null..........");
>                 return null;
>             }
>             return blockSet;
>         }
>     
>     
>     }