百万架构师第三十七课：RabbitMq：高可用集群搭建步骤｜JavaGuide

news/2025/2/22 11:22:45
安装环境

Centos-7

三台虚拟机
192.168.8.150（磁盘节点）
192.168.8.45 （内存节点）
192.168.8.40 （内存节点）
一、安装Erlang
1、erlang 下载地址：

http://www.rabbitmq.com/releases/erlang/

2、创建目录
[root@nogeek ]# mkdir -p /usr/local/tools/rabbitmq
[root@nogeek ]# cd /usr/local/tools/rabbitmq
3、下载安装包
[root@nogeek ]# wget http://www.rabbitmq.com/releases/erlang/erlang-19.0.4-1.el6.x86_64.rpm
4、安装
[root@nogeek ]# rpm -ivh erlang-19.0.4-1.el6.x86_64.rpm

二、安装RabbitMQ

1、rabbitMQ 下载地址

https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/

2、下载安装包
[root@nogeek ]# wget https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/rabbitmq-server-3.6.12-1.el6.noarch.rpm
[root@nogeek ]# rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
3、安装
[root@nogeek ]#  rpm -ivh rabbitmq-server-3.6.12-1.el6.noarch.rpm
问题解决

1、错误：依赖检测失败：
socat 被 rabbitmq-server-3.6.12-1.el6.noarch 需要

解决报错：
[root@nogeek ]#  wget –no-cache http://www.convirture.com/repos/definitions/rhel/6.x/convirt.repo -O /etc/yum.repos.d/convirt.repo
[root@nogeek ]#  yum makecache -y
[root@nogeek ]#  yum install socat -y
2、如果yum源有问题，无法安装：将CentOS的yum源更换为国内的阿里云源

使用yum时File contains no section headers.解决办法
http://xiaojingjing.iteye.com/blog/2393165

[root@nogeek ]#  rm -f /etc/yum.repos.d/*
[root@nogeek ]# wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
[root@nogeek ]# yum clean all

三、集群配置

1、hosts配置

三台机器的hosts都配置

[root@nogeek ]# vim /etc/hosts
192.168.8.150 rabbit1 （磁盘节点）
192.168.8.45 rabbit2（内存节点）
192.168.8.40 rabbit3（内存节点）

2、同步.erlang.cookie
保持三台机器的.erlang.cookie同步

/var/lib/rabbitmq/.erlang.cookie

在第二台机器8.45执行：

[root@nogeek ]# scp .erlang.cookie root@192.168.8.45:/var/lib/rabbitmq/
[root@nogeek ]# chown rabbitmq:rabbitmq .erlang.cookie

在第三台机器8.40执行：

[root@nogeek ]# scp .erlang.cookie root@192.168.8.40:/var/lib/rabbitmq/
[root@nogeek ]# chown rabbitmq:rabbitmq .erlang.cookie

重启服务

[root@nogeek ]# systemctl stop rabbitmq-server.service
[root@nogeek ]# systemctl start rabbitmq-server.service

或：

[root@nogeek ]# systemctl restart rabbitmq-server.service

查看服务状态：

[root@nogeek ]# systemctl status rabbitmq-server.service

如果启动报错：

Job for rabbitmq-server.service failed because the control process exited with error code. See "systemctl status rabbitmq-server.service" and "journalctl -xe" for details.

如果是因为服务停不掉，就要kill 端口。

3、加入集群
首先开放集群通信端口：

[root@nogeek ]# firewall-cmd --permanent --add-port={5672/tcp,4369/tcp,25672/tcp}
[root@nogeek ]# firewall-cmd --reload
[root@nogeek ]# setsebool -P nis_enabled 1

在第二台45，第三台机，40上执行：

[root@nogeek ]# rabbitmqctl stop_app
[root@nogeek ]# rabbitmqctl reset
[root@nogeek ]# rabbitmqctl join_cluster rabbit@rabbit1 --ram

创建用户：三台服务器都执行

 [root@nogeek ]# firewall-cmd --permanent --add-port=15672/tcp
 [root@nogeek ]# firewall-cmd –-reload
 [root@nogeek ]# rabbitmqctl add_user admin admin
 [root@nogeek ]# rabbitmqctl set_user_tags admin administrator
 [root@nogeek ]# rabbitmqctl set_permissions -p / admin "." "." ".*"

4、
RabbitMQ镜像队列
可以参考：
https://www.cnblogs.com/saneri/p/7798251.html

5、HAProxy + Keepalived 高可用方案

一、HAProxy
将5672端口映射为5673端口，15672端口映射为15673端口。

1)在两个内存节点上安装HAProxy

 [root@nogeek ]#  yum install haproxy

2)编辑配置文件

 [root@nogeek ]# vim /etc/haproxy/haproxy.cfg

内容修改为：

global
    log         127.0.0.1 local2
    chroot      /var/lib/haproxy
    pidfile     /var/run/haproxy.pid
    maxconn     4000
    user        haproxy
    group       haproxy
    daemon
    stats socket /var/lib/haproxy/stats
	
defaults
    log                     global
    option                  dontlognull
    option                  redispatch
    retries                 3
    timeout connect         10s
    timeout client          1m
    timeout server          1m
    maxconn                 3000
	
listen http_front
        mode http
        bind 0.0.0.0:1080           #监听端口
        stats refresh 30s           #统计页面自动刷新时间
        stats uri /haproxy?stats    #统计页面url
        stats realm Haproxy Manager #统计页面密码框上提示文本
        stats auth admin:123456     #统计页面用户名和密码设置
		
listen rabbitmq_admin
    bind 0.0.0.0:15673
    server node1 192.168.8.40:15672
    server node2 192.168.8.45:15672
	
listen rabbitmq_cluster 0.0.0.0:5673
    mode tcp
    balance roundrobin
    timeout client 3h
    timeout server 3h
    timeout connect 3h
    server   node1 192.168.8.40:5672 check inter 5s rise 2 fall 3
    server   node2 192.168.8.45:5672 check inter 5s rise 2 fall 3

3)启动HAProxy

 [root@nogeek ]# haproxy -f /etc/haproxy/haproxy.cfg

二、在两个内存节点上安装Keepalived
VIP 为 192.168.8.201

1)安装Keepalived

 [root@nogeek ]# yum -y install keepalived

2)修改配置文件

 [root@nogeek ]# vim /etc/keepalived/keepalived.conf

内容改成（物理网卡和当前主机IP要修改）：

global_defs {
   notification_email {
     acassen@firewall.loc
     failover@firewall.loc
     sysadmin@firewall.loc
   }
   notification_email_from Alexandre.Cassen@firewall.loc
   smtp_server 192.168.200.1
   smtp_connect_timeout 30
   router_id LVS_DEVEL
   vrrp_skip_check_adv_addr
   # vrrp_strict    # 注释掉，不然访问不到VIP
   vrrp_garp_interval 0
   vrrp_gna_interval 0
}
global_defs {
   notification_email {
     acassen@firewall.loc
     failover@firewall.loc
     sysadmin@firewall.loc
   }
   notification_email_from Alexandre.Cassen@firewall.loc
   smtp_server 192.168.200.1
   smtp_connect_timeout 30
   router_id LVS_DEVEL
   vrrp_skip_check_adv_addr
   # vrrp_strict    # 注释掉，不然访问不到VIP
   vrrp_garp_interval 0
   vrrp_gna_interval 0
}

# 检测任务
vrrp_script check_haproxy {
    # 检测HAProxy脚本
    script "/etc/keepalived/script/check_haproxy.sh"
    # 每隔两秒检测
    interval 2
    # 权重
    weight 2
}

# 虚拟组
vrrp_instance haproxy {
    state MASTER # 此处为`主`，备机是 `BACKUP`【此处要修改】
    interface ens33 # 物理网卡，根据情况而定 【此处要修改】
    mcast_src_ip 192.168.8.40 # 当前主机ip 【此处要修改】
    virtual_router_id 51 # 虚拟路由id，同一个组内需要相同
    priority 100 # 主机的优先权要比备机高
    advert_int 1 # 心跳检查频率，单位：秒
    authentication { # 认证，组内的要相同
        auth_type PASS
        auth_pass 1111
    }
    # 调用脚本
    track_script {
        check_haproxy
    }
    # 虚拟ip，多个换行
    virtual_ipaddress {
        192.168.8.201
    }
}

3)启动keepalived

[root@nogeek ]# keepalived -D

http://www.niftyadmin.cn/n/5862176.html

相关文章

Unity摄像机与灯光相关知识

Unity摄像机与灯光相关知识

一、Inspector窗口 Inspector窗口可以查看和编辑对象的属性以及设置 其中包含各种组件，例如用Cube对象来举例 1.Sphere(Mesh)组件： 用来决定对象的网格属性，例如球体网格为Sphere、立方体网格为Cube 2.Mesh Renderer组件： 用来设置…
阅读更多...
【弹性计算】虚拟化技术

【弹性计算】虚拟化技术

虚拟化技术 1.虚拟化技术的发展历程1.1 Xen 虚拟化架构（2009 ~ 2015 年）1.2 KVM 虚拟化架构（2015 ~ 2018 年）1.3 软硬件结合的虚拟化架构（2018 年至今） 2.KVM 虚拟化技术3.热迁移技术4.热升级技术4.1 内核热…
阅读更多...
玩机日记 10 群晖开启文件服务挂载到手机/电脑，测试传输性能

玩机日记 10 群晖开启文件服务挂载到手机/电脑，测试传输性能

目录 1、群晖开启smb和sftp 2、Windows11挂载群晖磁盘 3、手机连接sftp访问群晖文件 之前在PVE上安装Windows11时只划分了512g的磁盘大小作为C盘，没有添加别的磁盘。在安装了一堆游戏测试性能后，c盘已经爆红了，我需要挂载群晖的硬盘&#…
阅读更多...
利用非球面透镜进行激光光束重组

利用非球面透镜进行激光光束重组

这是高斯分布激光束重塑透镜设计的分步演示。该透镜用于将高斯分布转换为成像平面上的均匀照明。 输入激光光束轮廓： 光学结构： Excel 中坐标的数学计算： 输出照度曲线：
阅读更多...
一文读懂 KYC：金融、IT 领域的关键应用与实践

一文读懂 KYC：金融、IT 领域的关键应用与实践

文章目录 一、KYC 的基本概念（一）定义（二）起源与发展（三）目的与作用（四）主要组成部分（五）适用范围 二、KYC 在金融领域的应用 —— 以保险业务为例&#xff0…
阅读更多...
酒店旅游API：数据交互的隐形桥梁——以携程API为例

酒店旅游API：数据交互的隐形桥梁——以携程API为例

一、API：酒店 和第三方服务无缝连接。 核心价值： 实时数据互通：房态、价格、库存秒级同步。业务流程自动化：预订、支付、确认全程无需人工干预。生态扩展：开发者可基于API构建定制化工具（如比价插件、智能…
阅读更多...
VUE中的组件加载方式

VUE中的组件加载方式

加载方式有哪些，及如何进行选择 常规的静态引入是在组件初始化时就加载所有依赖的组件，而懒加载则是等到组件需要被渲染的时候才加载。 对于大型应用，可能会有很多组件，如果一开始都加载，可能会影响首屏加载时间。如…
阅读更多...
智能交通系统（Intelligent Transportation Systems）：智慧城市中的交通革新

智能交通系统（Intelligent Transportation Systems）：智慧城市中的交通革新

智能交通系统（Intelligent Transportation Systems, ITS）是利用先进的信息技术、通信技术、传感技术、计算机技术以及自动化技术等，来提升交通系统效率和安全性的一种交通管理方式。ITS通过收集和分析交通数据，智能化地调度、控制…
阅读更多...
最新文章

Copyright @ 2022~2023