rocketmq的基本命令
时间: 2023-11-02 21:23:47 浏览: 102
RocketMQ的基本命令有以下几个:
1. 启动RocketMQ服务器:在解压RocketMQ安装包后,使用命令`nohup sh bin/mqnamesrv &`启动NameServer,然后使用命令`nohup sh bin/mqbroker -n localhost:9876 &`启动Broker。
2. 创建Topic:使用命令`sh bin/mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t <Topic名称>`创建一个新的Topic。
3. 发送消息:使用命令`sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer`启动消息生产者示例,然后按照提示输入消息内容并发送。
4. 消费消息:使用命令`sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer`启动消息消费者示例,然后消费者将接收并打印出消息。
5. 查看Topic列表:使用命令`sh bin/mqadmin topicList -n localhost:9876`查看当前存在的所有Topic。
6. 查看消费者组列表:使用命令`sh bin/mqadmin consumerProgress -g <消费者组名称> -n localhost:9876`查看指定消费者组的消费进度。
7. 查看消息队列列表:使用命令`sh bin/mqadmin queryTopicConsumeByWho -t <Topic名称> -n localhost:9876`查看指定Topic的消费情况。
请注意,上述命令中的`localhost:9876`是默认的NameServer地址和端口,如果您的配置不同,请相应地修改命令中的地址和端口。此外,RocketMQ还提供了更多高级的命令和功能,您可以参考RocketMQ的官方文档以获取更详细的信息。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Linux安装rocketMQ步骤(单机--集群模式)以及rocketMQ基本命令的使用](https://blog.csdn.net/MaleLiu/article/details/108582964)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]
阅读全文