文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot+Redis哨兵模式的实现

2024-04-02 19:55

关注

最近学习到了Redis的哨兵模式,光看视频还不行,需要自己动手实现一遍才能加深映像,特此记录。

由于没有真实的服务器可以供我操作,所以在虚拟机上启动了3个redis服务,分别占用7001、7002、7003端口。

Redis下载安装不多赘述,只在这里记录一下配置。

首先在tmp目录下创建3个文件夹:

cd /tmp
mkdir 7001 7002 7003

然后将redis的配置文件redis.conf拷贝到刚刚创建的3个文件夹下

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个配置文件

vi redise.conf

找到端口,redis默认端口是6379,这里分别将端口改为7001、7002和7003

然后修改dir,redis持久化文件保存的路径,分别改为对应的路径

 接着注释掉bind并且修改protected-mode为no

redis默认不允许远程连接,修改这2项配置允许我们远程连接

最后在配置文件第一行加上 replica-announce-ip  #{ip}

注意:这里#{ip}填自己的ip地址

由于是在虚拟机安装的redis,会有多个ip,这里写明ip防止找不到

3个配置文件都改完后,cd 到对应的目录启动redis

 3个服务都启动后,连接7002的redis

redis-cli -p 7002

输入命令,搭建主从集群,让7002成为7001的从节点

REPLICAOF #{ip} 7001

注意:这里#{ip}填自己的ip地址

同理,7003也这样操作一遍,这样就搭建好了以7001为主节点,7002和7003位从节点的主从集群模式。

需要注意的是,以命令形式搭建的主从集群,重启后就失效了,想要持久保持可以在配置文件里配置,这里从简就不贴了。

上述操作完成后,接着在tmp目录下创建3个新文件夹

mkdir s1 s2 s3

cd到s1目录,创建文件sentinel.conf,这个文件也可以从redis的目录中拷贝。

编写文件配置

# sentinel端口
port 27001
#工作路径
dir "/tmp/s1"
# 哨兵监控的master,主从配置一样,在进行主从切换时7001会变成当前的master端口,最后的2为客观判断主节# 点下线的节点个数
sentinel monitor mymaster #{ip} 7001 2
# master或slave多长时间不能使用后标记为s_down状态
sentinel down-after-milliseconds mymaster 5000
#若sentinel在该配置值内未能完成failover操作(即故障时master/slave自动切换),
#则认为本次failover失败
sentinel failover-timeout mymaster 60000

注意:这里#{ip}填自己的ip地址

然后将sentinel.conf文件cp到s2和s3路径下,只用修改port和dir为各自的配置

然后分别在各自路径下启动3个哨兵

redis-sentinel sentinel.conf

 

 由于之前测试了7001关闭服务,哨兵自动切换主节点为7002了,若为第一次启动,日志和截图中的会稍有不同。

哨兵模式搭建好后,接着在Java端集成此模式

pom.xml引入最基本的依赖即可

<dependency>
     <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;
 

@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;
    }
}

编写一个测试接口

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;
 

@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));
    }
}

启动springboot,调用set接口

 查看redis

7002主节点有值了,并且它的从节点也同步到了数据

 然后调用get接口

 数据也成功获取到了

最后测试一下哨兵自动切换主从节点,这里关闭7002的redis

 接着查看27002哨兵打印的日志

 从日志中可以看到关闭7002的redis后,哨兵自动将主节点切换到了7001的redis

现在启动7002的redis

 查看哨兵27001的日志

 可以发现由将7002加入到了自己的从节点中

自此,Redis哨兵模式的简单搭建就完成了

到此这篇关于SpringBoot+Redis哨兵模式的实现示例的文章就介绍到这了,更多相关SpringBoot Redis哨兵模式内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯