功能概述

RabbitMQ 集群创建完成后,Client 节点上已经配置 rabbitmqadmin 工具,用户可以直接使用。用户如需在其他服务器上自行下载或自定义配置 rabbitmqadmin 工具,可参考附录内容

本文仅介绍常用命令,更多信息请查看官方文档

操作步骤

步骤一:登录 RabbitMQ Client 节点

详情可参考登录 RabbitMQ Client 节点

步骤二:操作 RabbitMQ 集群

登录 RabbitMQ Client 节点后,在 Client 节点内部的终端上,分别执行以下操作。

  • 定义一个 queue

    ./rabbitmqadmin declare queue name=test durable=true

    durable=true 表示该队列持久化,并不表示队列中的消息持久化。

  • 查看 queues

    ./rabbitmqadmin list queues
  • 查看 channels

    ./rabbitmqadmin list channels
  • 查看 consumers

    ./rabbitmqadmin list consumers
  • 发送一条消息

    ./rabbitmqadmin publish routing_key=test payload=”just for test”
  • 消费一条消息

    ./rabbitmqadmin get queue=test requeue=true

附录

配置 rabbitmqadmin 工具

  1. 配置待访问 RabbitMQ 集群的云服务器或本地设备与 RabbitMQ 集群之间的网络,确保两者之间的网络通畅。

  2. 执行以下命令行,下载安装 rabbitmqadmin 工具。其中 <节点IP> 可为 RabbitMQ 集群的任意节点 IP,或 Haproxy 节点 IP 地址。

    wget http://<节点 IP>:15672/cli/rabbitmqadmin
    file rabbitmqadmin
    chmod +x rabbitmqadmin

    如 Keepalived VIP 为 192.168.0.253,则命令行示例如下。

    wget http://192.168.0.253:15672/cli/rabbitmqadmin
    
    file rabbitmqadmin
    
    chmod +x rabbitmqadmin
  3. 修改配置文件 rabbitmqadmin 中的 default_options 中的 hostname 为任意 RabbitMQ 节点或者 Haproxy 节点 IP 或者 Keepalived VIP。

  4. 若 RabbitMQ 集群修改了 guest 用户密码,还需要修改配置文件 rabbitmqadmin 中的 default_options 中的用户名和密码配置。