rabbitmq 集群部署

• rabbitmq 集群部署
  • erlang 安装
  • rabbitmq 二级制包部署及 web 插件安装
  • 集群设置及启动

1.0 环境

// host
    # IP        # HOST_NAME     # APPS
    10.20.10.97	rabbitmq-10-97	erlang、rabbitmq
    10.20.10.98	rabbitmq-10-98	erlang、rabbitmq
    10.20.10.99	rabbitmq-10-99	erlang、rabbitmq
// centos 7.9

2.0 erlang 安装

所有主机均安装

// 安装 rabbitmq 之前,需先安装 erlang
# yum -y install socat                                # erlang 依赖 socat 包
# rpm -ivh erlang-23.2.1-1.el7.x86_64.rpm             # erlang 和 rabbitmq 不同版本之间依赖版本不一样,需官网查找确认
# erl -version

3.0 rabbitmq 二进制包部署及 web 插件安装

// host
    10.20.10.97
    10.20.10.98
    10.20.10.99

# mkdir -p /data/apps/
# xz -d rabbitmq-server-generic-unix-3.9.10.tar.xz
# tar -xf rabbitmq-server-generic-unix-3.9.10.tar
# mv rabbitmq_server-3.9.10 /data/apps/rabbitmq
# sh /data/apps/rabbitmq/sbin/rabbitmq-plugins enable rabbitmq_management	# 安装图形插件
# nohup sh /data/apps/rabbitmq/sbin/rabbitmq-server &				# 后台启动

3.1 创建用户并赋予角色权限

// host: 10.20.10.97

# cd /data/apps/rabbitmq/sbin
# ./rabbitmqctl add_user admin ink8s.com                         # 创建用户并设置密码
# ./rabbitmqctl set_user_tags admin administrator                # 赋予用户角色
# ./rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"      # 设置权限
# ./rabbitmqctl list_users                                       # 查看当前用户和角色

4.0 集群配置

// host:
    10.20.10.97
    10.20.10.98
    10.20.10.99

// 3 台 hosts 主机名和 IP 对应必须相同
# echo -e "10.20.10.97    rabbitmq-10-97\n10.20.10.98    rabbitmq-10-98\n10.20.10.99    rabbitmq-10-99" >> /etc/hosts

// 确保每个节点的 cookie 文件使用的是同一个值
[root@rabbitmq-10-97 ~]# scp .erlang.cookie [email protected]:/root/	# 将"10.97"的 cookie 同步到 98 和 99 服务器
[root@rabbitmq-10-97 ~]# scp .erlang.cookie [email protected]:/root/

// 3 台服务器均执行如下命令
# cd /data/apps/rabbitmq/sbin
# ./rabbitmq-server -detached
# kill -9 删除_epmd_和_beam.smp_进程的_PID
# nohup sh /data/apps/rabbitmq/sbin/rabbitmq-server &

4.1 将 98 节点加入到 97 节点

// host: 10.20.10.98

# ./rabbitmqctl stop_app                                   # 只关闭 rabbitmq 服务
# ./rabbitmqctl reset                                      # 重置
# ./rabbitmqctl join_cluster rabbit@rabbitmq-10-97         # 将 98 加入到 97; 后面必须只 hosts 里面配置的主机名,不能写 IP 地址
# ./rabbitmqctl start_app                                  # 只启动应用服务

4.2 将 99 节点加入到 98 节点

// host: 10.20.10.99

# ./rabbitmqctl stop_app
# ./rabbitmqctl reset
# ./rabbitmqctl join_cluster rabbit@rabbitmq-10-98
# ./rabbitmqctl start_app
# ./rabbitmqctl cluster_status				# 查看集群状态

// 浏览器访问: http://10.20.10.97:15672/
    User: admin
    Pass: ink8s.com

5.0 解除集群

// 解除服务器上执行如下命令
# ./rabbitmqctl stop_app
# ./rabbitmqctl reset
# ./rabbitmqctl start_app
# ./rabbitmqctl cluster_status

// 其它节点上执行。例: 97
# rabbitmqctl forget_cluster_node rabbit@rabbitmq-10-98            # 97 上解除 98

6.0 镜像队列

// 如果 RabbitMQ 集群中只有一个 Broker 节点，那么该节点的失效将导致整体服务的临时性不可用，并且也可能会导致消息的丢失。可以将所有消息都设置为持久化，并且对应队列的durable 属性也设置为true，但是这样仍然无法避免由于缓存导致的问题:因为消息在发送之后和被写入磁盘井执行刷盘动作之间存在一个短暂却会产生问题的时间窗。通过 publisherconfirm 机制能够确保客户端知道哪些消息己经存入磁盘，尽管如此，一般不希望遇到因单点故障导致的服务不可用
// 引入镜像队列(Mirror Queue)的机制，可以将队列镜像到集群中的其他 Broker 节点之上，如果集群中的一个节点失效了，队列能自动地切换到镜像中的另一个节点上以保证服务的可用性

// 任意节点配置; 图1
    mirrior-twp                # 名称根据需求命名
    ^mirrior                   # 正则匹配规则
    ha-mode                    # 本分模式

微信

加微信,入技术群

微信

• 本文作者： [email protected]
• 本文链接： https://www.ink8s.com/2023/08/26/rabbitmq-集群部署/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！