it编程 > 前端脚本 > Erlang

最全干货!使用Docker构建RabbitMQ高可用负载均衡集群,附答案+考点

176人参与 2024-07-28 Erlang

总结

如果你选择了it行业并坚定的走下去,这个方向肯定是没有一丝问题的,这是个高薪行业,但是高薪是凭自己的努力学习获取来的,这次我把p8大佬用过的一些学习笔记(pdf)都整理在本文中了

《java中高级核心知识全面解析》

小米商场项目实战,别再担心面试没有实战项目:

docker exec -it rabbit2 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@my-rabbit1
rabbitmqctl start_app
exit

设置节点3:

docker exec -it rabbit3 bash
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@my-rabbit1
rabbitmqctl start_app
exit

节点设置完成之后,在浏览器访问192.168.16.128:15672、192.168.16.128:15673和192.168.16.128:15674中任意一个,都会看到rabbitmq集群已经创建成功。

image

3. 配置镜像队列

镜像队列工作原理:在非镜像队列的集群中,消息会路由到指定的队列。当配置为镜像队列之后,消息除了按照路由规则投递到相应的队列外,还会投递到镜像队列的拷贝。也可以想象在镜像队列中隐藏着一个fanout交换器,将消息发送到镜像的队列的拷贝。

进入任意一个rabbitmq节点,执行如下命令:

rabbitmqctl set_policy ha-all “^” ‘{“ha-mode”:“all”}’

可以设置镜像队列,"^"表示匹配所有队列,即所有队列在各个节点上都会有备份。在集群中,只需要在一个节点上设置镜像队列,设置操作会同步到其他节点。

查看集群的状态:

rabbitmqctl cluster_status

二、haproxy负载均衡

第一步构建rabbitmq集群只是构建高可用负载均衡集群的基础,下面将使用haproxy为rabbitmq集群做负载均衡。

haproxy 是目前比较流行的一种群集调度工具,是使用c语言编写的自由及开放源代码软件,其提供高可用性、负载均衡,以及基于tcp和http的应用程序代理。同类群集调度工具有很多,如lvs 和 nginx 。相比较而言,lvs 性能最好,但是搭建相对复杂,nginx的upstream模块支持群集功能,但是对群集节点的健康检查功能不强,性能没有haproxy 好。

对于调度算法本文采用最简单最常用的轮询算法。

本来想采用docker的方式拉取并运行haproxy镜像,折腾了好几天搞不定,haproxy启动不了,故采用源码安装的方式安装haproxy。

配置两个haproxy节点实现负载均衡:
image.png
1. 安装haproxy

  1. 下载

由于到官网下载需要kexue上网,这里提供百度云链接。

链接:
https://pan.baidu.com/s/1uasja3nhfie1e6dk7ihmwq 提取码: irz6

  1. 将haproxy-1.7.8.tar.gz拷贝至/opt目录下,解压缩:

tar zxvf haproxy-1.7.8.tar.gz

  1. 进入目录,编译成可执行文件。

将源代码解压之后,需要运行make来将haproxy编译成为可执行文件。如果是在linux2.6系统上面进行编译的话,需要设置target=linux26以开启epoll支持,这也是为什么网上许多博客里面都是这么写的。对于其他的unix系统来说,直接采用target=generic方式,本文进行安装的系统为centos7 ,内核3.10版本。

cd haproxy-1.7.8
make target=generic

执行完毕之后,目录下出现haproxy的可执行文件。

2. 配置haproxy

haproxy配置文件说明

haproxy配置文件通常分为三个部分,即global、defaults和listen。global为全局配置,defaults为默认配置,listen为应用组件配置。

global为全局配置部分,属于进程级别的配置,通常和使用的操作系统配置相关。

defaults配置项配置默认参数,会被应用组件继承,如果在应用组件中没有特别声明,将使用默认配置参数。

以配置rabbitmq集群的负载均衡为例,在安装目录下面新建一个haproxy.cfg,输入下面配置信息:

global
#日志输出配置,所有日志都记录在本机,通过local0输出
log 127.0.0.1 local0 info
#最大连接数
maxconn 10240
#以守护进程方式运行
daemon

defaults
#应用全局的日志配置
log global
mode http
#超时配置
timeout connect 5000
timeout client 5000
timeout server 5000
timeout check 2000

listen http_front #haproxy的客户页面
bind 192.168.16.128:8888
mode http
option httplog
stats uri /haproxy
stats auth admin:123456
stats refresh 5s
stats enable

listen haproxy #负载均衡的名字
bind 0.0.0.0:5666 #对外提供的虚拟的端口
option tcplog
mode tcp
#轮询算法
balance roundrobin
server rabbit1 192.168.16.128:5672 check inter 5000 rise 2 fall 2
server rabbit2 192.168.16.128:5673 check inter 5000 rise 2 fall 2
server rabbit3 192.168.16.128:5674 check inter 5000 rise 2 fall 2

3. 启动

启动命令:

/opt/haproxy-1.7.8/haproxy -f /opt/haproxy-1.7.8/haproxy.cfg

验证一下是否启动成功:

[root@localhost haproxy-1.7.8]# lsof -i:8888
command pid user fd type device size/off node name
haproxy 45031 root 3u ipv4 228341 0t0 tcp localhost.localdomain:ddi-tcp-1 (listen)

在浏览器上访问
http://192.168.16.128:8888/haproxy,输入配置的用户名和密码登录以后,可以看到如下画面:

image

再以相同的方式在192.168.16.129服务器上面启动一个haproxy。

到此,负载均衡配置完成。

三、keepalived配置高可用

keepalived,它是一个高性能的服务器高可用或热备解决方案,keepalived主要来防止服务器单点故障的发生问题,可以通过其与nginx、haproxy等反向代理的负载均衡服务器配合实现web服务端的高可用。keepalived以vrrp协议为实现基础,用vrrp协议来实现高可用性(ha)。

1. keepalived安装

keepalived的官网下载keepalived的安装文件,目前最新的版本为:keepalived-2.0.17.tar.gz,下载地址为
http://www.keepalived.org/download.html。

下载之后进行解压和编译安装。

tar zxvf keepalived-2.0.17.tar.gz
cd keepalived-2.0.17
./configure --prefix=/opt/keepalived --with-init=sysv
#注:(upstart|systemd|sysv|suse|openrc) #根据你的系统选择对应的启动方式
make
make install

2. keepalived配置

之后将安装过后的keepalived加入系统服务中,详细步骤如下:

cp /opt/keepalived/etc/rc.d/init.d/keepalived /etc/init.d/
cp /opt/keepalived/etc/sysconfig/keepalived /etc/sysconfig
cp /opt/keepalived/sbin/keepalived /usr/sbin/
chmod +x /etc/init.d/keepalived
chkconfig --add keepalived
chkconfig keepalived on
#keepalived默认会读取/etc/keepalived/keepalived.conf配置文件
mkdir /etc/keepalived
cp /opt/keepalived/etc/keepalived/keepalived.conf /etc/keepalived/

接下来修改
/etc/keepalived/keepalived.conf文件,在keepalived的master上配置详情如下:

#keepalived配置文件
global_defs {
router_id nodea #路由id, 主备的id不能相同
}

#自定义监控脚本
vrrp_script chk_haproxy {
script “/etc/keepalived/check_haproxy.sh”
interval 5
weight 2
}

vrrp_instance vi_1 {
state master #keepalived的角色。master表示主服务器,从服务器设置为backup
interface eth0 #指定监测网卡
virtual_router_id 1
priority 100 #优先级,backup机器上的优先级要小于这个值
advert_int 1 #设置主备之间的检查时间,单位为s
authentication { #定义验证类型和密码
auth_type pass
auth_pass root123
}
track_script {

1200页java架构面试专题及答案

小编整理不易,对这份1200页java架构面试专题及答案感兴趣劳烦帮忙转发/点赞

百度、字节、美团等大厂常见面试题

.(img-t9zwi2hi-1715602041960)]

(0)
打赏 微信扫一扫 微信扫一扫

您想发表意见!!点此发布评论

推荐阅读

Ruby langchainrb gem and custom configuration for the model setup

07-28

RabbitMQ 安装分享

07-28

RabbitMQ详解与实战(绝对足够惊喜)

07-28

RabbitMQ 消息丢失的场景,如何保证消息不丢失?

07-28

25道RabbitMQ面试题含答案(很全)

07-28

【RabbitMQ】【Docker】基于docker-compose构建rabbitmq容器

07-28

猜你喜欢

版权声明:本文内容由互联网用户贡献,该文观点仅代表作者本人。本站仅提供信息存储服务,不拥有所有权,不承担相关法律责任。 如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 2386932994@qq.com 举报,一经查实将立刻删除。

发表评论