Redis集群之高可用可水平扩展

文章目录

  • 一、Redis集群方案比较
  • 二、Redis高可用集群搭建
  • 三、Java操作redis集群
  • 四、集群的Spring Boot整合Redis

一、Redis集群方案比较

哨兵模式

在redis3.0以前的版本要实现集群一般是借助哨兵sentinel工具来监控master节点的状态,如果master节点异 常,则会做主从切换,将某一台slave作为master,哨兵的配置略微复杂,并且性能和高可用性等各方面表现 一般,特别是在主从切换的瞬间存在访问瞬断的情况,而且哨兵模式只有一个主节点对外提供服务,没法支持很高的并发,且单个主节点内存也不宜设置得过大,否则会导致持久化文件过大,影响数据恢复或主从同步的效率
在这里插入图片描述
redis集群是一个由多个主从节点群组成的分布式服务器群,它具有复制、高可用和分片特性。Redis集群不需要sentinel哨兵也能完成节点移除故障转移的功能。需要将每个节点设置成集群模式,这种集群模式没有中心节点,可水平扩展,据官方文档称可以线性扩展到上万个节点(官方推荐不超过1000个节点)。redis集群的性能和高可用性均优于之前版本的哨兵模式,且集群配置非常简单。

二、Redis高可用集群搭建

redis集群搭建 :redis集群需要至少三个master节点,我们这里搭建三个master节点,并且给每个master再搭建一个slave节 点,总共6个redis节点,这里用三台机器部署6个redis实例,每台机器一主一从,搭建集群的步骤如下:

第一步:在第一台机器的/usr/local下创建文件夹redis‐cluster,然后在其下面分别创建2个文件夾如下 (1)mkdir ‐p /usr/local/redis‐cluster (2)mkdir 8001 8004 
第二步:把之前的redis.conf配置文件copy到8001下,修改如下内容: (1)daemonize yes (2)port 8001(分别对每个机器的端口号进行设置) (3)pidfile /var/run/redis_8001.pid # 把pid进程号写入pidfile配置的文件 (4)dir /usr/local/redis‐cluster/8001/(指定数据文件存放位置,必须要指定不同的目录位置,不然会 丢失数据) (5)cluster‐enabled yes(启动集群模式)(6)cluster‐config‐file nodes‐8001.conf(集群节点信息文件,这里800x最好和port对应上)(7)cluster‐node‐timeout 10000  (8)# bind 127.0.0.1(bind绑定的是自己机器网卡的ip,如果有多块网卡可以配多个ip,代表允许客户端通 过机器的哪些网卡ip去访问,内网一般可以不配置bind,注释掉即可)(9)protected‐mode no (关闭保护模式) (10)appendonly yes 16 如果要设置密码需要增加如下配置:(11)requirepass java (设置redis访问密码) (12)masterauth java (设置集群节点间访问密码,跟上面一致) 1920 第三步:把修改后的配置文件,copy到8004,修改第2346项里的端口号,可以用批量替换: 
:%s/源字符串/目的字符串/g 2223 第四步:另外两台机器也需要做上面几步操作,第二台机器用80028005,第三台机器用80038006 2425 第五步:分别启动6个redis实例,然后检查是否启动成功 
(1/usr/local/redis‐5.0.3/src/redis‐server /usr/local/redis‐cluster/800*/redis.conf 
(2)ps ‐ef | grep redis 查看是否启动成功 2829 第六步:用redis‐cli创建整个redis集群(redis5以前的版本集群是依靠ruby脚本redis‐trib.rb实现) # 下面命令里的1代表为每个创建的主服务器节点创建一个从服务器节点 # 执行这条命令需要确认三台机器之间的redis实例要能相互访问,可以先简单把所有机器防火墙关掉,如果不 关闭防火墙则需要打开redis服务端口和集群节点gossip通信端口16379(默认是在redis端口号上加1W) # 关闭防火墙 # systemctl stop firewalld # 临时关闭防火墙 # systemctl disable firewalld # 禁止开机启动 # 注意:下面这条创建集群的命令大家不要直接复制,里面的空格编码可能有问题导致创建集群不成功(1/usr/local/redis‐5.0.3/src/redis‐cli ‐a java ‐‐cluster create ‐‐cluster‐replicas 1 1 92.168.0.61:8001 192.168.0.62:8002 192.168.0.63:8003 192.168.0.61:8004 192.168.0.62:8005 192. 168.0.63:8006 3738 第七步:验证集群(1)连接任意一个客户端即可:./redis‐cli ‐c ‐h ‐p (‐a访问服务端密码,‐c表示集群模式,指定ip地址 和端口号)如:/usr/local/redis‐5.0.3/src/redis‐cli ‐a java ‐c ‐h 192.168.0.61 ‐p 800*2)进行验证: cluster info(查看集群信息)、cluster nodes(查看节点列表)(3)进行数据操作验证(4)关闭集群则需要逐个进行关闭,使用命令: /usr/local/redis‐5.0.3/src/redis‐cli ‐a java ‐c ‐h 192.168.0.60 ‐p 800* shutdown

三、Java操作redis集群

借助redis的java客户端jedis可以操作以上集群,引用jedis版本的maven坐标如下:

<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</version> </dependency>
public class JedisClusterTest{
public static void main(String[] args) throws IOException {
JedisPoolConfig config = new JedisPoolConfig().
config.setMaxTotal(20)
config.setMaxldle(10).
config.setMinldle(5);
Set<HostAndPort> iedisClusterNode = new HashSet<HostAndPort>();
jedisClusterNode.add(new HostAndPort"192.168.0.61",8001)):
jedisClusterNode.add(new HostAndPort("192.168.0.62",8002));
jedisClusterNode.add(new HostAndPort("192.168.0.63",8003));
jedisClusterNode.add(new HostAndPort("192.168.0.61",8004));
jedisClusterNode.add(new HostAndPort("192.168.0.62",8005));
jedisClusterNode.add(new HostAndPort("192.168.0.63",8006);try 
//connectionTimeout:指的是连接一个url的连接等待时间
//soTimeout: 指的是连接上一个url,获取response的返回等待时间
jedisCluster = new JedisCluster(jedisClusterNode, 6000, 5000, 10,"java", config);
System.out.printIn(jedisCluster.set("cluster", "java"));
System.out.printIn(iedisCluster.get("cluster"));
}catch (Exception e) {
e.printStackTrace();
}finally{
if (jedisCluster != null)
jedisCluster.close();
}
运行效果如下:
OK
java

四、集群的Spring Boot整合Redis

1、引入相关依赖:

<dependency>
<groupld>org.springframework.boot</groupld>
<artifactld>spring-boot-starter-data-redis</artifactld></dependency>
<dependency>
<groupld>org.apache.commons</groupld>
<artifactld>commons-pool2</artifactld>
</dependency>

2、springboot 项目核心配置:

server.port: 8080
springredisdatabase:0timeout: 3000password: javacluster:  nodes:192.168.0.61:8001,192.168.0.62:8002,192.168.0.63:8003,192.168.0.61:8004,192.168.0.62:8005,192.168.0.63:8006lettuce:pool:max-idle: 50min-idle: 10max-active: 100max-wait: 1000

3、访问代码

@RestController
public class IndexController {
private static final Logger logger = LoggerFactory.getLogger(IndexController.class);
@Autowired
private StringRedisTemplate stringRedisTemplate,
@RequestMapping("/test_cluster"public void testCluster ) throws InterruptedException{
stringRedisTemplate.opsForValue().set("java""666");
System.out.printIn(stringRedisTemplate.opsForValue().get("java"));
}
}

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

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

相关文章

解决nvidia驱动和CUDA升级问题

解决nvidia驱动和CUDA升级问题 注释&#xff1a;升级高版本的nvidia驱动和cuda是不影响现有的docker镜像和容器的。因为是向下兼容的。仅仅升级后重启服务器即可。 ERROR: An NVIDIA kernel module ‘nvidia-drm’ appears to already be loaded in your kernel. This may be…

Java(十二)——Comparable接口与Comparator接口

文章目录 Comparable与Comparator接口Comparable接口Comparator接口 Comparable与Comparator接口 我们可能会遇到这样的问题&#xff1a;怎么对一个对象数组进行排序&#xff1f; 比如对一个狗类对象数组进行排序&#xff0c;而想到这&#xff0c;我们又会有一个问题&#xff…

Java学习中,如何理解注解的概念及常用注解的使用方法

一、简介 Java注解&#xff08;Annotation&#xff09;是一种元数据&#xff0c;提供了一种将数据与程序元素&#xff08;类、方法、字段等&#xff09;关联的方法。注解本身不改变程序的执行逻辑&#xff0c;但可以通过工具或框架进行处理&#xff0c;从而影响编译、运行时的…

Oracle 误删数据后回滚

使用闪回查询 使用闪回查询&#xff0c;可以回滚到指定时间点的数据&#xff0c;可以通过系统时间(YYYY-MM-DD HH24:MI:SS)或SCN回滚数据。 SQL> select * from tableName as of timestamp(sysdate-1/24); SQL> select * from tableName as of scn(123456); 3、闪回事务或…

混合关键性系统技术【同构异构】【SMP、AMP、BMP】【嵌入式虚拟化】

混合关键性系统技术【同构异构】【SMP、AMP、BMP】【嵌入式虚拟化】 1 介绍1.1 概述openEuler Embedded 的运行模式openEuler Embedded 混合关键性系统技术架构UniProton 1.2 同构异构区别 【硬件侧】1.3 系统架构【SMP、AMP、BMP】多核处理器平台的系统架构 【软件侧】【SMP、…

前端进阶之HTML表单

前端之HTML表单 1.HTML表单的定义及概述 HTML 表单用于搜集不同类型的用户输入。 用<form> 元素定义HTML表单 例如&#xff1a; <form>. form elements. </form>1.1 HTML 表单包含表单元素&#xff1a;表单元素指的是不同类型的 input 元素、复选框、单…

探索Adobe XD:高效UI设计软件的中文入门教程

在这个数字化世界里&#xff0c;创意设计不仅是为了吸引观众的注意&#xff0c;也是用户体验的核心部分。强大的设计工具可以帮助设计师创造出明亮的视觉效果&#xff0c;从而提高用户体验。 一、Adobe XD是什么&#xff1f; Adobe XD是一家知名软件公司 Adobe Systems 用户体…

GeoJson格式简单说明(2024-06-06)

一个典型的时空“点”数据&#xff08;可理解为轨迹点&#xff09;格式如下&#xff1a; {"type": "Feature","geometry": {"type": "Point","coordinates": [125.6, 10.1]},"properties": {"nam…

JAVA学习-练习试用Java实现“简化路径”

问题&#xff1a; 给定一个字符串 path &#xff0c;表示指向某一文件或目录的 Unix 风格 绝对路径 &#xff08;以 / 开头&#xff09;&#xff0c;请将其转化为更加简洁的规范路径。 在 Unix 风格的文件系统中&#xff0c;一个点&#xff08;.&#xff09;表示当前目录本身…

海南聚广众达电子商务咨询有限公司引领抖音电商新风尚

在数字化浪潮汹涌澎湃的今天&#xff0c;电商行业正迎来前所未有的发展机遇。作为电商领域的一颗璀璨明星&#xff0c;海南聚广众达电子商务咨询有限公司凭借其专业的抖音电商服务&#xff0c;成功吸引了众多商家的目光&#xff0c;成为了业界的一匹黑马。 海南聚广众达电子商…

如何成功申请消防设施工程乙级资质?关键步骤详解

1. 自我评估与准备 条件核对&#xff1a;首先确认企业是否满足乙级资质的注册资本、技术团队、工程经验等硬性要求。团队组建&#xff1a;确保拥有足够数量且符合条件的专业技术人员&#xff0c;特别是关键岗位如主要技术负责人、注册消防工程师等。资料收集&#xff1a;提前准…

【全开源】CRM管理客户关系系统源码

CRM&#xff1a;助力企业高效管理客户关系 全面解决企业销售团队的全流程客户服务难题&#xff0c;旨在助力企业销售全流程精细化、数字化管理&#xff0c;全面解决企业销售团队的全流程客户服务难题&#xff0c;帮助企业有效盘活客户资源、量化销售行为&#xff0c;合理配置资…

vue2+elementui,动态生成的表单校验

话不多,先上一段视频,看看是不是你们需要的效果 elementui动态生成表单校验 附上代码 <template><div class"home"><div class"home-box"><!-- <menuHtml></menuHtml> --><div class"home-div"><…

springboot整合ENC加密解密

以redis为例&#xff0c;连数据库、连mq操作也一样 步骤 1: 添加Jasypt依赖 在Maven项目的pom.xml中添加如下依赖&#xff1a; <dependency><groupId>com.github.ulisesbocchio</groupId><artifactId>jasypt-spring-boot-starter</artifactId>…

超长正整数的加法

一、引言 在计算机科学中&#xff0c;整数加法是一个基础且重要的操作。然而&#xff0c;当面对超长正整数&#xff08;即超出计算机内置整数类型表示范围的整数&#xff09;时&#xff0c;传统的整数加法方法便不再适用。超长正整数通常使用字符串或数组来表示&#xff0c;每…

k8s AIOps

k8s AIOps 主要介绍下k8sgpt 官站 github 介绍 k8sgpt 是一个用于扫描Kubernetes集群、诊断和分级问题的工具。它以简单的英语呈现问题&#xff0c;并将站点可靠性工程&#xff08;SRE&#xff09;的经验编码到其分析器中。通过AI丰富问题的解释&#xff0c;k8sgpt帮助提取最…

Android RecycleView触摸事件记录

文章目录 一、前言二、onFilterTouchEventForSecurity三、addOnItemTouchListener四、参考链接 一、前言 在开发中有时候需要对RecycleView的触摸事件进行拦截和处理&#xff0c;RecyclView本身事件比较复杂&#xff0c;直接使用View的事件体系不能完成特定业务。比如区分滑动…

Full Stack Programming Further Web Programming COSC2758

1. Overview (you must read thisfirst) In this assignment, you will develop a Full Stack Web Application to complete the front‐end prototype built from assignment 1. You are required to use the following stacks:  Frontend: ReactJS or ReactTS  Mid…

iOS开发中copy on write

Copy-On-Write&#xff08;写时复制&#xff09;是一种内存管理技术&#xff0c;在iOS开发中被广泛使用。下面是一些常见的使用场景&#xff1a; 不可变对象的复制&#xff1a;当对一个不可变对象执行复制操作时&#xff0c;实际上只会创建该对象的引用计数副本&#xff0c;而不…

沉淀:心灵的宁静之道

在这个信息爆炸的时代&#xff0c;我们常常被繁杂的事务淹没。每日忙碌的工作、应接不暇的社交活动、纷至沓来的琐事&#xff0c;让人难以静下心来。最近&#xff0c;我也深感疲惫和迷茫&#xff0c;仿佛被生活的巨浪推着前行&#xff0c;却无暇思考方向。 沉淀&#xff0c;是一…