RocketMQ是一种开源的分布式消息中间件,用于在生产和消费过程中传输消息。以下是RocketMQ常用命令:
启动NameServer:
nohup sh mqnamesrv &
启动Broker:
nohup sh mqbroker -n localhost:9876 &
查看NameServer和Broker的运行状态:
sh mqadmin clusterList -n localhost:9876
查看所有Topic:
sh mqadmin topicList -n localhost:9876
创建Topic:
sh mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t testTopic
查看Topic的详细信息:
sh mqadmin topicStatus -n localhost:9876 -t testTopic
发送消息:
sh mqsend -n localhost:9876 -t testTopic -m "Hello RocketMQ"
消费消息:
sh mqconsume -n localhost:9876 -t testTopic -g myGroup -c myConsumer -b 10 -s 10
以上是RocketMQ常用命令的示例,您可以根据需要进行修改或扩展。