spring boot redis 哨兵,spring boot redisson 哨兵配置
最近学习了Redis的哨兵模式。光看视频是不够的。需要自己动手,加深形象。特此记录。
由于没有真正的服务器供我操作,虚拟机上启动了三个redis服务,分别占用端口7001、7002和7003。
Redis下载安装不详细,这里只记录配置。
首先,在tmp目录中创建三个文件夹:
cd /tmpmkdir 7001 7002 7003
然后将redis的配置文件redis.conf复制到刚才创建的三个文件夹中。
cpredis-6 . 2 . 6/redis . conf/tmp/7001 credis-6 . 2 . 6/redis . conf/tmp/7002 credis-6 . 2 . 6/redis . conf/tmp/7003然后修改这三个配置文件。
Vi redise.conf找到了端口。redis的默认端口是6379。这里,端口分别更改为7001、7002和7003。
然后修改dir和redis持久文件保存的路径,分别改为对应的路径。
然后注释掉bind并将protected-mode改为no。
Redis默认不允许远程连接。修改这两个配置允许我们远程连接。
最后,将replica-announce-ip #{ip}添加到配置文件的第一行。
注意:这里#{ip}填自己的ip地址
因为redis安装在虚拟机中,所以会有多个IP,这里写IP是为了防止被发现。
在所有三个配置文件都被更改之后,cd到相应的目录来启动redis。
三个服务都启动后,连接到7002的redis。
Redis-cli -p 7002输入命令构建主从集群,使7002成为7001的从节点。
第{ip} 7001号注意:这里#{ip}填自己的ip地址的复制品
类似地,再次操作7003,从而建立以7001为主节点,7002和7003从节点的主从集群模式。
需要注意的是,以命令形式搭建的主从集群重启后会失效,如果想保持持久,可以在配置文件中配置,这里就不贴了。
完成上述操作后,在tmp目录中创建三个新文件夹。
Mkdir s1 s2 s3cd到s1目录,并创建文件sentinel.conf,也可以从redis目录复制。
写入文件配置
# sentinel port端口27001#工作路径dir /tmp/S1 # sentinel监控的master,主从配置相同,主从切换时7001会成为当前的master端口。最后2个是客观判断主节点离线的节点数# sentinel monitor my master # { IP } 7001 2 # master或slave,标记为s _ down state sentinel down-after-millions my master 5000 #如果sentinel未能在此配置值内完成故障切换操作(即故障时自动进行主/从切换),#则认为本次故障切换失败。Sentinel故障转移-超时我的主服务器60000注意:这里#{ip}填自己的ip地址
然后将sentinel.conf文件cp到s2和s3路径,只修改它们各自配置的端口和目录。
然后在各自的路径下启动三个岗哨。
redis-sentinel哨兵. conf
因为之前测试了7001关机服务,所以sentinel会自动将主节点切换到7002。如果是第一次开始,日志和截图会略有不同。
设置好sentinel模式后,在Java端集成这个模式。
Pom.xml引入了最基本的依赖关系。
属国
<groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <exclusions><!-- 去掉springboot默认配置 --> <exclusion> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-logging</artifactId> </exclusion> </exclusions></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.73</version></dependency>application.xml
spring: redis: sentinel: master: mymaster nodes: - #{ip}:27001 - #{ip}:27002 - #{ip}:27003
注意:这里#{ip}填自己的ip地址
在一个配置类里注入一个bean,实现redis读写分离,配置从redis读数据时优先从从节点读取
package com.wl.demo.config; import com.alibaba.fastjson.serializer.SerializerFeature;import com.alibaba.fastjson.support.config.FastJsonConfig;import com.alibaba.fastjson.support.spring.FastJsonRedisSerializer;import io.lettuce.core.ReadFrom;import org.springframework.boot.autoconfigure.data.redis.LettuceClientConfigurationBuilderCustomizer;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.StringRedisSerializer; /** * @author wl * @date 2022/3/28 */@Configurationpublic class RedisConfig { @Bean public LettuceClientConfigurationBuilderCustomizer lettuceClientConfigurationBuilderCustomizer() { return builder -> builder.readFrom(ReadFrom.REPLICA_PREFERRED); } @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(connectionFactory); FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class); FastJsonConfig fastJsonConfig = fastJsonRedisSerializer.getFastJsonConfig(); SerializerFeature[] serializerFeatures = new SerializerFeature[] {SerializerFeature.WriteDateUseDateFormat, SerializerFeature.WriteMapNullValue}; fastJsonConfig.setSerializerFeatures(serializerFeatures); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); redisTemplate.setKeySerializer(stringRedisSerializer); redisTemplate.setHashKeySerializer(stringRedisSerializer); redisTemplate.setHashValueSerializer(fastJsonRedisSerializer); redisTemplate.setValueSerializer(fastJsonRedisSerializer); redisTemplate.setEnableTransactionSupport(true); redisTemplate.afterPropertiesSet(); return redisTemplate; }}
编写一个测试接口
package com.wl.demo.controller; import com.wl.demo.common.result.HttpResult;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController; /** * @author wl * @date 2022/4/14 */@RestControllerpublic class TestController { private final StringRedisTemplate stringRedisTemplate; @Autowired public TestController(StringRedisTemplate stringRedisTemplate) { this.stringRedisTemplate = stringRedisTemplate; } @GetMapping("/set/{key}/{value}") public HttpResult setValue(@PathVariable("key") String key, @PathVariable("value") String value) { stringRedisTemplate.opsForValue().set(key, value); return HttpResult.success(); } @GetMapping("/get/{key}") public HttpResult getValue(@PathVariable("key") String key) { return HttpResult.success(stringRedisTemplate.opsForValue().get(key)); }}
启动springboot,调用set接口
查看redis
7002主节点有值了,并且它的从节点也同步到了数据
然后调用get接口
数据也成功获取到了
最后测试一下哨兵自动切换主从节点,这里关闭7002的redis
接着查看27002哨兵打印的日志
从日志中可以看到关闭7002的redis后,哨兵自动将主节点切换到了7001的redis
现在启动7002的redis
查看哨兵27001的日志
可以发现由将7002加入到了自己的从节点中
自此,Redis哨兵模式的简单搭建就完成了
到此这篇关于SpringBoot+Redis哨兵模式的实现示例的文章就介绍到这了,更多相关SpringBoot Redis哨兵模式内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT!
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。