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>
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>
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>
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>
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>
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>
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>
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;
3. import java.util.List;
5. /**
6. * Created by gzy on 2017/11/17 17:16.
7. */
9. public interface JedisClient {
10. String get(String key);
12. <T> T get(String key, TypeReference<T> clazz);
14. <T> T get(String key, Class<T> clazz);
16. String get(String key, int select);
18. void setAndExpire(String key, Object o, int expire);
20. Long rpush(String key, String string);
22. // Long del(String... keys);
23. Long lpush(String key, String string);
25. void set(String key, Object o);
27. String set(String key, String value);
29. String hget(String hkey, String key);
31. long hset(String hkey, String key, String value);
33. long incr(String key);
35. long expire(String key, int second);
37. long ttl(String key);
39. long del(String key);
41. long hdel(String hkey, String key);
43. Boolean exists(String key);
45. Long decr(String key);
47. List<String> brpop(int timeout, String key);
49. }

jedisClient实现类JedisClientCluster：

1. /**
2. * Created by gzy on 2017/11/17 17:17.
3. */
5. import org.codehaus.jackson.type.TypeReference;
6. import com.thinkgem.jeesite.common.utils.StringUtils;
7. import org.springframework.beans.factory.annotation.Autowired;
9. import redis.clients.jedis.JedisCluster;
11. import java.util.List;
13. public class JedisClientCluster implements JedisClient {
15. @Autowired
16. private JedisCluster jedisCluster;
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. }
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. }
36. public void set(String key, Object o) {
37. String json = JsonUtil.Object2Json(o);
38. jedisCluster.set(key, json);
39. }
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. }
47. // public long del(String key) {
48. // return jedisCluster.del(key);
49. // }
51. public String get(String key) {
52. return jedisCluster.get(key);
53. }
55. public String get(String key, int select) {
56. jedisCluster.select(select);
57. return jedisCluster.get(key);
58. }
60. @Override
61. public String set(String key, String value) {
62. return jedisCluster.set(key, value);
63. }
65. @Override
66. public String hget(String hkey, String key) {
67. return jedisCluster.hget(hkey, key);
68. }
70. @Override
71. public long hset(String hkey, String key, String value) {
72. return jedisCluster.hset(hkey, key, value);
73. }
75. @Override
76. public long incr(String key) {
77. return jedisCluster.incr(key);
78. }
80. public Long decr(String key) {
81. return jedisCluster.decr(key);
82. }
84. @Override
85. public long expire(String key, int second) {
86. return jedisCluster.expire(key, second);
87. }
89. @Override
90. public long ttl(String key) {
91. return jedisCluster.ttl(key);
92. }
94. @Override
95. public long del(String key) {
96. return jedisCluster.del(key);
97. }
99. @Override
100. public long hdel(String hkey, String key) {
102. return jedisCluster.hdel(hkey, key);
103. }
105. public Long rpush(String key, String string) {
106. return jedisCluster.rpush(key, string);
107. }
109. public Long lpush(String key, String string) {
110. return jedisCluster.lpush(key, string);
111. }
113. public Boolean exists(String key) {
114. return jedisCluster.exists(key);
115. }
117. public List<String> brpop(int timeout, String key) {
118. return jedisCluster.brpop(timeout, key);
119. }
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;
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;
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)
24. }}

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

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