spring redis sentinel,spring boot sentinel

　　roupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies> <build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

修改application.properties配置文件

配置文件添加内容如下:

###########################################################REDIS (RedisProperties) redis基本配置；######################################################### database namespring.redis.database=0# server host1 单机使用，对应服务器ip#spring.redis.host=127.0.0.1 # server password 密码，如果没有设置可不配#spring.redis.password=#connection port 单机使用，对应端口号#spring.redis.port=6379# pool settings ...池配置spring.redis.pool.max-idle=8spring.redis.pool.min-idle=0spring.redis.pool.max-active=8spring.redis.pool.max-wait=-1# name of Redis server 哨兵监听的Redis server的名称spring.redis.sentinel.master=mymaster# comma-separated list of host:port pairs 哨兵的配置列表spring.redis.sentinel.nodes=127.0.0.1:26379,127.0.0.1:26479,127.0.0.1:26579

新建Redis服务

package com.chhliu.springboot.redis; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.stereotype.Service; @Service("redisService")public class RedisService {@Autowired //操作字符串的template，StringRedisTemplate是RedisTemplate的一个子集private StringRedisTemplate stringRedisTemplate;@Autowired // RedisTemplate，可以进行所有的操作 private RedisTemplate<Object,Object> redisTemplate; public void set(String key, String value){stringRedisTemplate.opsForValue().set(key, value);}public void set(Student s){redisTemplate.opsForValue().set(s.getId(), s);}public String get(String key){return stringRedisTemplate.opsForValue().get(key);}public Student getStudent(String key){return (Student) redisTemplate.opsForValue().get(key);}}

依赖的vo如下：

package com.chhliu.springboot.redis; import java.io.Serializable; public class Student implements Serializable{ /** * */private static final long serialVersionUID = 1L;private String id;private String name;private String age;private String grade; // 省略getter,setter/** * attention: * Details：TODO * @author chhliu * 创建时间：2017-1-18 下午2:24:39 * @return */@Overridepublic String toString() {return "Student [id=" + id + ", name=" + name + ", age=" + age+ ", grade=" + grade + "]";}}

测试类

package com.chhliu.springboot.redis; import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.test.context.junit4.SpringRunner; @RunWith(SpringRunner.class)@SpringBootTestpublic class SpringbootRedisApplicationTests {@Autowiredprivate RedisService service; @Testpublic void contextLoads() {service.set("myname", "chhliu");Student s = new Student();s.setId("001");s.setName("chhliu");s.setGrade("一年级");s.setAge("28");service.set(s);String name = service.get("myname");System.out.println("name:"+name);Student stu = service.getStudent("001");System.out.println(stu);} }

测试结果

name:chhliu

 

　　Student [id=001, name=chhliu, age=28, grade=一年级]

　　

redis哨兵模式sentinel与springboot集成

Redis的哨兵模式是官方提供的一种高可用解决方案，而且配置非常简单。

安装Redis集群

本文使用redis-5.0.5，redis安装在/soft/redis目录下，需新建/soft/redis/data目录

　　主节点配置

　　vim config/redis-6379.conf

# bind 127.0.0.1 port 6379protected-mode nodaemonize yespidfile "/var/run/redis_6379.pid"dir "/soft/redis/data"dbfilename "dump-6379.rdb"logfile "log-6379.log"

从节点1配置

　　vim config/redis-6380.conf

# bind 127.0.0.1port 6380protected-mode nodaemonize yespidfile "/var/run/redis_6380.pid"dir "/soft/redis/data"dbfilename "dump-6380.rdb"logfile "log-6380.log" replicaof 192.168.4.176 6379

从节点2配置

　　vim config/redis-6381.conf

# bind 127.0.0.1port 6381protected-mode nodaemonize yespidfile "/var/run/redis_6381.pid"dir "/soft/redis/data"dbfilename "dump-6381.rdb"logfile "log-6381.log" replicaof 192.168.4.176 6379

配置说明

　　# bind 127.0.0.1 注释掉这配置，以便其他机器的能连接redis

　　protected-mode no 关闭保护模式，以便其他机器的能连接redis

　　daemonize后台模式启动

　　redis-v5版本使用replicaof替换旧的slaveof指令。

　　启动这3个节点，在/soft/redis目录下运行

redis-server config/redis-6379.confredis-server config/redis-6380.confredis-server config/redis-6381.conf

打开主节点客户端看看配置是否成功

redis-cli -p 6379info replication

　　再配置3个哨兵，监控集群

　　哨兵节点1

　　vim config/redis-sentinel-26379.conf

port 26379daemonize yespidfile "/var/run/redis-sentinel-26379.pid"dir /tmplogfile "log-sentinel-26379.log"sentinel monitor mymaster 192.168.4.176 6379 2sentinel down-after-milliseconds mymaster 30000sentinel parallel-syncs mymaster 1sentinel failover-timeout mymaster 180000sentinel deny-scripts-reconfig yes

哨兵节点2

　　vim config/redis-sentinel-26380.conf

port 26380daemonize yespidfile "/var/run/redis-sentinel-26380.pid"dir /tmplogfile "log-sentinel-26380.log"sentinel monitor mymaster 192.168.4.176 6379 2sentinel down-after-milliseconds mymaster 30000sentinel parallel-syncs mymaster 1sentinel failover-timeout mymaster 180000sentinel deny-scripts-reconfig yes

哨兵节点3

　　vim config/redis-sentinel-26381.conf

port 26381daemonize yespidfile "/var/run/redis-sentinel-26381.pid"dir /tmplogfile "log-sentinel-26381.log"sentinel monitor mymaster 192.168.4.176 6379 2sentinel down-after-milliseconds mymaster 30000sentinel parallel-syncs mymaster 1sentinel failover-timeout mymaster 180000sentinel deny-scripts-reconfig yes

配置说明

monitor mymaster 192.168.4.176 6379 2

mymaster是master的名称，192.168.4.176是master主机ip。后面的2表示有2个sentinel认为master下线了，则线下master，建议设置为 sentinel节点数/2 + 1

down-after-milliseconds

发送ping请求给redis节点，在指定时间内未收到回复，则认为该节点应该被下线

parallel-syncs

在执行故障转移时，最多可以有多少个从节点同时对新的主服务器进行同步。

　　启动哨兵

redis-sentinel config/redis-sentinel-26379.confredis-sentinel config/redis-sentinel-26380.confredis-sentinel config/redis-sentinel-26381.conf

配置spring-boot

　　pom.xml中导入依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency>

application.properties加入两行配置

# 使用哨兵模式不能加以下两行配置，其他配置可以加# spring.redis.host=192.168.4.176# spring.redis.port=6379 spring.redis.sentinel.master=mymasterspring.redis.sentinel.nodes=192.168.4.176:26379, 192.168.4.176:26380, 192.168.4.176:26381

写一个测试类运行

@RunWith(SpringRunner.class)@SpringBootTestpublic class Sentinel001 { @Autowired RedisTemplate redisTemplate; @Test public void test001() throws Exception{ while (true){ String key = "time:" + new Date().getTime(); redisTemplate.opsForValue().set(key, new Date().getTime()); TimeUnit.MILLISECONDS.sleep(100L); System.out.println(redisTemplate.opsForValue().get(key)); } } }

然后杀掉master实例（端口号为6379的redis）的进程

ps -efgrep rediskill -9 11110

观察代码编辑器控制台输出，经过短暂的时间（大概是50s）后，程序重新运行正常

　　在6380和6381节点执行info replication，发现6381变成了主节点

　　查看下6380、6381的配置文件

cat config/redis-6380.confreplicaof 192.168.4.176 6381replicaof 变成了192.168.4.176 6381，而不是刚开始配置时的192.168.4.176 6379cat config/redis-6381.conf replicaof 的配置被删除了

重启下6379这个redis实例

redis-server config/redis-6379.conf

6379变成了6381的从节点

　　有个比较坑爹的事情，RedisTemplate未实现读写分离，读写都是操作master节点。运行上面的代码，在3个redis客户端运行monitor发现，只有master会运行get、set命令，从节点只运行了set命令。

　　以上为个人经验，希望能给大家一个参考，也希望大家多多支持盛行IT。

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。