操作指南

 

RocketMQ CLI命令示例

更新时间 2020-12-01

用户可使用ubuntu/p12cHANgepwD通过网页VNC登录客户端节点进行操作。

下面列举几个常见操作,详情可参见官方使用文档

注意

通过此客户端可以对集群中的实际数据进行增删改,请谨慎操作。

发送测试消息

$ /opt/apache-rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

注意

  • RocketMQ 4.3.1 - ShanHe 1.0.0版本节点的环境变量已经内置了name server的地址列表以方便用户使用。
  • 如果在用户使用过程中,管理员对name server节点进行了调整(增删节点),可以退出重新登录以使环境变量生效,或者通过命令重新加载环境变量:source /etc/profile.d/rocketmq-path.sh
  • RocketMQ 4.7.1 - ShanHe 1.1.0版本需要设定环境变量,export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64export NAMESRV_ADDR=namesrv_node_ip:9876 ,同时所有脚本位于 /opt/rocketmq/current/bin/*

接收消息

$ /opt/apache-rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

注意

  • RocketMQ 4.3.1 - ShanHe 1.0.0版本节点的环境变量已经内置了name server的地址列表以方便用户使用。
  • 如果在用户使用过程中,管理员对name server节点进行了调整(增删节点),可以退出重新登录以使环境变量生效,或者通过命令重新加载环境变量:source /etc/profile.d/rocketmq-path.sh
  • RocketMQ 4.7.1 - ShanHe 1.1.0版本需要设定环境变量,export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64export NAMESRV_ADDR=namesrv_node_ip:9876 ,同时所有脚本位于 /opt/rocketmq/current/bin/*

创建Topic

$ /opt/apache-rocketmq/current/bin/mqadmin updateTopic -c DefaultCluster -b 192.168.2.26:10911 -n 192.168.2.29:9876 -t shanhe

提示

  • -c参数后面指定集群名称(在集群“配置参数”选项卡里设置,如未设置则默认为DefaultCluster)。
  • -b参数后面指定broker地址。
  • -n参数后面指定name server地址。

删除Topic

$ /opt/apache-rocketmq/current/bin/mqadmin deleteTopic -c DefaultCluster -n 192.168.2.29:9876 -t shanhe

提示

  • -c参数后面指定集群名称(在集群“配置参数”选项卡里设置,如未设置则默认为DefaultCluster)。
  • -n参数后面指定name server地址。
这篇文档解决了您的问题吗?
0
0