java项目中配置redis-cluster集群的两种方式

谁借莪１个温暖的怀抱￠ 2023-02-25 07:14 11阅读 0赞

本文分两部分：

（1）jedisCluster  
（2）Spring-Data-Redis集群配置和RedisTemplate用法

我这里是在本机上搭建的3主3从6个redis实例。

一，jedisCluster  
jar引入：

<dependency>  
    <groupId>redis.clients</groupId>  
    <artifactId>jedis</artifactId>  
    <version>2.4.2</version>  
</dependency>  
1  
2  
3  
4  
5  
连接集群测试：

@Test    
    public void testJedisCluster() throws Exception \{    
        // 第一步：使用JedisCluster对象。需要一个Set<HostAndPort>参数。Redis节点的列表。    
        Set<HostAndPort> nodes = new HashSet<>();    
        nodes.add(new HostAndPort("127.0.0.1", 7001));    
        nodes.add(new HostAndPort("127.0.0.1", 7002));    
        nodes.add(new HostAndPort("127.0.0.1", 7003));    
        nodes.add(new HostAndPort("127.0.0.1", 7004));    
        nodes.add(new HostAndPort("127.0.0.1", 7005));    
        nodes.add(new HostAndPort("127.0.0.1", 7006));    
        JedisCluster jedisCluster = new JedisCluster(nodes);    
        // 第二步：直接使用JedisCluster对象操作redis。在系统中单例存在。    
        jedisCluster.set("a", "1");    
        String result = jedisCluster.get("a");    
        // 第三步：打印结果    
        System.out.println(result);    
        // 第四步：系统关闭前，关闭JedisCluster对象。    
        jedisCluster.close();    
    \}    
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
基于Spring的配置：

<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">    
        <constructor-arg>    
            <set>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7001"></constructor-arg>    
                </bean>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7002"></constructor-arg>    
                </bean>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7003"></constructor-arg>    
                </bean>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7004"></constructor-arg>    
                </bean>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7005"></constructor-arg>    
                </bean>    
                <bean class="redis.clients.jedis.HostAndPort">    
                    <constructor-arg name="host" value="127.0.0.1"></constructor-arg>    
                    <constructor-arg name="port" value="7006"></constructor-arg>    
                </bean>    
            </set>    
        </constructor-arg>    
    </bean>    
    <bean id="jedisClientCluster" class="com.demo.jedis.JedisClientCluster"/>  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
接口定义：

public interface JedisClient \{

String set(String key, String value);    
    String get(String key);    
    Boolean exists(String key);    
    Long expire(String key, int seconds);    
    Long ttl(String key);    
    Long incr(String key);    
    Long hset(String key, String field, String value);    
    String hget(String key, String field);    
    Long hdel(String key, String... field);    
\}    
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
实现类:

public class JedisClientCluster implements JedisClient \{

@Autowired    
    private JedisCluster jedisCluster;

@Override    
    public String set(String key, String value) \{    
        return jedisCluster.set(key, value);    
    \}

@Override    
    public String get(String key) \{    
        return jedisCluster.get(key);    
    \}

@Override    
    public Boolean exists(String key) \{    
        return jedisCluster.exists(key);    
    \}

@Override    
    public Long expire(String key, int seconds) \{    
        return jedisCluster.expire(key, seconds);    
    \}

@Override    
    public Long ttl(String key) \{    
        return jedisCluster.ttl(key);    
    \}

@Override    
    public Long incr(String key) \{    
        return jedisCluster.incr(key);    
    \}

@Override    
    public Long hset(String key, String field, String value) \{    
        return jedisCluster.hset(key, field, value);    
    \}

@Override    
    public String hget(String key, String field) \{    
        return jedisCluster.hget(key, field);    
    \}

@Override    
    public Long hdel(String key, String... field) \{    
        return jedisCluster.hdel(key, field);    
    \}

\}    
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
最后可以在项目中直接使用接口类。

二，Spring-Data-Redis集群配置和RedisTemplate用法  
注意版本与spring版本最好相差不多，不然会报错。  
jar:

<dependency>  
            <groupId>org.springframework.data</groupId>  
            <artifactId>spring-data-redis</artifactId>  
            <version>1.7.11.RELEASE</version>  
        </dependency>  
        <dependency>  
            <groupId>redis.clients</groupId>  
            <artifactId>jedis</artifactId>  
            <version>2.8.2</version>  
        </dependency>  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
spring-data-redis.xml配置：

<description>Jedis Cluster Configuration</description>  
  
<context:property-placeholder  
    ignore-unresolvable="true" location="classpath:redis.cluster.properties" />  
  
<bean id="redisClusterConfiguration"  
    class="org.springframework.data.redis.connection.RedisClusterConfiguration">  
    <property name="maxRedirects" value="3"></property>  
      
    <property name="clusterNodes">  
        <set>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7001"></constructor-arg>  
            </bean>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7002"></constructor-arg>  
            </bean>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7003"></constructor-arg>  
            </bean>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7004"></constructor-arg>  
            </bean>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7005"></constructor-arg>  
            </bean>  
            <bean class="org.springframework.data.redis.connection.RedisClusterNode">  
                <constructor-arg name="host" value="127.0.0.1"></constructor-arg>  
                <constructor-arg name="port" value="7006"></constructor-arg>  
            </bean>  
        </set>  
    </property>  
</bean>  
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
    <property name="maxIdle" value="100" />  
    <property name="maxTotal" value="600" />  
</bean>  
<bean id="jeidsConnectionFactory"  
    class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">  
    <constructor-arg ref="redisClusterConfiguration" />  
    <constructor-arg ref="jedisPoolConfig" />  
</bean>  
  
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">  
    <property name="connectionFactory" ref="jeidsConnectionFactory" />  
</bean>  
1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
40  
41  
42  
43  
44  
45  
46  
47  
48  
49  
50  
51  
以上就是全部配置，可以使用模板操作：

@Autowired  
   private RedisTemplate redisTemplate;

https://blog.csdn.net/qq\_22860341/article/details/80706325