springboot集成redis哨兵集群的实现示例

 更新时间:2023年08月06日 11:16:39   作者:渣渣→_→  
本文主要介绍了springboot集成redis哨兵集群的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

前言

redis主从集群和redis sentinel集群都配置完毕了, 现在我们需要了解spring boot 如何连接上该集群

才能用上这两个集群带来的便利

本章内容

  • 为什么需要关注这个问题?
  • 怎么配置?

记住. 本章是针对redis已经配置了主从集群和哨兵集群的, 而非cluster集群模式

为什么需要关注这个问题?

没有 Redis Sentinel 架构之前,如果主节点挂了,需要运维人员手动进行主从切换,然后更新所有用到的 Redis IP 地址参数再重新启动系统,所有恢复操作都需要人为干预,如果半夜挂了,如果系统很多,如果某个操作搞错了,等等,这对运维人员来说简直就是恶梦。

有了 Redis Sentinel,主从节点故障都是自动化切换,应用程序参数什么也不用改,对于客户端来说都是透明无缝切换的,运维人员再也不用担惊受怕了。

怎么配置?

看看源码分析分析

我们需要注意redis中springboot的这个接口

也就是RedisConnectionFactory这个接口

可以看到三个函数, 分别拿到

  • redis集群的Connection
  • 单机redis的Connection
  • 哨兵方式的Connection

如果你写过springboot整合redis的hello world 项目的话, 你会发现, springboot默认使用

LettuceConnectionFactory

同时我们通过在 application.yml 上的 spring.redis 字符串找到

org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration

可以看到下面的这个Bean配置

优先级已经决定了, sentinel > cluster > 单机 方式

进入getSentinelConfig函数

protected final RedisSentinelConfiguration getSentinelConfig() {
   if (this.sentinelConfiguration != null) {
      return this.sentinelConfiguration;
   }
   RedisProperties.Sentinel sentinelProperties = this.properties.getSentinel();
   if (sentinelProperties != null) {
      RedisSentinelConfiguration config = new RedisSentinelConfiguration();
      config.master(sentinelProperties.getMaster());
      config.setSentinels(createSentinels(sentinelProperties));
      config.setUsername(this.properties.getUsername());
      if (this.properties.getPassword() != null) {
         config.setPassword(RedisPassword.of(this.properties.getPassword()));
      }
      config.setSentinelUsername(sentinelProperties.getUsername());
      if (sentinelProperties.getPassword() != null) {
         config.setSentinelPassword(RedisPassword.of(sentinelProperties.getPassword()));
      }
      config.setDatabase(this.properties.getDatabase());
      return config;
   }
   return null;
}

上面可以看到 password 和 sentinelPassword 是可选的

跳到RedisProperties.Sentinel 就看到

配置

sentinel:
  master: mymaster
  password: 123456
  nodes:
    - 192.168.7.5:26379
    - 192.168.7.6:26380
    - 192.168.7.7:26381

完整application.yml

server:
  port: 8081
spring:
  application:
    name: redis-data-demo
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/hmdp?useSSL=false&serverTimezone=UTC
    username: root
    password: 123456
  redis:
    host: 127.0.0.1
    port: 6379
    lettuce:
      pool:
        max-active: 10
        max-idle: 10
        min-idle: 1
        time-between-eviction-runs: 10s
        enabled: true
    sentinel:
      master: mymaster
      password: 123456
      nodes:
        - 192.168.7.5:26379
        - 192.168.7.6:26380
        - 192.168.7.7:26381
  jackson:
    default-property-inclusion: non_null
    date-format: yyyy-MM-dd HH:mm:ss
    serialization:
      WRITE_DATES_AS_TIMESTAMPS: false
    deserialization:
      READ_DATE_TIMESTAMPS_AS_NANOSECONDS: false
  #  cache:
  #    type: redis
  #    redis:
  #      time-to-live: 1800 # 全局 key 过期时间
  #      cache-null-values: true
  main:
    allow-circular-references: true
  rabbitmq:
    host: 127.0.0.1
    username: zhazha
    password: 123456
    virtual-host: /
    listener:
      simple:
        acknowledge-mode: manual
        retry:
          enabled: true
          initial-interval: 300
          max-attempts: 3
          max-interval: 1000
    publisher-returns: true
    publisher-confirm-type: correlated
mybatis-plus:
  type-aliases-package: com.zhazha.entity
  global-config:
    banner: off
logging:
  level:
    com.zhazha: debug

在项目的启动类中,添加一个新的bean:

@Bean
public LettuceClientConfigurationBuilderCustomizer clientConfigurationBuilderCustomizer(){
    return clientConfigurationBuilder -> clientConfigurationBuilder.readFrom(ReadFrom.REPLICA_PREFERRED);
}

这个bean中配置的就是读写策略,包括四种:

  • MASTER:从主节点读取
  • MASTER_PREFERRED:优先从master节点读取,master不可用才读取replica
  • REPLICA:从slave(replica)节点读取
  • REPLICA_PREFERRED:优先从slave(replica)节点读取,所有的slave都不可用才读取master

其他操作不需要修改

到此这篇关于springboot集成redis哨兵集群的实现示例的文章就介绍到这了,更多相关springboot redis哨兵集群内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • java实现多客户聊天功能

    java实现多客户聊天功能

    这篇文章主要为大家详细介绍了java实现多客户聊天功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08
  • Springboot 整合 RabbitMQ 消息队列 详情

    Springboot 整合 RabbitMQ 消息队列 详情

    这篇文章主要介绍了Springboot整合RabbitMQ 消息队列详情,文章为荣啊主题展开详细的内容介绍,具有一定的参考价值,需要的小伙伴可以参考一下
    2022-08-08
  • Java(springboot) 读取txt文本内容代码实例

    Java(springboot) 读取txt文本内容代码实例

    这篇文章主要介绍了Java(springboot) 读取txt文本内容代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • Java经典面试题汇总--多线程

    Java经典面试题汇总--多线程

    本篇总结的是Java多线程相关的面试题,后续会持续更新,希望我的分享可以帮助到正在备战面试的实习生或者已经工作的同行,如果发现错误还望大家多多包涵,不吝赐教,谢谢
    2021-06-06
  • RESTful API设计原则与实现示例详解

    RESTful API设计原则与实现示例详解

    这篇文章主要为大家介绍了RESTful API设计原则与实现示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-04-04
  • 深度剖析Java中的内存原型及工作原理

    深度剖析Java中的内存原型及工作原理

    这篇文章主要介绍了深度剖析Java中的内存原型及工作原理,本文讲解了java虚拟机内存原型、常量池、Java内存分配中的栈、Java内存分配中的堆等内容,需要的朋友可以参考下
    2015-01-01
  • Java中ByteArrayInputStream和ByteArrayOutputStream用法详解

    Java中ByteArrayInputStream和ByteArrayOutputStream用法详解

    这篇文章主要介绍了Java中ByteArrayInputStream和ByteArrayOutputStream用法详解, ByteArrayInputStream 的内部额外的定义了一个计数器,它被用来跟踪 read() 方法要读取的下一个字节
    2022-06-06
  • Java使用自定义注解实现为事件源绑定事件监听器操作示例

    Java使用自定义注解实现为事件源绑定事件监听器操作示例

    这篇文章主要介绍了Java使用自定义注解实现为事件源绑定事件监听器操作,结合实例形式分析了java自定义注解、注解处理、事件监听与响应等相关操作技巧,需要的朋友可以参考下
    2019-10-10
  • Java字符串详解的实例介绍

    Java字符串详解的实例介绍

    本篇文章介绍了,在Java中关于字符串详解一些实例操作,需要的朋友参考下
    2013-04-04
  • SSH框架网上商城项目第11战之查询和删除商品功能实现

    SSH框架网上商城项目第11战之查询和删除商品功能实现

    这篇文章主要为大家详细介绍了SSH框架网上商城项目第11战之查询和删除商品功能实现的相关资料,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-06-06

最新评论