Redis主从复制和哨兵架构图,集成Spring Boot项目实战分享

目录

  • 1. Redis 主从复制
  • 2. Redis 哨兵架构
  • 3. 集成spring boot项目案列

Redis 主从复制和哨兵架构是 Redis 集群的重要组成部分,用于提高 Redis 集群的可用性和性能。以下是 Redis 主从复制和哨兵架构的详细介绍,包括架构图和 Java 代码详解。

1. Redis 主从复制

Redis 主从复制是通过节点间的异步复制实现的。在 Redis 集群中,每个主节点可以有多个从节点,每个从节点只能有一个主节点。当一个主节点接收到写入操作时,它会将这个操作记录在自己的本地数据库中,并将操作复制到所有从节点中。从节点通过复制积压缓冲区获取这些命令,并在本地执行它们,以保证从节点的数据和主节点的数据一致。
Redis 主从复制的架构图如下所示:

+--------------------+           +--------------------+  
|    Master        |<--------->|    Slave         |  
+--------------------+           +--------------------+  |                 |             |  |                 |             |  |                 |             |  
+--------------------+           +--------------------+  
|    Master        |<--------->|    Slave         |  
+--------------------+           +--------------------+  

在 Java 中,创建一个 Redis 主节点需要使用 RedisServer 类,创建一个 Redis 从节点需要使用 RedisSlave 类。以下是一个简单的 Java 代码示例,用于创建一个 Redis 主节点和一个从节点:

import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.RedisClient;
public class Main {  public static void main(String[] args) {  // 创建 Redis 主节点  RedisServer redisServer = new RedisServer(6379);  redisServer.start();// 创建 Redis 从节点  RedisClient slaveClient = new RedisClient(redisServer.getAddress(), 6379);  slaveClient.connect();// 执行主节点和从节点之间的同步  slaveClient.slaveOf(redisServer.getAddress(), 6379);  }  
}

2. Redis 哨兵架构

Redis 哨兵模式是在 Redis 主从的基础上进行升级的,它可以选举 master,并在 master 故障的时候进行切换。Redis 哨兵通过 sentinel.conf 配置文件来存放配置,其中包括 sentinel 的监听端口、master 的 IP 地址和端口号等信息。
Redis 哨兵架构图如下所示:

+--------------------+       +--------------------+  
|        Sentinel       |<--------->|    Master        |  
+--------------------+       +--------------------+  |                   |             |  |                   |             |  |                   |             |  
+--------------------+       +--------------------+  
|        Sentinel       |<--------->|    Master        |  
+--------------------+       +--------------------+  

在 Java 中,可以使用 RedisSentinel 类来创建一个 Redis 哨兵节点。以下是一个简单的 Java 代码示例,用于创建一个 Redis 哨兵节点:

import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.RedisClient;
public class Main {  public static void main(String[] args) {  // 创建 Redis 哨兵节点  RedisSentinel sentinel = new RedisSentinel("sentinel.conf");  sentinel.start();// 执行哨兵节点的同步  sentinel.syncConfig();  }  
}

综上所述,Redis 主从复制和哨兵架构是 Redis 集群的重要组成部分,它们可以提高 Redis 集群的可用性和性能。在 Java 中,可以使用 RedisServer、RedisClient 和 RedisSentinel 类来创建 Redis 主节点、从节点和哨兵节点。

3. 集成spring boot项目案列

Redis 主从复制和哨兵模式是 Redis 集群的基础架构,可以在多个节点之间同步数据,提高 Redis 的可用性和性能。在 Spring Boot 项目中,可以使用 Redis 的事务来实现分布式锁和并发控制等功能。
以下是一个简单的示例,展示如何在 Spring Boot 项目中集成 Redis 主从复制和哨兵模式:

  1. 首先,在 pom.xml 文件中添加对 Redis 依赖的配置:
<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-data-redis</artifactId>  
</dependency>  
  1. 创建 Redis 配置类,设置主从复制和哨兵模式的相关参数:
@Configuration  
@EnableTransactionManagement  
public class RedisConfig {@Bean  public RedisTemplate<String, Object> redisTemplate(JedisConnectionFactory jedisConnectionFactory) {  RedisTemplate<String, Object> template = new RedisTemplate<>();  template.setConnectionFactory(jedisConnectionFactory);  template.setEnableTransactionSupport(true);  return template;  }@Bean  public RedisSlave slave(JedisConnectionFactory jedisConnectionFactory) {  RedisSlave slave = new RedisSlave();  slave.setMasterAddress("localhost", 6379);  slave.setPassword("password");  slave.setDatabase(0);  jedisConnectionFactory.setSlaveOFlag(true);  return slave;  }@Bean  public RedisMaster master(JedisConnectionFactory jedisConnectionFactory) {  RedisMaster master = new RedisMaster();  master.setHostName("localhost");  master.setPort(6379);  master.setPassword("password");  master.setDatabase(0);  jedisConnectionFactory.setMasterOFlag(true);  return master;  }  
}

在配置类中,我们创建了 RedisTemplate、RedisSlave 和 RedisMaster 三个 bean。RedisTemplate 用于配置 Redis 连接和事务支持,RedisSlave 和 RedisMaster 用于配置从节点和主节点的相关参数。
3. 在 Spring Boot 应用程序中使用 Redis 事务来实现分布式锁和并发控制等功能:

@Service  
public class LockService {private final RedisTemplate<String, Object> redisTemplate;public LockService(RedisTemplate<String, Object> redisTemplate) {  this.redisTemplate = redisTemplate;  }public void lock(String lockKey) {  try {  redisTemplate.set(lockKey, "locked", 3000);  } catch (Exception e) {  e.printStackTrace();  }  }public void unlock(String lockKey) {  try {  redisTemplate.delete(lockKey);  } catch (Exception e) {  e.printStackTrace();  }  }  
}

在这个示例中,我们创建了一个 LockService 类,它使用 RedisTemplate 来实现分布式锁的功能。lock 方法尝试在 Redis 中设置一个锁键,如果设置成功则表示获取到锁,否则抛出异常。unlock 方法尝试在 Redis 中删除锁键,如果删除成功则表示释放锁,否则抛出异常。
以上是一个简单的示例,展示了如何在 Spring Boot 项目中集成 Redis 主从复制和哨兵模式。通过使用 Redis 事务和分布式锁,可以实现高并发和分布式环境下的优雅编程。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/30875.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

流数据湖平台Apache Paimon(四)集成 Hive 引擎

文章目录 第3章 集成 Hive 引擎3.1 环境准备3.2 访问已有的Paimon表3.3 创建Paimon表3.4 通过外部表访问Paimon表 第3章 集成 Hive 引擎 前面与Flink集成时&#xff0c;通过使用 paimon Hive Catalog&#xff0c;可以从 Flink 创建、删除、查询和插入到 paimon 表中。这些操作…

【目标检测系列】YOLOV2解读

为更好理解YOLOv2模型&#xff0c;请先移步&#xff0c;了解YOLOv1后才能更好的理解YOLOv2所做的改进。 前情回顾&#xff1a;【目标检测系列】YOLOV1解读_怀逸%的博客-CSDN博客 背景 通用的目标检测应该具备快速、准确且能过识别各种各样的目标的特点。自从引入神经网络以来&a…

【go语言学习笔记】04 Go 语言工程管理

文章目录 一、质量保证1. 单元测试1.1 定义1.2 Go 语言的单元测试1.3 单元测试覆盖率 2. 基准测试2.1 定义2.2 Go 语言的基准测试2.3 计时方法2.4 内存统计2.5 并发基准测试2.6 基准测试实战 3. 特别注意 二、性能优化1. 代码规范检查1.1 定义1.2 golangci-lint1.2.1 安装1.2.2…

【C# 基础精讲】循环语句:for、while、do-while

循环语句是C#编程中用于重复执行一段代码块的关键结构。C#支持for、while和do-while三种常见的循环语句&#xff0c;它们允许根据条件来控制代码块的重复执行。在本文中&#xff0c;我们将详细介绍这三种循环语句的语法和使用方法。 for循环 for循环是一种常见的循环结构&…

MySQL8是什么-MySQL8知识详解

从今天起&#xff0c;开始更新MySQL8的教程&#xff0c;今天更新MySQL8的第一篇文章&#xff0c;主要讲了MySQL8是什么、MySQL数据库的概念、MySQL的优势和MySQL的发展历史。 1、MySQL8是什么 MySQL 8是一个开源的关系型数据库管理系统。它是MySQL数据库的最新版本&#xff0c…

【RTT驱动框架分析06】-pwn驱动框架分析+pwm驱动实现

pwm pwm应用程序开发 访问 PWM 设备API 应用程序通过 RT-Thread 提供的 PWM 设备管理接口来访问 PWM 设备硬件&#xff0c;相关接口如下所示&#xff1a; 函数描述rt_device_find()根据 PWM 设备名称查找设备获取设备句柄rt_pwm_set()设置 PWM 周期和脉冲宽度rt_pwm_enable…

Tomcat 部署及优化

Tomcat概述 Tomcat 是 Java 语言开发的&#xff0c;Tomcat 服务器是一个免费的开放源代码的 Web 应用服务器&#xff0c;是 Apache 软件基金会的 Jakarta 项目中的一个核心项目&#xff0c;由 Apache、Sun 和其他一些公司及个人共同开发而成。在中小型系统和并发访问用户不是很…

【腾讯云 Cloud Studio 实战训练营】基于Cloud Studio构建React完成点餐H5页面

前言 【腾讯云 Cloud Studio 实战训练营】基于Cloud Studio 构建React完成点餐H5页面一、Cloud Studio介绍1.1 Cloud Studio 是什么1.2 相关链接1.3 登录注册 二、实战练习2.1 初始化工作空间2.2 开发一个简版的点餐系统页面1. 安装 antd-mobile2. 安装 less 和 less-loader3. …

opencv基础-38 形态学操作-闭运算(先膨胀,后腐蚀)cv2.morphologyEx(img, cv2.MORPH_CLOSE, kernel)

闭运算是先膨胀、后腐蚀的运算&#xff0c;它有助于关闭前景物体内部的小孔&#xff0c;或去除物体上的小黑点&#xff0c;还可以将不同的前景图像进行连接。 例如&#xff0c;在图 8-17 中&#xff0c;通过先膨胀后腐蚀的闭运算去除了原始图像内部的小孔&#xff08;内部闭合的…

剑指offer39.数组中出现次数超过一半的数字

这个题非常简单&#xff0c;解法有很多种&#xff0c;我用的是HashMap记录每个元素出现的次数&#xff0c;只要次数大于数组长度的一半就返回。下面是我的代码&#xff1a; class Solution {public int majorityElement(int[] nums) {int len nums.length/2;HashMap<Integ…

为生成式AI提速,亚马逊云科技Amazon EC2 P5满足GPU需求

生成式AI&#xff08;Generative AI&#xff09;已经成为全球范围内的一个重要趋势&#xff0c;得到越来越多企业和研究机构的关注和应用。纽约时间7月26日&#xff0c;亚马逊云科技数据库、数据分析和机器学习全球副总裁Swami Sivasubramanian在亚马逊云科技举办的纽约峰会上更…

剑指 Offer 15. 二进制中1的个数

题目描述 编写一个函数&#xff0c;输入是一个无符号整数&#xff08;以二进制串的形式&#xff09;&#xff0c;返回其二进制表达式中数字位数为 ‘1’ 的个数&#xff08;也被称为 汉明重量).&#xff09;。 提示&#xff1a; 请注意&#xff0c;在某些语言&#xff08;如…

电动汽车设计、制造、研发的学科、技术和前沿科技综述

引言&#xff1a;电动汽车作为替代传统燃油汽车的一种先进交通工具&#xff0c;不仅具有环保、低噪音等优势&#xff0c;而且对于能源消耗和气候变化等全球性问题也具有重要意义。本文将综述与电动汽车设计、制造、研发相关的学科、技术和前沿科技&#xff0c;以期对电动汽车领…

PHP8的程序结构-PHP8知识详解

在做任何事情之前&#xff0c;都需要遵循一定的规则。在PHP8中&#xff0c;程序能够安照人们的意愿执行程序&#xff0c;主要依靠程序的流程控制语句。 不管多复杂的程序&#xff0c;都是由这些基本的语句组成的。语句是构造程序的基本单位。程序执行的过程就是执行程序语句的…

你不了解的Dictionary和ConcurrentDictionary

最近在做项目时&#xff0c;多线程中使用Dictionary的全局变量时&#xff0c;发现数据并没有存入到Dictionary中&#xff0c;但是程序也没有报错&#xff0c;经过自己的一番排查&#xff0c;发现Dictionary为非线程安全类型&#xff0c;因此我感觉数据没有写进去的原因是多线程…

【Fegin技术专题】「原生态」打开Fegin之RPC技术的开端,你会使用原生态的Fegin吗?(下)

内容简介 在项目开发中&#xff0c;除了考虑正常的调用之外&#xff0c;负载均衡和故障转移也是关注的重点&#xff0c;这也是feign ribbon的优势所在&#xff0c;基于上面两篇文章的基础&#xff0c;接下来我们开展最后一篇原生态fegin结合ribbon服务进行服务远程调用且实现负…

网络原因导致git下载报错处理办法

如下&#xff0c;git clone时报错&#xff1a; RPC failed; curl 18 transfer closed with outstanding read data remaining 5670 bytes of body are still expected fetch-pack: unexpected disconnect while reading sideband packet early EOF fetch-pack: invalid index…

基于Python 简易实现接口测试自动化

目录 实现思路 统筹脚本 请求封装 日志封装 结果比对 结果邮件 用例获取及数据格式化 请求url转换 测试用例excel结构 测试报告 邮件接收结果 资料获取方法 实现思路 使用excel管理用例用例信息&#xff0c;requests模块发送http请求&#xff0c;实现了记录日志&…

使用vue模拟通讯录列表,对中文名拼音首字母提取并排序

一个功能需求,做一个类似联系人列表的功能,点击名称获取对应的id,样式简陋,只是一个模板,原来是uniapp项目,根据需要改成了vue,需要的自行设计css&#xff08;万是有一个mo的音&#xff09; 流程 获取数据提取首个字的拼音的首个字母排序并分组 上代码&#xff1a; <temp…

SpringBoot自动装配及run方法原理探究

自动装配 1、pom.xml spring-boot-dependencies&#xff1a;核心依赖在父工程中&#xff01;我们在写或者引入一些SpringBoot依赖的时候&#xff0c;不需要指定版本&#xff0c;就因为有这些版本仓库 1.1 其中它主要是依赖一个父工程&#xff0c;作用是管理项目的资源过滤及…