redis集群 java dmeo

男娘i 2022-07-13 00:16 108阅读 0赞

package cn.tvm.shaketv.search.test;
    
    import java.io.IOException;
    import java.util.HashSet;
    import java.util.Set;
    
    import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
    
    import redis.clients.jedis.HostAndPort;
    import redis.clients.jedis.JedisCluster;
    
    public class RedisClusterTest { 
    
        private static RedisClusterTest redisClusterComponent = new RedisClusterTest();
    
        private static final String HOST = "192.168.38.59";
        /** * redisCluster客户端 */
            private JedisCluster redisCluster;
            /** * 客户端连接超时时间 */
            private final static int TIME_OUT = 3000;
    
            /** * soket超时时间 */
            private final static int SO_TIME_OUT = 3000;
    
            /** * 最大尝试次数 */
            private final static int MAX_ATTEMP = 5;
    
            private RedisClusterTest() {
                try {
                    // redis节点信息
                    Set<HostAndPort> nodeList = new HashSet<HostAndPort>();
                    nodeList.add(new HostAndPort(HOST, 7000));
                    nodeList.add(new HostAndPort(HOST, 7001));
                    nodeList.add(new HostAndPort(HOST, 7002));
                    nodeList.add(new HostAndPort(HOST, 7003));
                    nodeList.add(new HostAndPort(HOST, 7004));
                    nodeList.add(new HostAndPort(HOST, 7005));
                    //redisCluster = new JedisCluster(nodeList, getCommonPoolConfig()); 不需要密码
                    redisCluster = new JedisCluster(nodeList, TIME_OUT, 
                    SO_TIME_OUT, MAX_ATTEMP, "yao_ana#2015", getCommonPoolConfig());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            /** * pool配置 * @return */
            public static GenericObjectPoolConfig getCommonPoolConfig() {
                GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
                poolConfig.setMaxTotal(GenericObjectPoolConfig.DEFAULT_MAX_TOTAL * 10);
                poolConfig.setMaxIdle(GenericObjectPoolConfig.DEFAULT_MAX_IDLE * 5);
                poolConfig.setMinIdle(GenericObjectPoolConfig.DEFAULT_MAX_IDLE * 2);
                // JedisPool.borrowObject最大等待时间
                poolConfig.setMaxWaitMillis(1000L);
                // 开启jmx
                poolConfig.setJmxEnabled(true);
                return poolConfig;
            }
    
            public static RedisClusterTest getInstance() {
                return redisClusterComponent;
            }
    
            public void destroy() {
                if (redisCluster != null) {
                    try {
                        redisCluster.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
    
            public JedisCluster getRedisCluster() {
                return redisCluster;
            }
    
            public static void main(String[] args) {
                JedisCluster cluster = RedisClusterTest.getInstance().getRedisCluster();
                cluster.set("testkey","testvalue");
                System.out.println(cluster.get("testkey"));
            }
    }

说明：如果需要有密码的方式访问，最好是使用最新的redis架包  
例如maven最新的2.9.0版架包：

<dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
             <version>2.9.0</version>
             <type>jar</type>
        </dependency>