SpringBoot+Redis哨兵模式的實(shí)現(xiàn)
最近學(xué)習(xí)到了Redis的哨兵模式，光看視頻還不行，需要自己動(dòng)手實(shí)現(xiàn)一遍才能加深映像，特此記錄。
由于沒有真實(shí)的服務(wù)器可以供我操作，所以在虛擬機(jī)上啟動(dòng)了3個(gè)redis服務(wù)，分別占用7001、7002、7003端口。
Redis下載安裝不多贅述，只在這里記錄一下配置。
首先在tmp目錄下創(chuàng)建3個(gè)文件夾:
cd /tmp mkdir 7001 7002 7003
然后將redis的配置文件redis.conf拷貝到剛剛創(chuàng)建的3個(gè)文件夾下
cp redis-6.2.6/redis.conf /tmp/7001 cp redis-6.2.6/redis.conf /tmp/7002 cp redis-6.2.6/redis.conf /tmp/7003
接著修改這3個(gè)配置文件
vi redise.conf
找到端口，redis默認(rèn)端口是6379，這里分別將端口改為7001、7002和7003
然后修改dir，redis持久化文件保存的路徑，分別改為對(duì)應(yīng)的路徑
接著注釋掉bind并且修改protected-mode為no
redis默認(rèn)不允許遠(yuǎn)程連接，修改這2項(xiàng)配置允許我們遠(yuǎn)程連接
最后在配置文件第一行加上 replica-announce-ip #{ip}
注意：這里#{ip}填自己的ip地址
由于是在虛擬機(jī)安裝的redis，會(huì)有多個(gè)ip，這里寫明ip防止找不到
3個(gè)配置文件都改完后，cd 到對(duì)應(yīng)的目錄啟動(dòng)redis
3個(gè)服務(wù)都啟動(dòng)后，連接7002的redis
redis-cli -p 7002
輸入命令，搭建主從集群，讓7002成為7001的從節(jié)點(diǎn)
REPLICAOF #{ip} 7001注意：這里#{ip}填自己的ip地址
同理，7003也這樣操作一遍，這樣就搭建好了以7001為主節(jié)點(diǎn)，7002和7003位從節(jié)點(diǎn)的主從集群模式。
需要注意的是，以命令形式搭建的主從集群，重啟后就失效了，想要持久保持可以在配置文件里配置，這里從簡就不貼了。
上述操作完成后，接著在tmp目錄下創(chuàng)建3個(gè)新文件夾
mkdir s1 s2 s3
cd到s1目錄，創(chuàng)建文件sentinel.conf，這個(gè)文件也可以從redis的目錄中拷貝。
編寫文件配置
# sentinel端口
port 27001
#工作路徑
dir "/tmp/s1"
# 哨兵監(jiān)控的master，主從配置一樣，在進(jìn)行主從切換時(shí)7001會(huì)變成當(dāng)前的master端口,最后的2為客觀判斷主節(jié)# 點(diǎn)下線的節(jié)點(diǎn)個(gè)數(shù)
sentinel monitor mymaster #{ip} 7001 2
# master或slave多長時(shí)間不能使用后標(biāo)記為s_down狀態(tài)
sentinel down-after-milliseconds mymaster 5000
#若sentinel在該配置值內(nèi)未能完成failover操作（即故障時(shí)master/slave自動(dòng)切換），
#則認(rèn)為本次failover失敗
sentinel failover-timeout mymaster 60000注意：這里#{ip}填自己的ip地址
然后將sentinel.conf文件cp到s2和s3路徑下，只用修改port和dir為各自的配置
然后分別在各自路徑下啟動(dòng)3個(gè)哨兵
redis-sentinel sentinel.conf
由于之前測試了7001關(guān)閉服務(wù)，哨兵自動(dòng)切換主節(jié)點(diǎn)為7002了，若為第一次啟動(dòng)，日志和截圖中的會(huì)稍有不同。
哨兵模式搭建好后，接著在Java端集成此模式
pom.xml引入最基本的依賴即可
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions><!-- 去掉springboot默認(rèn)配置 -->
<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地址
在一個(gè)配置類里注入一個(gè)bean，實(shí)現(xiàn)redis讀寫分離，配置從redis讀數(shù)據(jù)時(shí)優(yōu)先從從節(jié)點(diǎn)讀取
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
*/
@Configuration
public 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;
}
}編寫一個(gè)測試接口
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
*/
@RestController
public 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));
}
}啟動(dòng)springboot，調(diào)用set接口
查看redis
7002主節(jié)點(diǎn)有值了，并且它的從節(jié)點(diǎn)也同步到了數(shù)據(jù)
然后調(diào)用get接口
數(shù)據(jù)也成功獲取到了
最后測試一下哨兵自動(dòng)切換主從節(jié)點(diǎn)，這里關(guān)閉7002的redis
接著查看27002哨兵打印的日志
從日志中可以看到關(guān)閉7002的redis后，哨兵自動(dòng)將主節(jié)點(diǎn)切換到了7001的redis
現(xiàn)在啟動(dòng)7002的redis
查看哨兵27001的日志
可以發(fā)現(xiàn)由將7002加入到了自己的從節(jié)點(diǎn)中
自此，Redis哨兵模式的簡單搭建就完成了
到此這篇關(guān)于SpringBoot+Redis哨兵模式的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)SpringBoot Redis哨兵模式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
迅速學(xué)會(huì)@ConfigurationProperties的使用操作
這篇文章主要介紹了迅速學(xué)會(huì)@ConfigurationProperties的使用，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-10-10
SpringBoot整合Quartz實(shí)現(xiàn)動(dòng)態(tài)配置的代碼示例
這篇文章將介紹如何把Quartz定時(shí)任務(wù)做成接口，實(shí)現(xiàn)以下功能的動(dòng)態(tài)配置添加任務(wù)，修改任務(wù)，暫停任務(wù)，恢復(fù)任務(wù)，刪除任務(wù)，任務(wù)列表，任務(wù)詳情，文章通過代碼示例介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
java selenium教程環(huán)境搭建基于Maven
本文主要介紹Java selenium 環(huán)境的安裝,這里介紹了基于Maven的環(huán)境搭建，有需要的小伙伴可以參考下2016-08-08
Springboot集成Kafka進(jìn)行批量消費(fèi)及踩坑點(diǎn)
本文主要介紹了Springboot集成Kafka進(jìn)行批量消費(fèi)及踩坑點(diǎn)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-12-12
在我們?nèi)粘Ｊ褂胘son序列化框架過程中，經(jīng)常會(huì)遇到在輸出json字符串時(shí)，忽略某些字段，那么在Gson框架中，要想實(shí)現(xiàn)這種方式，可以怎么處理呢，本文就來介紹一下2021-10-10
Java中的異常處理(try,catch,finally,throw,throws)
本文主要介紹了Java中的異常處理，文章主要介紹的異常處理包括5個(gè)關(guān)鍵字try,catch,finally,throw,throws，更多詳細(xì)內(nèi)容需要的朋友可以參考一下2022-06-06
Netty分布式pipeline管道傳播事件的邏輯總結(jié)分析
這篇文章主要為大家介紹了Netty分布式pipeline管道傳播事件總結(jié)分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-03-03
本文主要介紹了SpringCloud如何解決服務(wù)之間的通信問題，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-08-08
這篇文章主要介紹了Springboot內(nèi)置的工具類之StringUtils的使用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧2022-12-12
Mybatis Plus 代碼生成器的實(shí)現(xiàn)
這篇文章主要介紹了Mybatis Plus 代碼生成器的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-03-03