端口说明：

安装 Erlang

yum -y install erlang

一键部署 RabbitMQ 仓库

curl -s https://packagecloud.io/install/repositories/rabbitmq/rabbitmq-server/script.rpm.sh | bash

安装 RabbitMQ

yum -y install rabbitmq-server

启动服务

systemctl enable —now rabbitmq-server.service

  1. <a name="maylz"></a>
  2. ### 1.1.2 CentOS 8
  3. <a name="FSRRe"></a>
  4. #### 官方源安装
  5. ```bash
  6. # 添加 repo 仓库
  7. vim /etc/yum.repos.d/rabbitmq.repo
  9. [rabbitmq_erlang]
  10. name=rabbitmq_erlang
  11. baseurl=https://packagecloud.io/rabbitmq/erlang/el/8/$basearch
  12. repo_gpgcheck=1
  13. gpgcheck=1
  14. enabled=1
  15. gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
  16. sslverify=1
  17. sslcacert=/etc/pki/tls/certs/ca-bundle.crt
  18. metadata_expire=300
  20. [rabbitmq_erlang-source]
  21. name=rabbitmq_erlang-source
  22. baseurl=https://packagecloud.io/rabbitmq/erlang/el/8/SRPMS
  23. repo_gpgcheck=1
  24. gpgcheck=0
  25. enabled=1
  26. gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
  27. sslverify=1
  28. sslcacert=/etc/pki/tls/certs/ca-bundle.crt
  29. metadata_expire=300
  31. [rabbitmq_rabbitmq-server]
  32. name=rabbitmq_rabbitmq-server
  33. baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/8/$basearch
  34. repo_gpgcheck=1
  35. gpgcheck=0
  36. enabled=1
  37. gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
  38. sslverify=1
  39. sslcacert=/etc/pki/tls/certs/ca-bundle.crt
  40. metadata_expire=300
  42. [rabbitmq_rabbitmq-server-source]
  43. name=rabbitmq_rabbitmq-server-source
  44. baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/8/SRPMS
  45. repo_gpgcheck=1
  46. gpgcheck=0
  47. enabled=1
  48. gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
  49. sslverify=1
  50. sslcacert=/etc/pki/tls/certs/ca-bundle.crt
  51. metadata_expire=300
  54. # 导入 GPG KEY
  55. rpm --import https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
  56. rpm --import https://packagecloud.io/rabbitmq/erlang/gpgkey
  57. rpm --import https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
  60. # 安装 Erlang
  61. dnf -y install erlang
  64. # 安装 RabbitMQ
  65. dnf -y install rabbitmq-server
  68. # 启动服务
  69. systemctl enable --now rabbitmq-server.service

1.1.3 Ubuntu20.04

  1. [root@rabbitmq-01:~]# apt update
  3. # 安装 apt HTTPS 传输
  4. [root@rabbitmq-01:~]# apt install apt-transport-https
  6. # 添加仓库签名密钥
  7. [root@rabbitmq-01:~]# curl -1sLf "https://keys.openpgp.org/vks/v1/by-fingerprint/0A9AF2115F4687BD29803A206B73A36E6026DFCA" | sudo gpg --dearmor > /usr/share/keyrings/com.rabbitmq.team.gpg
  8. [root@rabbitmq-01:~]# curl -1sLf "https://keyserver.ubuntu.com/pks/lookup?op=get&search=0xf77f1eda57ebb1cc" | sudo gpg --dearmor > /usr/share/keyrings/net.launchpad.ppa.rabbitmq.erlang.gpg
  9. [root@rabbitmq-01:~]# curl -1sLf "https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey" | sudo gpg --dearmor > /usr/share/keyrings/io.packagecloud.rabbitmq.gpg
  11. # 添加 PackageCloud 仓库源
  12. [root@rabbitmq-01:~]# tee /etc/apt/sources.list.d/rabbitmq.list <<EOF
  13. deb [signed-by=/usr/share/keyrings/net.launchpad.ppa.rabbitmq.erlang.gpg] http://ppa.launchpad.net/rabbitmq/rabbitmq-erlang/ubuntu bionic main
  14. deb-src [signed-by=/usr/share/keyrings/net.launchpad.ppa.rabbitmq.erlang.gpg] http://ppa.launchpad.net/rabbitmq/rabbitmq-erlang/ubuntu bionic main
  16. deb [signed-by=/usr/share/keyrings/io.packagecloud.rabbitmq.gpg] https://packagecloud.io/rabbitmq/rabbitmq-server/ubuntu/ focal main
  17. deb-src [signed-by=/usr/share/keyrings/io.packagecloud.rabbitmq.gpg] https://packagecloud.io/rabbitmq/rabbitmq-server/ubuntu/ focal main
  18. EOF
  20. # 安装 Erlang
  21. [root@rabbitmq-01:~]# apt update
  22. [root@rabbitmq-01:~]# apt install -y erlang-base \
  23. erlang-asn1 erlang-crypto erlang-eldap erlang-ftp erlang-inets \
  24. erlang-mnesia erlang-os-mon erlang-parsetools erlang-public-key \
  25. erlang-runtime-tools erlang-snmp erlang-ssl \
  26. erlang-syntax-tools erlang-tftp erlang-tools erlang-xmerl
  28. # 安装 RabbitMQ
  29. [root@rabbitmq-01:~]# apt install rabbitmq-server -y --fix-missing
  31. # 自启动服务
  32. [root@c7-04 ~]# systemctl enable rabbitmq-server.service

1.2 RabbitMQ 集群

1.2.1 集群队列模式

Rabbitmq 集群有两种方式：

  1. 普通模式：创建好 RabbitMQ 集群之后的默认模式。queue 创建之后，如果没有其它 policy，消息实体只存在于其中 一个节点。例如有 A、B 两个 Rabbitmq 节点，他们仅有相同的元数据，即队列结构，但队列的数据仅保存有一份，即创建该队列的 rabbitmq 节点（A 节点），当消息进入 A 节点的 Queue 中后，consumer 从 B 节点拉取时，RabbitMQ 会临时在 A、B 间进行消息传输，把 A 中的消息实体取出并经过 B 发送给 consumer，所以 consumer 可以连接每一个节点来取消息，但该模式存在一个问题就是当 A 节点故障后，B 节点无法取到 A 节点中还未消费的消息实体。
  2. 镜像模式：把需要的服务器做成镜像队列。数据存在于多个节点，属于 RabbitMQ 的 HA 方案（镜像模式是在普通模式的基础上，增加一些镜像策略）该模式解决了普通模式中的数据丢失问题，其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步，而不是在 consumer 取数据时临时拉取，该模式带来的副作用也很明显，除了降低系统性能外，如果镜像队列数量过多，加之大量的消息进入，集群内部的网络带宽将会被这种同步通讯大大消耗掉，所以在对可靠性要求较高的场合中适用，一个队列想做成镜像队列，需要先设置 policy，然后客户端创建队列的时候，rabbitmq 集群根据“队列名称”自动设置是普通集群模式或镜像队列。

    1.2.2 集群节点类型

  • 内存节点：只将数据保存到内存中。
  • 磁盘节点：保存数据到内存和磁盘。

内存节点虽然不写入磁盘，但是它执行比磁盘节点要好，集群中，只需要一个磁盘节点来保存数据就足够了如果集群中只有内存节点，那么不能全部停止它们，否则所有数据消息在服务器全部停机之后都会丢失。
推荐设计架构：在一个 rabbitmq 集群里，有 3 台或以上机器，其中 1 台使用磁盘模式，其它节点使用内存模式，内存节点无访问速度更快，由于磁盘 IO 相对较慢，因此可作为数据备份使用。

1.2.3 集群实现

RabbitMQ 基于Erlang编写，Erlang 语言天生具备分布式特性（通过同步 Erlang 集群各节点的 magic cookie 来实现）。因此，RabbitMQ 天然支持 Clustering。使得 RabbitMQ 不需要像 ActiveMQ、Kafka 那样通过 ZooKeeper 分别来实现 HA 方案和保存集群的元数据。这个 magic cookie 存放在 /var/lib/rabbitmq/.erlang.cookie 中，文件是 400 的权限，所以必须保证各节点 cookie 保持一致，否则节点之间就无法通信。

  1. [root@rabbitmq-01:~]# ll /var/lib/rabbitmq/.erlang.cookie
  2. -r-------- 1 rabbitmq rabbitmq 20 Oct 18 00:00 /var/lib/rabbitmq/.erlang.cookie
  4. [root@rabbitmq-01:~]# cat /var/lib/rabbitmq/.erlang.cookie
  5. YQYFOFYLVHRYBNXSKVDS

1.3 集群部署详解

1.3.1 部署环境

三台集群 ip 和 主机名如下：

  1. # 设置主机名
  2. hostnamectl set-hostname rabbitmq-01 && bash
  3. hostnamectl set-hostname rabbitmq-02 && bash
  4. hostnamectl set-hostname rabbitmq-03 && bash
  6. cat >>/etc/hosts <<EOF
  7. 10.0.0.91 rabbitmq-01 rabbitmq-01.wuvikr.top
  8. 10.0.0.92 rabbitmq-02 rabbitmq-02.wuvikr.top 
  9. 10.0.0.93 rabbitmq-03 rabbitmq-03.wuvikr.top
  10. EOF

1.3.2 安装 RabbitMQ

安装过程祥见 1.1 单机部署 章节，这里不再重复。部署完成以后不要启动服务。

1.3.3 复制 .erlang.cookie 文件

保证三台机器上的 /var/lib/rabbitmq/.erlang.cookie 文件一致，否则节点之间就无法通信。这里拷贝 10.0.0.91 上的文件到其他另外两个节点。

  1. [root@rabbitmq-01:~]# scp -p /var/lib/rabbitmq/.erlang.cookie 10.0.0.92:/var/lib/rabbitmq/.erlang.cookie
  2. [root@rabbitmq-01:~]# scp -p /var/lib/rabbitmq/.erlang.cookie 10.0.0.93:/var/lib/rabbitmq/.erlang.cookie

1.3.4 启动 RabbitMQ 服务

  1. [root@rabbitmq-01:~]# systemctl start rabbitmq-server
  2. [root@rabbitmq-02:~]# systemctl start rabbitmq-server
  3. [root@rabbitmq-03:~]# systemctl start rabbitmq-server

1.3.5 创建集群

将 rabbitmq-01 作为集群，将 rabbitmq-02 和 rabbitmq-03 两台机器作为内存节点加入 rabbitmq-01 集群。

  1. # 停止服务
  2. [root@rabbitmq-02:~]# rabbitmqctl stop_app
  3. [root@rabbitmq-03:~]# rabbitmqctl stop_app
  5. # 清空元数据
  6. [root@rabbitmq-02:~]# rabbitmqctl reset
  7. [root@rabbitmq-03:~]# rabbitmqctl reset
  9. # 添加到集群当中，并成为内存节点，不加--ram 默认是磁盘节点
  10. [root@rabbitmq-02:~]# rabbitmqctl join_cluster rabbit@rabbitmq-01 --ram
  11. [root@rabbitmq-03:~]# rabbitmqctl join_cluster rabbit@rabbitmq-01 --ram
  13. # 启动服务
  14. [root@rabbitmq-02:~]# rabbitmqctl start_app
  15. [root@rabbitmq-03:~]# rabbitmqctl start_app

1.3.6 查看集群状态

  1. [root@rabbitmq-01:~]# rabbitmqctl cluster_status
  2. Cluster status of node rabbit@rabbitmq-01 ...
  3. Basics
  5. Cluster name: rabbit@rabbitmq-01
  7. Disk Nodes
  9. rabbit@rabbitmq-01
  11. RAM Nodes
  13. rabbit@rabbitmq-02
  14. rabbit@rabbitmq-03
  16. Running Nodes
  18. rabbit@rabbitmq-01
  19. rabbit@rabbitmq-02
  20. rabbit@rabbitmq-03
  22. Versions
  24. rabbit@rabbitmq-01: RabbitMQ 3.9.7 on Erlang 24.1.2
  25. rabbit@rabbitmq-02: RabbitMQ 3.9.7 on Erlang 24.1.2
  26. rabbit@rabbitmq-03: RabbitMQ 3.9.7 on Erlang 24.1.2
  28. Maintenance status
  30. Node: rabbit@rabbitmq-01, status: not under maintenance
  31. Node: rabbit@rabbitmq-02, status: not under maintenance
  32. Node: rabbit@rabbitmq-03, status: not under maintenance
  34. Alarms
  36. (none)
  38. Network Partitions
  40. (none)
  42. Listeners
  44. Node: rabbit@rabbitmq-01, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
  45. Node: rabbit@rabbitmq-01, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
  46. Node: rabbit@rabbitmq-02, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
  47. Node: rabbit@rabbitmq-02, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
  48. Node: rabbit@rabbitmq-03, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
  49. Node: rabbit@rabbitmq-03, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
  51. Feature flags
  53. Flag: implicit_default_bindings, state: enabled
  54. Flag: maintenance_mode_status, state: enabled
  55. Flag: quorum_queue, state: enabled
  56. Flag: stream_queue, state: enabled
  57. Flag: user_limits, state: enabled
  58. Flag: virtual_host_metadata, state: enabled

可以看见新加入的节点信息。

1.3.8 开启镜像模式

在任意一台节点上执行下面的命令即可：

  1. rabbitmqctl set_policy ha-all "#" '{"ha-mode":"all"}'

注意：这里指定了 ha-mode 的值为 all ，代表消息会被同步到所有节点的相同队列中。当集群机器较多时，复制的性能开销会非常大，此时再使用 all 就不太合适了，需要选择合适的复制系数。通常可以遵循过半写原则，即对于一个节点数为 n 的集群，只需要同步到 n/2+1 个节点上即可。此时需要同时修改镜像策略为 exactly，并指定复制系数 ha-params，具体命令如下：

  1. rabbitmqctl set_policy ha-two "^" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

2. 其他配置

2.1 开启 Web 管理界面

  1. rabbitmq-plugins enable rabbitmq_management

2.2 配置文件

配置文件参考模板

  1. vim /etc/rabbitmq/rabbitmq.conf
  2. ...
  3. # 配置远程登录
  4. loopback_users.guest = false

3. 使用和操作

3.1 操作用户并授权

  1. # 创建用户
  2. rabbitmqctl add_user rabbitmq '12345678'
  4. # 设置用户[管理员]标签
  5. rabbitmqctl set_user_tags rabbitmq administrator
  7. # 创建virtual host
  8. rabbitmqctl add_vhost /vhost1
  10. # 为用户授权可以访问的[virtual host]和操作类型[配置、读、写]
  11. rabbitmqctl set_permissions -p /vhost1 rabbitmq '.*' '.*' '.*'
  13. # 删除一个用户
  14. rabbitmqctl delete_user Username
  16. # 修改用户的密码
  17. rabbitmqctl change_password Username Newpassword
  19. # 查看当前用户列表
  20. rabbitmqctl list_users

3.2 RabbitMQ 角色权限

  • none：不能访问 management_plugin（图形管理界面）
  • management：单一 virtual hosts 用户，用户仅可以通过 AMQP 协议查看和自己相关的信息。
  • policymaker：单一 virtual hosts 用户，另外可以查看、创建和删除自己的 virtual hosts 所属的 policies 和 parameters。
  • monitoring：监控用户，可以查看所有信息。
  • administrator：管理员用户。

    3.3 rabbitmqctl 命令详解

    命令格式：rabbitmqctl [-n <node>] [-q] <command> [<command options>]

    3.3.1 基本命令

    ```bash

    停止运行rabbitmq

    rabbitmqctl stop

停止运行rabbitmq上的应用

rabbitmqctl stop_app

等待rabbitmq服务启动

rabbitmqctl wait

初始化node状态(需要先执行rabbitmqctl stop_app)

rabbitmqctl reset

强制初始化node状态

rabbitmqctl force_reset

轮转日志文件

rabbitmqctl rotate_logs 

  1. <a name="aP1VC"></a>
  2. ### 3.3.2 cluster集群管理
  3. ```bash
  4. # 默认node以disc node加入集群，--ram表示node以ram node加入集群中(要先执行rabbitmqctl stop_app)
  5. rabbitmqctl join_cluster <node name> --ram
  7. # 显示cluster中的所有node
  8. rabbitmqctl cluster_status
  10. # 改变一个cluster中node的模式，注意，转换前必须先停止节点，不能把一个集群中唯一的disk node转化为ram node
  11. rabbitmqctl change_cluster_node_type disc | ram
  13. # 远程移除cluster中的一个node，前提是该node必须处于offline状态，如果是online状态，则需要加--offline参数。
  14. rabbitmqctl forget_cluster_node --offline
  16. # 远程更新cluster中的node
  17. rabbitmqctl update_cluster_nodes clusternode
  19. # 同步镜像队列
  20. rabbitmqctl sync_queue queue
  22. # 取消同步镜像队列
  23. rabbitmqctl cancel_sync_queue queue

3.3.3 用户管理

  1. # 添加rabbitmq用户
  2. rabbitmqctl add_user <username> <password>
  4. # 删除rabbitmq用户
  5. rabbitmqctl delete_user <username>
  7. # 改变rabbitmq用户密码
  8. rabbitmqctl change_password <username> <newpassword>
  10. # 清除用户密码，禁止用户登录
  11. rabbitmqctl clear_password <username>
  13. # 设置用户标签
  14. rabbitmqctl set_user_tags <username> <tag1> <tag2> ... <tag_n>
  16. # 列出用户
  17. rabbitmqctl list_users
  19. # 创建一个vhosts
  20. rabbitmqctl add_vhost <vhostpath>
  22. # 删除一个vhosts
  23. rabbitmqctl delete_vhost <vhostpath>
  25. # 列出vhosts
  26. rabbitmqctl list_vhosts <vhostinfoitem1> <vhostinfoitem2> ... <vhostinfoitem_n>
  28. # 针对一个vhosts 给用户赋予相关权限
  29. rabbitmqctl set_permissions [-p <vhostpath>] <user> <conf> <write> <read>
  31. # 清除一个用户对vhosts的权限
  32. rabbitmqctl clear_permissions [-p <vhostpath>] <username>
  34. # 列出哪些用户可以访问该vhosts
  35. rabbitmqctl list_permissions [-p <vhostpath>]
  37. #列出该用户的访问权限
  38. rabbitmqctl list_user_permissions <username>
  40. # 修改vhost路径参数
  41. rabbitmqctl set_parameter [-p <vhostpath>] <component_name> <key> <value>
  43. # 清除vhost路径参数
  44. rabbitmqctl clear_parameter [-p <vhostpath>] <component_name> <key>
  46. # 列出vhost路径参数
  47. rabbitmqctl list_parameters [-p <vhostpath>]

3.3.4 策略管理

  1. # priority:整数优先级 apply-to:策略应用类型范围，有[all、queues、exchange] name:策略名称 pattern:匹配资源正则表达式 definition:json格式设置的策略
  2. rabbitmqctl set_policy [-p <vhostpath>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition(json)>
  4. #清除一个策略
  5. rabbitmqctl clear_policy [-p <vhostpath>] <name>
  7. # 列出已有的策略
  8. rabbitmqctl list_policies [-p <vhostpath>]
  10. # queues exchanges
  11. # 返回queue的信息，如果省略了-p参数，则默认显示的是"/"vhosts的信息。
  12. rabbitmqctl list_queues [-p <vhostpath>] [<queueinfoitem> ...]
  14. # 返回exchange的信息
  15. rabbitmqctl list_exchanges [-p <vhostpath>] [<exchangeinfoitem> ...]
  17. # 返回绑定信息
  18. rabbitmqctl list_bindings [-p <vhostpath>] [<bindinginfoitem> ...]
  20. # 返回链接信息
  21. rabbitmqctl list_connections [<connectioninfoitem> ...]
  23. # 返回目前所有的channels
  24. rabbitmqctl list_channels [<channelinfoitem> ...]
  26. # 返回consumers
  27. rabbitmqctl list_consumers [-p <vhostpath>]
  29. # 显示broker的状态
  30. rabbitmqctl status
  32. # 显示环境参数的信息
  33. rabbitmqctl environment
  35. # 返回一个服务状态report
  36. rabbitmqctl report
  38. # 返回一个服务状态eval
  39. rabbitmqctl eval <expr>

3.4 手动安装插件

RabbitMQ 提供很多插件，需要手动去官方插件社区下载安装。下载好对应版本的插件后放在/usr/lib/rabbitmq/lib/rabbitmq_server-<Version>/plugins目录下，然后使用rabbitmq-plugins enable <Plugin-Name>命令启动即可。

4. 报错解决

4.1 统计数据库内存爆满

4.1.1 现象

日志：

  1. **********************************************************
  2. *** Publishers will be blocked until this alarm clears ***
  3. **********************************************************
  5. =INFO REPORT==== 16-Jan-2022::09:31:35 ===
  6. vm_memory_high_watermark clear. Memory used:8069568592 allowed:13426866585
  8. =WARNING REPORT==== 16-Jan-2022::09:31:35 ===
  9. memory resource limit alarm cleared on node rabbit@Agent03
  11. =WARNING REPORT==== 16-Jan-2022::09:31:35 ===
  12. memory resource limit alarm cleared across the cluster
  14. =INFO REPORT==== 16-Jan-2022::09:37:28 ===
  15. vm_memory_high_watermark set. Memory used:14187251472 allowed:13426866585
  17. =WARNING REPORT==== 16-Jan-2022::09:37:28 ===
  18. memory resource limit alarm set on node rabbit@Agent03.
  1. 管理界面：<br />![image.png](https://cdn.nlark.com/yuque/0/2022/png/12817856/1642302175884-53e71e1c-ca86-48eb-9852-86c53716eb57.png#clientId=ue4a15b0e-a6e5-4&crop=0&crop=0&crop=1&crop=1&from=paste&height=631&id=ueb7caa21&margin=%5Bobject%20Object%5D&name=image.png&originHeight=1262&originWidth=2560&originalType=binary&ratio=1&rotation=0&showTitle=false&size=194096&status=done&style=none&taskId=ub5dfd134-bcc3-4eb4-99a3-fc62affb6f8&title=&width=1280)

4.1.2 解决方法

统计数据库完全存储在内存中。所有内容都是短暂的。在版本3.6.7之前，stats数据库存储在单个节点上。从版本3.6.7开始，每个节点都有自己的统计数据库，其中包含记录在该节点上的一小部分统计数据。当统计数据库内存过高时可以重新启动统计数据库。
3.6.2版本之前重新启动数据库命令：

  1. rabbitmqctl eval 'exit(erlang:whereis(rabbit_mgmt_db), please_terminate).'

3.6.2-3.6.5版本：

  1. rabbitmqctl eval 'supervisor2:terminate_child(rabbit_mgmt_sup_sup, rabbit_mgmt_sup), rabbit_mgmt_sup_sup:start_child().'

注意：这些命令必须在托管数据库的节点上执行。

从 3.6.7 版本开始，可以使用每个节点重置数据库，另外3.6.10版本的 management 控制台已经可见 reset 按钮

  1. rabbitmqctl eval 'rabbit_mgmt_storage:reset().'

重置所有节点上的整个管理数据库：

  1. rabbitmqctl eval 'rabbit_mgmt_storage:reset_all().'