Spring+Redis+Sentinel

Posted 2020-06-14

master：192.168.25.129:6379

slave:192.168.25.129:6380,192.168.25.130:6379,192.168.25.130:6380

 

jar包：jedis-2.5.2,spring-data-redis-1.4.1.RELEASE

spring配置文件：

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
 6     xmlns:aop="http://www.springframework.org/schema/aop"
 7     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
 8             http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">
 9     <bean id="propertyConfigurer"
10           class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
11         <property name="locations">
12             <list>
13                 <value>classpath:redis.properties</value>
14             </list>
15         </property>
16     </bean>
17     <bean id="redisSentinelConfiguration"
18           class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
19         <property name="master">
20             <bean class="org.springframework.data.redis.connection.RedisNode">
21                 <property name="name" value="mymaster"></property>
22             </bean>
23         </property>
24         <property name="sentinels">
25             <set>
26                 <bean class="org.springframework.data.redis.connection.RedisNode">
27                     <constructor-arg index="0" value="${redis1.ip}" />
28                     <constructor-arg index="1" value="${redis1.port}" />
29                 </bean>
30                 <bean class="org.springframework.data.redis.connection.RedisNode">
31                     <constructor-arg index="0" value="${redis2.ip}" />
32                     <constructor-arg index="1" value="${redis2.port}" />
33                 </bean>
34             </set>
35         </property>
36     </bean>
37 
38     <bean id="jedisConnFactory"
39           class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
40         <property name="hostName" value="192.168.25.129"/>
41         <property name="port" value="6379"/>
42         <property name="usePool" value="false"/>
43         <constructor-arg ref="redisSentinelConfiguration" />
44     </bean>
45 
46     <bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
47         <property name="connectionFactory" ref="jedisConnFactory" />
48     </bean>
49 </beans>

View Code

 

redis.properties:

1 redis1.ip=192.168.25.129
2 redis1.port=26379
3 
4 redis2.ip=192.168.25.130
5 redis2.port=26379

View Code

 

测试代码：

 1 public class RedisTest {
 2 
 3     public static void main(String[] args) {
 4         ConfigurableApplicationContext ctx = null;
 5         try {
 6              ctx = new ClassPathXmlApplicationContext("applicationContext_redis_sentinel.xml");
 7             final StringRedisTemplate redisTemplate = ctx.getBean(StringRedisTemplate.class);
 8 
 9             new Thread(new Runnable() {
10                 @Override
11                 public void run() {
12                     int loopNum = 60;
13                     while (loopNum-->0) {
14                         redisTemplate.opsForValue().set("win_time",new SimpleDateFormat("yyyy/MM/dd HH:mm:ss").format(new Date()));
15                         System.out.println(redisTemplate.opsForValue().get("win_time"));
16                         try {
17                             Thread.sleep(1000);
18                         } catch (InterruptedException e) {
19                             e.printStackTrace();
20                         }
21                     }
22                 }
23             }).start();
24 
25             // 写入bean
26             JedisConnectionFactory jedisConnectionFactory = ctx.getBean(JedisConnectionFactory.class);
27             ObjectRedisTemplate userRedisTemplate = new ObjectRedisTemplate(jedisConnectionFactory,User.class);
28             User user = new User();
29             user.setId(1);
30             user.setName("test");
31             userRedisTemplate.opsForValue().set("user1",user);
32             System.out.println(userRedisTemplate.opsForValue().get("user1"));
33         } catch(Exception e) {
34             e.printStackTrace();
35         } finally {
36             if (ctx != null && ctx.isActive()) {
37                 ctx.close();
38             }
39         }
40 
41     }
42 
43     static class User implements Serializable {
44         private int id;
45         private String name;
46 
47         public int getId() {
48             return id;
49         }
50 
51         public void setId(int id) {
52             this.id = id;
53         }
54 
55         public String getName() {
56             return name;
57         }
58 
59         public void setName(String name) {
60             this.name = name;
61         }
62 
63         @Override
64         public String toString() {
65             return "User{" +
66                     "id=" + id +
67                     ", name=‘" + name + ‘\‘‘ +
68                     ‘}‘;
69         }
70     }
71 }

View Code

 

有几个问题：

1）JedisConnecitonFactory的配置中必须指定hostName和Port，否则就使用的默认值localhost和6379;

2）使用redis-cli -p 6379 shutdown使master宕掉后，程序执行出错，没法连接redis；

3）即便2没有问题，自动切换到了新的master，因为1中指定了master的ip和port，那么程序重启就连不上redis。