当前位置: 首页 > news >正文

redis分布式集群-redis+keepalived+ haproxy

redis分布式集群架构(Redis+Keepalived+Haproxy)至少需要3台服务器、6个节点,一台服务器2个节点。

redis分布式集群架构中的每台服务器都使用六个端口来实现多路复用,最终实现主从热备、负载均衡、秒级切换的目标。

redis分布式集群架构思路为:keepalived给haproxy做高可用,当一台haproxy出现故障时,高可用会将另一台备用的haproxy作为master,继续给后端提供服务,防止单点故障。

部署redis集群

第一步,环境准备。

redis分布式集群架构至少需要3台服务器、6个节点,一台机器2个节点,创建出3个master节点、3个salve节点环境。

第一台服务器:

私网IP:x.x.x.x redis-master 6001 redis-slave 6002

第二台服务器:

私网IP:y.y.y.y redis-master 6001 redis-slave 6002

第三台服务器:

私网IP:z.z.z.z redis-master 6001 redis-slave 6002

第二步,安装redis。(每台服务器都安装)

命令:yum -y install redis

若结果显示“redis-6.0.5-1.11.al8.x86_64”,则说明成功安装了redis-6.0.5。

第三步,启动redis服务。(每台服务器都启动)

命令:systemctl start redis

若结果显示“Active: failed”,则需要把文件/usr/lib/systemd/system/redis.service中的“--daemonize no --supervised systemd”去掉,注释掉“Type=notify”,最后再次启动redis,服务状态为“Active: active (running)。

systemctl stop redis

systemctl restart redis

systemctl daemon-reload

# 设置开机自启动

命令:systemctl enable redis

# 查看服务状态是否为“Active: active (running)”

命令:systemctl status redis

ps -ef | grep redis

netstat -nap | grep  6379

# 服务端启动成功后,启动redis 客户端,查看端口号。

命令:redis-cli

set [key] [value]

get [key]

exit

ps -ef | grep redis

netstat -nap | grep 6379

第四步,在/usr/local中新建/redis/6001/conf、/redis/6001/data、/redis/6001/log、 /redis/6002/conf、/redis/6002/data和/redis/6002/log文件夹。(每台服务器都新建)

命令:mkdir -p /usr/local/redis/{6001,6002}/{conf,data,log}

第五步,将/etc/redis.conf配置文件复制粘贴到文件夹/usr/local/redis/6001/conf。(每台服务器都复制)

命令:cp /etc/redis.conf /usr/local/redis/6001/conf

cp /etc/redis.conf /usr/local/redis/6002/conf

步,配置redis.conf(每台服务器都配置)

redis主编辑配置/usr/local/redis/6001/conf/redis.conf文件,做以下几处修改:

“bind 127.0.0.1”改为“bind 0.0.0.0”,“protected-mode yes”改为“protected-mode no”,“port 6379”改为“port 6001”,“daemonize no”改为“daemonize yes”,“requirepass foobared”改为requirepass "redis123456",“dir ./”改为“dir /usr/local/redis/6001/data”,“pidfile /var/run/redis_6379.pid”改为“pidfile /usr/local/redis/6001/redis.pid”,“logfile ”改为“logfile /usr/local/redis/6001/log/redis.log”,“appendonly no”改为“appendonly yes”,“# cluster-enabled yes”改为“cluster-enabled yes”,“# cluster-config-file nodes-6379.conf”改为“cluster-config-file /usr/local/redis/6001/conf/nodes.conf”,“# cluster-node-timeout 15000”改为“cluster-node-timeout 5000”。

redis从编辑配置/usr/local/redis/6002/conf/redis.conf文件,做以下几处修改:

“bind 127.0.0.1”改为“bind 0.0.0.0”,“protected-mode yes”改为“protected-mode no”,“port 6379”改为“port 6002”,“daemonize no”改为“daemonize yes”,“requirepass foobared”改为requirepass "redis123456",“dir ./”改为“dir /usr/local/redis/6002/data”,“pidfile /var/run/redis_6379.pid”改为“pidfile /usr/local/redis/6002/redis.pid”,“logfile ”改为“logfile /usr/local/redis/6002/log/redis.log”,“appendonly no”改为“appendonly yes”,“# cluster-enabled yes”改为“cluster-enabled yes”,“# cluster-config-file nodes-6379.conf”改为“cluster-config-file /usr/local/redis/6002/conf/nodes.conf”,“# cluster-node-timeout 15000”改为“cluster-node-timeout 5000”。

第七步,重新启动redis服务。(每台服务器都重启)

# 关闭redis服务

命令:systemctl stop redis

ps -ef | grep redis

或  ss -tnlp|grep redis

# 重新启动redis服务

命令:/usr/bin/redis-server /usr/local/redis/6001/conf/redis.conf

/usr/bin/redis-server /usr/local/redis/6002/conf/redis.conf

第八步,检查redis启动情况。(每台服务器都检查)

命令:ps -ef | grep redis

或    ss -tnlp|grep redis

 

 

第九步,创建redis集群。

命令:/usr/bin/redis-cli --cluster create x.x.x.x:6001 x.x.x.x:6002 y.y.y.y:6001 y.y.y.y:6002 z.z.z.z:6001 z.z.z.z:6002 --cluster-replicas 1

ps -ef|grep redis

第十步,redis集群验证。

# 连接集群

命令:redis-cli -c -p 6001 -a redis123456

部署keepalived

第一步,环境准备。

redis分布式集群架构选择任意两个节点进行配置,实现主从热备和秒级切换。

keepalived主服务器私网IP:x.x.x.x redis-master 6001 redis-slave 6002

keepalived备服务器私网IP:y.y.y.y redis-master 6001 redis-slave 6002

高可用虚拟IP:v.v.v.v

第二步,安装keepalived。(keepalived主、备服务器都安装)

命令:yum -y install keepalived

若结果显示“keepalived-2.2.4-6.al8.x86_64”,则说明成功安装了keepalived-2.2.4。

第三步,配置keepalived.conf文件。(keepalived主、备服务器都配置)

1)配置Keepalived主服务器中的/etc/keepalivedkeepalived.conf文件,代码如下:

global_defs {router_id redis-master}vrrp_script redis_check {script "/etc/keepalived/scripts/haproxy_check.sh"interval 4weight -5fall 3rise 2}vrrp_instance VI_REDIS {state MASTERinterface eth0virtual_router_id 51priority 150advert_int 1nopreemptauthentication {auth_type PASSauth_pass 1111}track_script {chk_haproxy}virtual_ipaddress {v.v.v.v}}

2)先利用命令“mkdir -p /etc/keepalived/scripts”在Keepalived主服务器创建文件夹。然后在新建文件夹中创建haproxy_check.sh脚本,在脚本中写入下面代码:

#!/bin/bashsystemctl status haproxy | grep runningif [ $? -ne 0 ];thensystemctl stop keepalivedfi

3)配置Keepalived备服务器中的/etc/keepalivedkeepalived.conf文件,代码如下:

global_defs {router_id redis-slave}vrrp_script redis_check {script "/etc/keepalived/scripts/haproxy_check.sh"interval 4weight -5fall 3rise 2}vrrp_instance VI_REDIS {state BAKCUPinterface eth0virtual_router_id 51priority 100advert_int 1nopreemptauthentication {auth_type PASSauth_pass 1111}track_script {chk_haproxy}virtual_ipaddress {v.v.v.v}}

4)先利用命令“mkdir -p /etc/keepalived/scripts”在Keepalived备服务器创建文件夹。然后在新建文件夹中创建haproxy_check.sh脚本,在脚本中写入下面代码:

#!/bin/bashsystemctl status haproxy | grep runningif [ $? -ne 0 ];thensystemctl stop keepalivedfi

步,给新建的脚本加上可执行权限。(keepalived主、备服务器都加上

命令:chmod +x /etc/keepalived/scripts/*.sh

第五步,开启服务验证

关掉Keepalived主服务器的keepalived服务之后,VIP可以漂移Keepalived备服务器。

部署haproxy

第一步,环境准备。

redis分布式集群架构选择安装keepalived的两个服务器来部署haproxy,haproxy访问6379端口时,轮询访问六个节点。

keepalived主服务器私网IP:x.x.x.x redis-master 6001 redis-slave 6002

keepalived备服务器私网IP:y.y.y.y redis-master 6001 redis-slave 6002

高可用虚拟IP:v.v.v.v

第二步,安装haproxy。

命令:yum -y install haproxy

第三步,配置haproxy.cfg文件。

配置/etc/haproxy/haproxy.cfg文件,在文件中写入下面代码:

globallog                     127.0.0.1 local0chroot                  /var/lib/haproxypidfile                 /var/run/haproxy.pidmaxconn                 4000user                    nobodygroup                   nobodydaemondefaultsmode                     httplog                      globaloption                   dontlognullretries                  3maxconn                  3000contimeout               50000clitimeout               50000srvtimeout               50000listen statsbind                    *:8888stats                   enablestats                   hide-versionstats uri               /haproxystats realm             Haproxy\ statsstats auth              admin:adminstats admin             if TRUElisten  redisbind *:6379mode tcpbalance roundrobinserver redis1 x.x.x.x:6001 checkserver redis2 x.x.x.x:6002 checkserver redis3 y.y.y.y:6001 checkserver redis4 y.y.y.y:6002 checkserver redis5 z.z.z.z:6001 checkserver redis6 z.z.z.z:6002 check

第四步,配置haproxy rsyslog.conf文件。

vim /etc/rsyslog.conf

在/etc/rsyslog.conf文件中做出如下修改:

“# Provides UDP syslog reception# for parameters see http://www.rsyslog.com/doc/imudp.html#module(load="imudp") # needs to be done just once#input(type="imudp" port="514")”修改为“# Provides UDP syslog reception$ModLoad imudp$UDPServerRun 514”;“# Provides TCP syslog reception# for parameters see http://www.rsyslog.com/doc/imtcp.html#module(load="imtcp") # needs to be done just once#input(type="imtcp" port="514")”修改为“# Provides TCP syslog reception$ModLoad imtcp$InputTCPServerRun 514”;添加“# haproxy loglocal0.*                 /var/log/haproxy.log”。

第五步,haproxy访问6379端口时,轮询访问六个节点

命令:redis-cli -c -p 6379 -h v.v.v.v -a redis123456

测试

经测试,keepalived优先级最高的服务器(私网:x.x.x.x keepalived主+haproxy)中的两个redis节点不能同时被杀死,否则集群会马上停止,但是重启该服务器,集群就会马上恢复。

另两台服务器中的任何一台服务器发生宕机(或者两个redis节点挂掉)都不会影响redis集群的使用。

redis集群负载比较低。

需要注意redis集群缺点:

redis集群模式下只能选择db0,选择其他库会出现类似“(error) ERR SELECT is not allowed in cluster mode”的异常。

相关文章:

redis分布式集群-redis+keepalived+ haproxy

redis分布式集群架构(RedisKeepalivedHaproxy)至少需要3台服务器、6个节点,一台服务器2个节点。 redis分布式集群架构中的每台服务器都使用六个端口来实现多路复用,最终实现主从热备、负载均衡、秒级切换的目标。 redis分布式集…...

快递管理系统springboot 寄件物流仓库java jsp源代码mysql

本项目为前几天收费帮学妹做的一个项目,Java EE JSP项目,在工作环境中基本使用不到,但是很多学校把这个当作编程入门的项目来做,故分享出本项目供初学者参考。 一、项目描述 快递管理系统springboot 系统有1权限:管…...

自学黑客/网络安全(学习路线+教程视频+工具包+经验分享)

一、为什么选择网络安全? 这几年随着我国《国家网络空间安全战略》《网络安全法》《网络安全等级保护2.0》等一系列政策/法规/标准的持续落地,网络安全行业地位、薪资随之水涨船高。 未来3-5年,是安全行业的黄金发展期,提前踏入…...

如何进行游戏平台搭建?

游戏平台搭建涉及多个步骤和技术,下面是一个大致的指南: 市场调研和定位:首先,要了解游戏市场和受众的需求,选择适合的游戏类型和定位。 选择平台类型:决定是要搭建网页平台、移动应用平台还是其他类型的…...

安全防御问题

SSL VPN的实现,防火墙需要放行哪些流量? 实现 SSL VPN 时,在防火墙上需要放行以下流量, SSL/TLS 流量:SSL VPN 通过加密通信来确保安全性,因此防火墙需要允许 SSL/TLS 流量通过。一般情况下,SSL…...

x-www-form-urlencoded、application/json到底是什么

在http协议中规定了GET、HEAD、POST、PUT、DELETE、CONNECT 等请求方式,其中比较常用的就是post和get,其中post用来向服务器提交数据,post只规定了提交的数据必须放在请求的主体中,但是并没有规定传输数据的编码方式。比较主流的有如下的几种…...

LeetCode 33题:搜索旋转排序数组

目录 题目 思路 代码 暴力解法 分方向法 二分法 题目 整数数组 nums 按升序排列&#xff0c;数组中的值 互不相同 。 在传递给函数之前&#xff0c;nums 在预先未知的某个下标 k&#xff08;0 < k < nums.length&#xff09;上进行了 旋转&#xff0c;使数组变为 …...

用python来爬取某鱼的商品信息(1/2)

目录 前言 第一大难题——找到网站入口 曲线救国 模拟搜索 第二大难题——登录 提一嘴 登录cookie获取 第一种 第二种 第四大难题——无法使用导出的cookie 原因 解决办法 最后 出现小问题 总结 下一篇博客&#xff08;大部分代码实现&#xff09; 前言 本章讲理…...

网工最常犯的9大错误,越早知道越吃香

下午好&#xff0c;我的网工朋友 我们常说&#xff0c;人要学会避免错误&#xff0c;尤其是对在职场生活的打工人来说&#xff0c;更是如此。 学生时代&#xff0c;我们通过错题本收集错误&#xff0c;提高刷题正确率和分数&#xff0c;但到了职场&#xff0c;因为没有量化的…...

Windows - UWP - 网络不好的情况下安装(微软商店)MicrosoftStore的应用

Windows - UWP - 网络不好的情况下安装&#xff08;微软商店&#xff09;MicrosoftStore的应用 前言 UWP虽然几乎被微软抛弃了&#xff0c;但不得不否认UWP应用给用户带来的体验。沙箱的运行方式加上微软的审核&#xff0c;用户使用起来非常放心&#xff0c;并且完美契合Wind…...

1040:输出绝对值

【题目描述】 输入一个浮点数&#xff0c;输出这个浮点数的绝对值&#xff0c;保留到小数点后两位。 【输入】 输入一个浮点数&#xff0c;其绝对值不超过10000。 【输出】 输出这个浮点数的绝对值&#xff0c;保留到小数点后两位。 【输入样例】 -3.14 【输出样例】 …...

[Docker精进篇] Docker部署和实践 (二)

前言&#xff1a; Docker部署是通过使用Docker容器技术&#xff0c;将应用程序及其所有相关依赖项打包为一个可移植、自包含的镜像&#xff0c;然后在任何支持Docker的环境中快速部署和运行应用程序的过程。 文章目录 Docker部署1️⃣为什么需要&#xff1f;2️⃣有什么作用&am…...

day9 | 28. 实现 strStr()、459.重复的子字符串

目录&#xff1a; 解题及思路学习 28. 实现 strStr() https://leetcode.cn/problems/find-the-index-of-the-first-occurrence-in-a-string/ 给你两个字符串 haystack 和 needle &#xff0c;请你在 haystack 字符串中找出 needle 字符串的第一个匹配项的下标&#xff08;下…...

hive on tez资源控制

sql insert overwrite table dwintdata.dw_f_da_enterprise2 select * from dwintdata.dw_f_da_enterprise; hdfs文件大小数量展示 注意这里文件数有17个 共计321M 最后是划分为了21个task 为什么会有21个task&#xff1f;不是128M 64M 或者说我这里小于128 每个文件一个map…...

企业有VR全景拍摄的需求吗?能带来哪些好处?

在传统图文和平面视频逐渐疲软的当下&#xff0c;企业商家如何做才能让远在千里之外的客户更深入、更直接的详细了解企业品牌和实力呢&#xff1f;千篇一律的纸质材料已经过时了&#xff0c;即使制作的再精美&#xff0c;大家也会审美疲劳&#xff1b;但是你让客户远隔千里&…...

【问题解决】Git命令行常见error及其解决方法

以下是我一段时间没有使用xshell&#xff0c;然后用git命令行遇到的一些系列错误和他们的解决方法 遇到了这个报错&#xff1a; fatal: Not a git repository (or any of the parent directories): .git 我查阅一些博客和资料&#xff0c;可以解决的方式&#xff1a; git in…...

【100天精通python】Day34:使用python操作数据库_ORM(SQLAlchemy)使用

目录 专栏导读 1 ORM 概述 2 SQLAlchemy 概述 3 ORM&#xff1a;SQLAlchemy使用 3.1 安装SQLAlchemy&#xff1a; 3.2 定义数据库模型类&#xff1a; 3.3 创建数据表&#xff1a; 3.4 插入数据&#xff1a; 3.5 查询数据&#xff1a; 3.6 更新数据&#xff1a; 3.7 删…...

CCLINK IE转MODBUS-TCP网关modbus tcp协议详解

你是否曾经遇到过需要同时处理CCLINK IE FIELD BASIC和MODBUS两种数据协议的情况&#xff1f;捷米的JM-CCLKIE-TCP网关可以帮助你解决这个问题。 捷米JM-CCLKIE-TCP网关可以分别从CCLINK IE FIELD BASIC一侧和MODBUS一侧读写数据&#xff0c;然后将数据存入各自的缓冲区。接着…...

vue2根据不同的电脑分辨率显示页面内容及不同设备适配显示

1.安装插件: npm install postcss-px2rem px2rem-loader --save npm i lib-flexible --save 2.创建flexible.js,并在main.js引用 ;(function(win, lib) {var doc = win.document;var docEl = doc.documentElement;var metaEl = doc.querySelector(meta[name="viewport&…...

概率论:多维随机变量及分布

多维随机变量及分布 X X X为随机变量&#xff0c; ∀ x ∈ R , P { X ≤ x } F ( x ) \forall x\in R,P\{X\le x\}F(x) ∀x∈R,P{X≤x}F(x) 设 F ( x ) F(x) F(x)为 X X X的分布函数&#xff0c;则 &#xff08;1&#xff09; 0 ≤ F ( x ) ≤ 1 0\le F(x)\le1 0≤F(x)≤1 &am…...

C++实现分布式网络通信框架RPC(3)--rpc调用端

目录 一、前言 二、UserServiceRpc_Stub 三、 CallMethod方法的重写 头文件 实现 四、rpc调用端的调用 实现 五、 google::protobuf::RpcController *controller 头文件 实现 六、总结 一、前言 在前边的文章中&#xff0c;我们已经大致实现了rpc服务端的各项功能代…...

多种风格导航菜单 HTML 实现(附源码)

下面我将为您展示 6 种不同风格的导航菜单实现&#xff0c;每种都包含完整 HTML、CSS 和 JavaScript 代码。 1. 简约水平导航栏 <!DOCTYPE html> <html lang"zh-CN"> <head><meta charset"UTF-8"><meta name"viewport&qu…...

css3笔记 (1) 自用

outline: none 用于移除元素获得焦点时默认的轮廓线 broder:0 用于移除边框 font-size&#xff1a;0 用于设置字体不显示 list-style: none 消除<li> 标签默认样式 margin: xx auto 版心居中 width:100% 通栏 vertical-align 作用于行内元素 / 表格单元格&#xff…...

如何在最短时间内提升打ctf(web)的水平?

刚刚刷完2遍 bugku 的 web 题&#xff0c;前来答题。 每个人对刷题理解是不同&#xff0c;有的人是看了writeup就等于刷了&#xff0c;有的人是收藏了writeup就等于刷了&#xff0c;有的人是跟着writeup做了一遍就等于刷了&#xff0c;还有的人是独立思考做了一遍就等于刷了。…...

3-11单元格区域边界定位(End属性)学习笔记

返回一个Range 对象&#xff0c;只读。该对象代表包含源区域的区域上端下端左端右端的最后一个单元格。等同于按键 End 向上键(End(xlUp))、End向下键(End(xlDown))、End向左键(End(xlToLeft)End向右键(End(xlToRight)) 注意&#xff1a;它移动的位置必须是相连的有内容的单元格…...

.Net Framework 4/C# 关键字(非常用,持续更新...)

一、is 关键字 is 关键字用于检查对象是否于给定类型兼容,如果兼容将返回 true,如果不兼容则返回 false,在进行类型转换前,可以先使用 is 关键字判断对象是否与指定类型兼容,如果兼容才进行转换,这样的转换是安全的。 例如有:首先创建一个字符串对象,然后将字符串对象隐…...

sipsak:SIP瑞士军刀!全参数详细教程!Kali Linux教程!

简介 sipsak 是一个面向会话初始协议 (SIP) 应用程序开发人员和管理员的小型命令行工具。它可以用于对 SIP 应用程序和设备进行一些简单的测试。 sipsak 是一款 SIP 压力和诊断实用程序。它通过 sip-uri 向服务器发送 SIP 请求&#xff0c;并检查收到的响应。它以以下模式之一…...

蓝桥杯 冶炼金属

原题目链接 &#x1f527; 冶炼金属转换率推测题解 &#x1f4dc; 原题描述 小蓝有一个神奇的炉子用于将普通金属 O O O 冶炼成为一种特殊金属 X X X。这个炉子有一个属性叫转换率 V V V&#xff0c;是一个正整数&#xff0c;表示每 V V V 个普通金属 O O O 可以冶炼出 …...

【VLNs篇】07:NavRL—在动态环境中学习安全飞行

项目内容论文标题NavRL: 在动态环境中学习安全飞行 (NavRL: Learning Safe Flight in Dynamic Environments)核心问题解决无人机在包含静态和动态障碍物的复杂环境中进行安全、高效自主导航的挑战&#xff0c;克服传统方法和现有强化学习方法的局限性。核心算法基于近端策略优化…...

Go 并发编程基础:通道(Channel)的使用

在 Go 中&#xff0c;Channel 是 Goroutine 之间通信的核心机制。它提供了一个线程安全的通信方式&#xff0c;用于在多个 Goroutine 之间传递数据&#xff0c;从而实现高效的并发编程。 本章将介绍 Channel 的基本概念、用法、缓冲、关闭机制以及 select 的使用。 一、Channel…...