java操作redis集群配置[可配置密码]和工具类

Posted lykbk

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java操作redis集群配置[可配置密码]和工具类相关的知识,希望对你有一定的参考价值。

java操作redis集群配置[可配置密码]和工具类

  1.  
    <dependency>
  2.  
    <groupId>redis.clients</groupId>
  3.  
    <artifactId>jedis</artifactId>
  4.  
    <version>2.9.0</version>
  5.  
    </dependency>
  6.  
    <dependency>
  7.  
    <groupId>org.apache.commons</groupId>
  8.  
    <artifactId>commons-pool2</artifactId>
  9.  
    <version>2.4.2</version>
  10.  
    </dependency>

版本:jedis2.9.0[此版本可以加入密码配置]+commons-pools2.4.2

 

 

配置:

 

  <context:property-placeholder ignore-unresolvable="true" location="classpath*:cache.properties"/>
  1.  
    <!-- 连接池配置 -->
  2.  
    <bean id="jedisConfig" class="redis.clients.jedis.JedisPoolConfig">
  3.  
    <!-- 最大连接数 -->
  4.  
    <property name="maxTotal" value="150" />
  5.  
    <!-- 最大空闲连接数 -->
  6.  
    <property name="maxIdle" value="50" />
  7.  
    <!-- 最小空闲连接数 -->
  8.  
    <property name="minIdle" value="10" />
  9.  
    <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
  10.  
    <property name="maxWaitMillis" value="3000" />
  11.  
    <!-- 每次释放连接的最大数目 -->
  12.  
    <property name="numTestsPerEvictionRun" value="100" />
  13.  
    <!-- 释放连接的扫描间隔(毫秒) -->
  14.  
    <property name="timeBetweenEvictionRunsMillis" value="3000" />
  15.  
    <!-- 连接最小空闲时间 -->
  16.  
    <property name="minEvictableIdleTimeMillis" value="1800000" />
  17.  
    <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
  18.  
    <property name="softMinEvictableIdleTimeMillis" value="10000" />
  19.  
    <!-- 在获取连接的时候检查有效性, 默认false -->
  20.  
    <property name="testOnBorrow" value="true" />
  21.  
    <!-- 在空闲时检查有效性, 默认false -->
  22.  
    <property name="testWhileIdle" value="true" />
  23.  
    <!-- 在归还给pool时,是否提前进行validate操作 -->
  24.  
    <property name="testOnReturn" value="true" />
  25.  
    <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
  26.  
    <property name="blockWhenExhausted" value="false" />
  27.  
    </bean>
  28.  
     
  29.  
     
  30.  
    <!-- jedis集群版配置 -->
  31.  
    <bean id="hostport1" class="redis.clients.jedis.HostAndPort">
  32.  
    <constructor-arg name="host" value="${redis.host}"/>
  33.  
    <constructor-arg name="port" value="${redis.port1}"/>
  34.  
    </bean>
  35.  
     
  36.  
    <bean id="hostport2" class="redis.clients.jedis.HostAndPort">
  37.  
    <constructor-arg name="host" value="${redis.host}"/>
  38.  
    <constructor-arg name="port" value="${redis.port2}"/>
  39.  
    </bean>
  40.  
     
  41.  
    <bean id="hostport3" class="redis.clients.jedis.HostAndPort">
  42.  
    <constructor-arg name="host" value="${redis.host}"/>
  43.  
    <constructor-arg name="port" value="${redis.port3}"/>
  44.  
    </bean>
  45.  
     
  46.  
    <bean id="hostport4" class="redis.clients.jedis.HostAndPort">
  47.  
    <constructor-arg name="host" value="${redis.host}"/>
  48.  
    <constructor-arg name="port" value="${redis.port4}"/>
  49.  
    </bean>
  50.  
     
  51.  
    <bean id="hostport5" class="redis.clients.jedis.HostAndPort">
  52.  
    <constructor-arg name="host" value="${redis.host}"/>
  53.  
    <constructor-arg name="port" value="${redis.port5}"/>
  54.  
    </bean>
  55.  
     
  56.  
    <bean id="hostport6" class="redis.clients.jedis.HostAndPort">
  57.  
    <constructor-arg name="host" value="${redis.host}"/>
  58.  
    <constructor-arg name="port" value="${redis.port6}"/>
  59.  
    </bean>
  60.  
     
  61.  
    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
  62.  
    <constructor-arg name="jedisClusterNode">
  63.  
    <set>
  64.  
    <ref bean="hostport1"/>
  65.  
    <ref bean="hostport2"/>
  66.  
    <ref bean="hostport3"/>
  67.  
    <ref bean="hostport4"/>
  68.  
    <ref bean="hostport5"/>
  69.  
    <ref bean="hostport6"/>
  70.  
    </set>
  71.  
    </constructor-arg>
  72.  
    <constructor-arg name="connectionTimeout" value="2000"/>
  73.  
    <constructor-arg name="soTimeout" value="2000"/>
  74.  
    <constructor-arg name="maxAttempts" value="3"/>
  75.  
    <constructor-arg name="password" value="${redis.clusterpassword}"/>
  76.  
    <constructor-arg name="poolConfig">
  77.  
    <ref bean="jedisConfig"/>
  78.  
    </constructor-arg>
  79.  
    </bean>
  80.  
    <bean id="jedisClientCluster" class="xx.xxx.xxxxx.xxxx.xxxx.JedisClientCluster"></bean>

 

创建cache.properties:

 

redis.host =192.168.xx.xxx
redis.port1=7001

redis.port2=7002

redis.port3=7003

redis.port4=7004

redis.port5=7005

redis.port6=7006

redis.clusterpassword=xxxxxxx

 

创建接口JedisClient:

 

  1.  
    import org.codehaus.jackson.type.TypeReference;
  2.  
     
  3.  
    import java.util.List;
  4.  
     
  5.  
    /**
  6.  
    * Created by gzy on 2017/11/17 17:16.
  7.  
    */
  8.  
     
  9.  
    public interface JedisClient {
  10.  
    String get(String key);
  11.  
     
  12.  
    <T> T get(String key, TypeReference<T> clazz);
  13.  
     
  14.  
    <T> T get(String key, Class<T> clazz);
  15.  
     
  16.  
    String get(String key, int select);
  17.  
     
  18.  
    void setAndExpire(String key, Object o, int expire);
  19.  
     
  20.  
    Long rpush(String key, String string);
  21.  
     
  22.  
    // Long del(String... keys);
  23.  
    Long lpush(String key, String string);
  24.  
     
  25.  
    void set(String key, Object o);
  26.  
     
  27.  
    String set(String key, String value);
  28.  
     
  29.  
    String hget(String hkey, String key);
  30.  
     
  31.  
    long hset(String hkey, String key, String value);
  32.  
     
  33.  
    long incr(String key);
  34.  
     
  35.  
    long expire(String key, int second);
  36.  
     
  37.  
    long ttl(String key);
  38.  
     
  39.  
    long del(String key);
  40.  
     
  41.  
    long hdel(String hkey, String key);
  42.  
     
  43.  
    Boolean exists(String key);
  44.  
     
  45.  
    Long decr(String key);
  46.  
     
  47.  
    List<String> brpop(int timeout, String key);
  48.  
     
  49.  
    }

 

jedisClient实现类JedisClientCluster:

 

  1.  
    /**
  2.  
    * Created by gzy on 2017/11/17 17:17.
  3.  
    */
  4.  
     
  5.  
    import org.codehaus.jackson.type.TypeReference;
  6.  
    import com.thinkgem.jeesite.common.utils.StringUtils;
  7.  
    import org.springframework.beans.factory.annotation.Autowired;
  8.  
     
  9.  
    import redis.clients.jedis.JedisCluster;
  10.  
     
  11.  
    import java.util.List;
  12.  
     
  13.  
    public class JedisClientCluster implements JedisClient {
  14.  
     
  15.  
    @Autowired
  16.  
    private JedisCluster jedisCluster;
  17.  
     
  18.  
    public <T> T get(String key, TypeReference<T> clazz) {
  19.  
    String json = jedisCluster.get(key);
  20.  
    if (StringUtils.isNotEmpty(json)) {
  21.  
    return JsonUtil.Json2Object(json, clazz);
  22.  
    } else {
  23.  
    return null;
  24.  
    }
  25.  
    }
  26.  
     
  27.  
    public <T> T get(String key, Class<T> clazz) {
  28.  
    String json = jedisCluster.get(key);
  29.  
    if (StringUtils.isNotEmpty(json)) {
  30.  
    return JsonUtil.Json2Object(json, clazz);
  31.  
    } else {
  32.  
    return null;
  33.  
    }
  34.  
    }
  35.  
     
  36.  
    public void set(String key, Object o) {
  37.  
    String json = JsonUtil.Object2Json(o);
  38.  
    jedisCluster.set(key, json);
  39.  
    }
  40.  
     
  41.  
    public void setAndExpire(String key, Object o, int expire) {
  42.  
    String json = JsonUtil.Object2Json(o);
  43.  
    jedisCluster.set(key, json);
  44.  
    jedisCluster.expire(key, expire);
  45.  
    }
  46.  
     
  47.  
    // public long del(String key) {
  48.  
    // return jedisCluster.del(key);
  49.  
    // }
  50.  
     
  51.  
    public String get(String key) {
  52.  
    return jedisCluster.get(key);
  53.  
    }
  54.  
     
  55.  
    public String get(String key, int select) {
  56.  
    jedisCluster.select(select);
  57.  
    return jedisCluster.get(key);
  58.  
    }
  59.  
     
  60.  
    @Override
  61.  
    public String set(String key, String value) {
  62.  
    return jedisCluster.set(key, value);
  63.  
    }
  64.  
     
  65.  
    @Override
  66.  
    public String hget(String hkey, String key) {
  67.  
    return jedisCluster.hget(hkey, key);
  68.  
    }
  69.  
     
  70.  
    @Override
  71.  
    public long hset(String hkey, String key, String value) {
  72.  
    return jedisCluster.hset(hkey, key, value);
  73.  
    }
  74.  
     
  75.  
    @Override
  76.  
    public long incr(String key) {
  77.  
    return jedisCluster.incr(key);
  78.  
    }
  79.  
     
  80.  
    public Long decr(String key) {
  81.  
    return jedisCluster.decr(key);
  82.  
    }
  83.  
     
  84.  
    @Override
  85.  
    public long expire(String key, int second) {
  86.  
    return jedisCluster.expire(key, second);
  87.  
    }
  88.  
     
  89.  
    @Override
  90.  
    public long ttl(String key) {
  91.  
    return jedisCluster.ttl(key);
  92.  
    }
  93.  
     
  94.  
    @Override
  95.  
    public long del(String key) {
  96.  
    return jedisCluster.del(key);
  97.  
    }
  98.  
     
  99.  
    @Override
  100.  
    public long hdel(String hkey, String key) {
  101.  
     
  102.  
    return jedisCluster.hdel(hkey, key);
  103.  
    }
  104.  
     
  105.  
    public Long rpush(String key, String string) {
  106.  
    return jedisCluster.rpush(key, string);
  107.  
    }
  108.  
     
  109.  
    public Long lpush(String key, String string) {
  110.  
    return jedisCluster.lpush(key, string);
  111.  
    }
  112.  
     
  113.  
    public Boolean exists(String key) {
  114.  
    return jedisCluster.exists(key);
  115.  
    }
  116.  
     
  117.  
    public List<String> brpop(int timeout, String key) {
  118.  
    return jedisCluster.brpop(timeout, key);
  119.  
    }
  120.  
     
  121.  
    }

 

创建测试类ClusterTest:

 

  1.  
    import xx.xx.xxx.xxxx.JedisClient;
  2.  
    import org.junit.Test;
  3.  
    import org.junit.runner.RunWith;
  4.  
    import org.springframework.beans.factory.annotation.Autowired;
  5.  
    import org.springframework.test.context.ContextConfiguration;
  6.  
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  7.  
     
  8.  
    /**
  9.  
    * Created by gzy on 2017/11/20 15:22.
  10.  
    */
  11.  
    @RunWith(SpringJUnit4ClassRunner.class)
  12.  
    @ContextConfiguration("classpath:spring-context-cache.xml")
  13.  
    public class ClusterTest {
  14.  
    // private static JedisClientCluster redisCluster = SpringContextHolder.getBean("jedisClientCluster");
  15.  
    @Autowired
  16.  
    private JedisClient jedisClient;
  17.  
     
  18.  
    @Test
  19.  
    public void testJCluster() {
  20.  
    jedisClient.set("test:phone:" + "11111111","hhha");
  21.  
    String result = jedisClient.get("test:phone:" + "11111111")
  22.  
    System.out.println("result==="+result)
  23.  
     
  24.  
    }}


 原文地址: https://blog.csdn.net/gzy_0922/article/details/78602716

注意:Redis集群并不支持处理多个keys的命令,因为这需要在不同的节点间移动数据,从而达不到像Redis那样的性能,在高负载的情况下可能会导致不可预料的错误.

以上是关于java操作redis集群配置[可配置密码]和工具类的主要内容,如果未能解决你的问题,请参考以下文章

redis集群设置密码详解

Redis6.0.9配置redis集群

Redis简单集群配置

redis集群的部署

Java中Redis缓存

Redis的集群配置