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 主从复制和哨兵模式:
- 首先,在 pom.xml 文件中添加对 Redis 依赖的配置:
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
- 创建 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 事务和分布式锁,可以实现高并发和分布式环境下的优雅编程。
相关文章:
Redis主从复制和哨兵架构图,集成Spring Boot项目实战分享
目录 1. Redis 主从复制2. Redis 哨兵架构3. 集成spring boot项目案列 Redis 主从复制和哨兵架构是 Redis 集群的重要组成部分,用于提高 Redis 集群的可用性和性能。以下是 Redis 主从复制和哨兵架构的详细介绍,包括架构图和 Java 代码详解。 1. Redis …...
java中try-with-resources自动关闭io流
文章目录 java中try-with-resources自动关闭io流0 简要说明try-with-resources java中try-with-resources自动关闭io流 0 简要说明 在传统的输入输出流处理中,我们一般使用的结构如下所示,使用try - catch - finally结构捕获相关异常,最后不…...
Games101学习笔记 -光栅化
光栅化 经过MVP矩阵和视口变换后,我们就可以从相机的角度看到一个和屏幕大小一致的二维平面。 那么把这个看到的二维平面应用到我们的屏幕上的过程就是光栅化。在这儿我们需要补充一个概念-像素: 像素: 一个二位数组,数组中每个…...
Pytorch量化之Post Train Static Quantization(训练后静态量化)
使用Pytorch训练出的模型权重为fp32,部署时,为了加快速度,一般会将模型量化至int8。与fp32相比,int8模型的大小为原来的1/4, 速度为2~4倍。 Pytorch支持三种量化方式: 动态量化(Dynamic Quantization&…...
Sql奇技淫巧之EXIST实现分层过滤
在这样一个场景,我 left join 了很多张表,用这些表的不同列来过滤,看起来非常合理 但是出现的问题是 left join 其中一张或多张表出现了笛卡尔积,且无法消除 FUNCTION fun_get_xxx_helper(v_param_1 VARCHAR2,v_param_2 VARCHAR2…...
Linux下升级jdk1.8小版本
先输入java -version 查看是否安装了jdk java -version (1)如果没有返回值,直接安装新的jdk即可。 (2)如果有返回值,例如: java version "1.8.0_251" Java(TM) SE Runtime Enviro…...
【Mysql】数据库基础与基本操作
🌇个人主页:平凡的小苏 📚学习格言:命运给你一个低的起点,是想看你精彩的翻盘,而不是让你自甘堕落,脚下的路虽然难走,但我还能走,比起向阳而生,我更想尝试逆风…...
87 | Python人工智能篇 —— 机器学习算法 决策树
本教程将深入探讨决策树的基本原理,包括特征选择方法、树的构建过程以及剪枝技术,旨在帮助读者全面理解决策树算法的工作机制。同时,我们将使用 Python 和 scikit-learn 库演示如何轻松地实现和应用决策树,以及如何对结果进行可视化。无论您是初学者还是有一定机器学习经验…...
【计算机视觉】干货分享:Segmentation model PyTorch(快速搭建图像分割网络)
一、前言 如何快速搭建图像分割网络? 要手写把backbone ,手写decoder 吗? 介绍一个分割神器,分分钟搭建一个分割网络。 仓库的地址: https://github.com/qubvel/segmentation_models.pytorch该库的主要特点是&#…...
解析湖仓一体的支撑技术及实践路径
自2021年“湖仓一体”首次写入Gartner数据管理领域成熟度模型报告以来,随着企业数字化转型的不断深入,“湖仓一体”作为新型的技术受到了前所未有的关注,越来越多的企业视“湖仓一体” 为数字化转型的重要基础设施。 01 数据平台的发展历程…...
40.利用欧拉法求解微分方程组(matlab程序)
1.简述 求解微分方程的时候,如果不能将求出结果的表达式,则可以对利用数值积分对微分方程求解,获取数值解。欧拉方法是最简单的一种数值解法。前面介绍过MATLAB实例讲解欧拉法求解微分方程,今天实例讲解欧拉法求解一阶微分方程组。…...
OpenAI-Translator 实战总结
最近在极客时间学习《AI 大模型应用开发实战营》,自己一边跟着学一边开发了一个进阶版本的 OpenAI-Translator,在这里简单记录下开发过程和心得体会,供有兴趣的同学参考 功能概览 通过openai的chat API,实现一个pdf翻译器实现一个…...
【工业机器人】用于轨迹规划和执行器分析的机械手和移动机器人模型(MatlabSimulink)
💥💥💞💞欢迎来到本博客❤️❤️💥💥 🏆博主优势:🌞🌞🌞博客内容尽量做到思维缜密,逻辑清晰,为了方便读者。 ⛳️座右铭&a…...
开源在线文档服务OnlyOffice
开源在线文档服务OnlyOffice应用启动与示例运行 - 掘金 ONLYOFFICE API 文档 - Example - IDEA运行Java示例 | ONLYOFFICE中文网 NEXTCLOUDonlyoffice的搭建和使用_nextcloud onlyoffice_莫冲的博客-CSDN博客 OnlyOffice java 部署使用,文件流方式 预览文件 | 言曌博…...
汽车基本常识
目录 电源KL30KL15 零部件简称 电源 KL30 KL15 零部件简称 VCU:整车控制器 直接网络管理节点 CDU:充电系统控制器 MCU:电机控制器 TCU:变速箱控制器 ABS:防抱死系统 EPS:助力转向 T-Box:远程…...
百度资深PMO阚洁受邀为第十二届中国PMO大会演讲嘉宾
百度在线网络技术(北京)有限公司资深PMO阚洁女士受邀为由PMO评论主办的2023第十二届中国PMO大会演讲嘉宾,演讲议题:运筹于股掌之间,决胜于千里之外 —— 360斡旋项目干系人。大会将于8月12-13日在北京举办,…...
为什么C++有多种整型?
C中有多种整型是为了满足不同的需求,提供更灵活和高效的整数表示方式。不同的整型具有不同的字节大小、范围和精度,可以根据应用的需求选择合适的整型类型。以下是一些原因解释为什么C有多种整型: 内存和性能优化:不同的整型在内存…...
玩一玩通义千问Qwen开源版,Win11 RTX3060本地安装记录!
大概在两天前,阿里做了一件大事儿。 就是开源了一个低配版的通义千问模型--通义千问-7B-Chat。 这应该是国内第一个大厂开源的大语言模型吧。 虽然是低配版,但是在各类测试里面都非常能打。 官方介绍: Qwen-7B是基于Transformer的大语言模…...
oracle积累增量和差异增量
积累增量和差异增量: 对于 RMAN 来说,积累增量备份和差异增量备份都是增量备份的一种形式,它们之间的区别在于备份的范围和备份集的方式。 积累增量备份:在进行积累增量备份时,RMAN 会备份自最后一次完全备份或增量备…...
利用C++nlohmann库解析json文件
json文件示例: 代码运行环境VS2019 一、git下载nlohmann库文件源代码 源代码文件目录 二、利用VS2019新建工程,并配置项目属性 配置VC目录---包含目录 三、项目源代码 #include <iostream> #include <fstream> #include <nlohmann/jso…...
基于距离变化能量开销动态调整的WSN低功耗拓扑控制开销算法matlab仿真
目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.算法仿真参数 5.算法理论概述 6.参考文献 7.完整程序 1.程序功能描述 通过动态调整节点通信的能量开销,平衡网络负载,延长WSN生命周期。具体通过建立基于距离的能量消耗模型&am…...
React hook之useRef
React useRef 详解 useRef 是 React 提供的一个 Hook,用于在函数组件中创建可变的引用对象。它在 React 开发中有多种重要用途,下面我将全面详细地介绍它的特性和用法。 基本概念 1. 创建 ref const refContainer useRef(initialValue);initialValu…...
VB.net复制Ntag213卡写入UID
本示例使用的发卡器:https://item.taobao.com/item.htm?ftt&id615391857885 一、读取旧Ntag卡的UID和数据 Private Sub Button15_Click(sender As Object, e As EventArgs) Handles Button15.Click轻松读卡技术支持:网站:Dim i, j As IntegerDim cardidhex, …...
STM32F4基本定时器使用和原理详解
STM32F4基本定时器使用和原理详解 前言如何确定定时器挂载在哪条时钟线上配置及使用方法参数配置PrescalerCounter ModeCounter Periodauto-reload preloadTrigger Event Selection 中断配置生成的代码及使用方法初始化代码基本定时器触发DCA或者ADC的代码讲解中断代码定时启动…...
Linux云原生安全:零信任架构与机密计算
Linux云原生安全:零信任架构与机密计算 构建坚不可摧的云原生防御体系 引言:云原生安全的范式革命 随着云原生技术的普及,安全边界正在从传统的网络边界向工作负载内部转移。Gartner预测,到2025年,零信任架构将成为超…...
关于 WASM:1. WASM 基础原理
一、WASM 简介 1.1 WebAssembly 是什么? WebAssembly(WASM) 是一种能在现代浏览器中高效运行的二进制指令格式,它不是传统的编程语言,而是一种 低级字节码格式,可由高级语言(如 C、C、Rust&am…...
k8s业务程序联调工具-KtConnect
概述 原理 工具作用是建立了一个从本地到集群的单向VPN,根据VPN原理,打通两个内网必然需要借助一个公共中继节点,ktconnect工具巧妙的利用k8s原生的portforward能力,简化了建立连接的过程,apiserver间接起到了中继节…...
多模态大语言模型arxiv论文略读(108)
CROME: Cross-Modal Adapters for Efficient Multimodal LLM ➡️ 论文标题:CROME: Cross-Modal Adapters for Efficient Multimodal LLM ➡️ 论文作者:Sayna Ebrahimi, Sercan O. Arik, Tejas Nama, Tomas Pfister ➡️ 研究机构: Google Cloud AI Re…...
pikachu靶场通关笔记22-1 SQL注入05-1-insert注入(报错法)
目录 一、SQL注入 二、insert注入 三、报错型注入 四、updatexml函数 五、源码审计 六、insert渗透实战 1、渗透准备 2、获取数据库名database 3、获取表名table 4、获取列名column 5、获取字段 本系列为通过《pikachu靶场通关笔记》的SQL注入关卡(共10关࿰…...
如何理解 IP 数据报中的 TTL?
目录 前言理解 前言 面试灵魂一问:说说对 IP 数据报中 TTL 的理解?我们都知道,IP 数据报由首部和数据两部分组成,首部又分为两部分:固定部分和可变部分,共占 20 字节,而即将讨论的 TTL 就位于首…...
