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>

配置：

  <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那样的性能,在高负载的情况下可能会导致不可预料的错误.