应用与集群管理

本章主要介绍应用与集群相关的一些操作管理命令，包括关闭、重置、开启服务，还有建立集群的一些信息。有关集群搭建请参考后续的「RabbitMQ 运维」章节

应用管理

停止运行 stop 用于停止运行 RabbitMQ 和 Erlang 虚拟机。

  1. rabbitmqctl stop [pid_file]
  3. 参数：
  4. pid_file：通过 rabbitmq-server 命令启动 RabbitMQ 服务创建的。默认情况存放与 rabbitmq安装目录/var/lib/rabbitmq/mnesia 目录下；可以通过 RABBITMQ_PID_FILE 环境变量来改变存放路径。
  5. 注意：通过 rabbitmq-server --detach 这个后缀命令启动不会生成 pid_file 文件
  8.           Copied!

1
2
3
4
5
6

实践练习

  1. # 注意啊，我们通过 rabbitmq-server -detached 后台运行启动的
  2. # 可以通过它来停止，而且写一个错误的路径也可以停止运行
  3. # 通过下面讲解的 shutdown 命令，可以看到这个 pid 或许不是真正的 pid 文件
  4. # 因为在启动的时候打印了 Warning: PID file not written; -detached was passed.
  5. [root@study mnesia]# rabbitmqctl stop /opt/rabbitmq/var/lib/rabbitmq/mnesia/rabbit@study.pid
  6. Stopping and halting node rabbit@study
  8.           Copied!

1
2
3
4
5
6

停止运行 shutdown

用于停止运行 RabbitMQ 和 Erlang 虚拟机。

  1. rabbitmqctl shutdown
  3.           Copied!

1

执行该指令会阻塞知道 Erlang 虚拟机进程退出。如果 RabbitMQ 没有成功关闭，则会返回一个非零值。
与 stop 不同的是，不需要指定 pid_file，而且可以阻塞等待指定进程的关闭
实践练习

  1. [root@study mnesia]# rabbitmqctl shutdown
  2. Shutting down RabbitMQ node rabbit@study running at PID 19531
  3. Waiting for PID 19531 to terminate
  4. RabbitMQ node rabbit@study running at PID 19531 successfully shut down
  6.           Copied!

1
2
3
4

停止 RabbitMQ 服务应用：stop_app

停止 RabbitMQ 服务应用，但是 Erlang 虚拟机还是处于运行状态。此命令的执行优先于其他管理操作（这些管理操作需要先停止 RabbitMQ 应用），比如 rabbitmqct reset
实践练习

  1. [root@study mnesia]# rabbitmqctl stop_app
  2. Stopping rabbit application on node rabbit@study
  4.           Copied!

1
2

启动 RabbitMQ 服务应用：start_app

该命令的典型应用场景是：在执行了其他的管理操作之后，重新启动之前停止的 RabbitMQ 应用，比如 rabbitmqct reset
实践练习

  1. [root@study mnesia]# rabbitmqctl start_app
  2. Starting node rabbit@study
  4.           Copied!

1
2

等待 RabbitMQ 应用的启动：wait

  1. rabbitmqctl wait [pid_file]
  3.           Copied!

1

等待 RabbitMQ 应用的启动。它会 等到 pid_file 的创建，然后 等待 pid_file 中所代表的进程启动。当指定的进程没有启动 RabbitMQ 应用而关闭时将返回失败。
实践练习

  1. [root@study mnesia]# rabbitmqctl wait /opt/rabbitmq/var/lib/rabbitmq/mnesia/rabbit@study.pid
  2. Waiting for rabbit@study
  3. pid is 18130
  4. Error: process_not_running
  5. # 前面讲到启动时，有一个警告 Warning: PID file not written; 
  6. # 在这里也能证明出来，的确没有写入。这个 18130 可能是最开始笔者不小心直接执行了 rabbitmq-server 创建的
  8.           Copied!

1
2
3
4
5
6

重置 RabbitMQ 节点：reset

  1. rabbitmqctl reset
  3.           Copied!

1

将 RabbitMQ 节点重置还原到最初状态。包括从 原来所在的集群中删除此节点，从管理数据库中删除所有的配置数据，如已配置的用户、vhost 等。以及删除所有的持久化消息。
执行该命令前必须停止 RabbitMQ 应用，比如先执行 rabbitmqctl stop_app
这里笔者就不尝试实践了，只有一个节点

强制重置 RabbitMQ 节点：force_reset

  1. rabbitmqctl force_reset
  3.           Copied!

1

与 reset 类似，不过它无论当前管理数据库的状态和集群配置是什么，都会无条件的重置节点。只能在数据库或集群配置已损坏的情况下使用。

配置轮换日志文件：rotate_logs

  1. rabbitmqctl rotate_logs {suffix}
  3.           Copied!

1

配置 RabbitMQ 节点轮换日志文件。RabbitMQ 节点会将原来的日志文件中的内容追加到「原始名称 + 后缀」的日志文件中，然后再将新的日志内容记录到新创建的日志文件中（与原日志同名）。
当目标文件不存在时，会重新创建。如果不指定 suffix 后缀，则日志文件只是重新打开而不会进行轮换。
实践练习

  1. # 进入到日志目录
  2. [root@study ~]# cd /opt/rabbitmq/var/log/rabbitmq/
  3. [root@study rabbitmq]# ll
  4. 总用量 60
  5. -rw-r--r--. 1 root root 59781 6月  29 06:04 rabbit@study.log
  6. -rw-r--r--. 1 root root     0 6月  23 10:23 rabbit@study-sasl.log
  8. # 执行轮换操作
  9. [root@study rabbitmq]# rabbitmqctl rotate_logs .1
  10. Rotating logs to files with suffix ".1"
  12. [root@study rabbitmq]# ll
  13. 总用量 60
  14. -rw-r--r--. 1 root root     0 6月  29 06:17 rabbit@study.log
  15. -rw-r--r--. 1 root root 59856 6月  29 06:17 rabbit@study.log.1
  16. -rw-r--r--. 1 root root     0 6月  29 06:17 rabbit@study-sasl.log
  17. -rw-r--r--. 1 root root     0 6月  29 06:17 rabbit@study-sasl.log.1
  18. # 可以看到原来的文件被归档了一样。
  20.           Copied!

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

编译：hipe_compile

  1. rabbitmqctl hipe_compile {directory}
  3.           Copied!

1

将部分 RabbitMQ 代码用 HiPE 编译，并将编译后的 .beam 文件保存到指定的文件目录中。如果该目录不存在则会创建，如果存在，则先删除里面的任何 .beam 文件。
如果要使用预编译的这些文件，则需要设置 RABBITMQ_SERVER_CODE_PATH 环境变量来指定 hipe_compile 调用的路径
名词解释：

  • HiPE：High Performance Erlang，是 Erlang 版的 JIT 编译
  • .beam ：是 Erlang 编译器生成的文件格式，可以直接加载到 Erlang 虚拟机中运行的文件格式

如下所示

  1. [root@study rabbitmq]# rabbitmqctl hipe_compile /opt/rabbitmq/tmp/rabbit-hipe/ebin
  3. HiPE compiling:  |---------------------------------------------------------|
  4.                  |#########################################################|
  6. Compiled 57 modules in 221s
  8.           Copied!

1
2
3
4
5
6
7

虽然知道有啥用处，指定的新目录里面的确多了很多 .beamni c 文件

集群管理

这里只列出来命令，具体的使用详见后续章节 RabbitMQ 运维;

#加入集群：join_cluster

  1. rabbitmqctl join_cluster {cluster_node} [--ram]
  3.           Copied!

1

将节点计入指定集群中

集群状态：cluster_status

  1. rabbitmqctl cluster_status
  3.           Copied!

1

显示集群状态。

修改集群节点类型

  1. rabbitmqctl change_cluster_node_type {disc | ram }
  3.           Copied!

1

修改集群节点的类型，修改之前需要停止 RabbitMQ 引用

删除集群节点：forget_cluster_node

  1. rabbitmqctl forget_cluster_node [--offline]
  3.           Copied!

1

将节点从集群中删除，允许离线执行。

更新集群信息：update_cluster_nodes

  1. rabbitmqctl update_cluster_nodes {clusternode}
  3.           Copied!

1

在集群中的节点应用启动前咨询 clusternode 节点的最新信息，并更新相应的集群信息；
与 join_cluster 不同，它不加入集群；如这种情况：

  • 节点 A 和节点 B 在集群中，
  • 当节点 A 离线了，节点 C 又和 节点 B 组成了一个集群，
  • 然后节点 B 又离开了集群

当节点 A 醒来时，它会尝试联系节点 B，但是这样会失败，因为节点 B 已经不在集群中了。

  1. rabbitmqctl update_cluster_nodes -n A C 
  3.           Copied!

1

使用以上命令，可解决这种场景下出现的问题。

确保节点可以启动：force_boot

  1. rabbitmqctl force_boot
  3.           Copied!

1

确保节点可以启动，即使它不是最后一个关闭的节点。
通常情况下，当关闭整个 RabbitMQ 集群时，重启的第一个节点 应该是最后关闭的节点，因为它可以看到其他节点所看不到的事情。但是有时候会出现一些异常情况，比如整个集群都断电，所有节点都不是最后一个关闭的。
在这种情况下就可以使用该命令告诉节点可以无条件启动。
在此节点关闭后，集群的任何变化，都会丢失。如果最后一个关闭的节点永久丢失了，那么需要优先使用

  1. rabbitmqctl forget_cluster_node --offline
  3.           Copied!

1

因为他可以确保镜像队列的正常运转。

同步镜像队列内容：sync_queue

  1. rabbitmqctl sync_queue [-p vhost] {queue}
  3.           Copied!

1

指定 未同步队列 queue 的 slave 镜像可以同步 master 镜像行的内容。同步期间此队列会被阻塞（所有此队列的生产消息都会被阻塞），直到同步完成。
前提是：配置了 queue 镜像
注意：未同步队列中的消息被消耗尽后，最终也会变成同步，此命令主要用于未耗尽的队列。（详见后组章节 RabbitMQ 高阶）

取消镜像队列同步：cancel_sync_queue

  1. rabbitmqctl cancel_sync_queue [-p vhost] {queue}
  3.           Copied!

1

设置集群名称：set_cluster_name

  1. rabbitmqctl set_cluster_name {name}
  3.           Copied!

1

设置集群名称。
集群名称在客户端连接时会通报给客户端。Federation 和 Shovel 插件也会有用到集群名的地方，详细内容参考后续章节 跨越集群的界限
集群名称 默认是集群中第一个节点的名称，通过该命令重新设置。在 web 管理界面右上角有可以修改，如下图
image.png
通过集群状态也能查看到当前的集群名称

  1. [root@study rabbitmq]# rabbitmqctl cluster_status
  2. Cluster status of node rabbit@study
  3. [{nodes,[{disc,[rabbit@study]}]},
  4.  {running_nodes,[rabbit@study]},
  5.  {cluster_name,<<"rabbit@study">>},
  6.  {partitions,[]},
  7.  {alarms,[{rabbit@study,[]}]}]
  8. # 这个是没有操作过集群的，默认就是个单节点的集群