rocketmq控制台指令

1.1. 控制台使用 RocketMQ提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker等信息的管理； l 登录控制台： 首先进入RocketMQ工程，进入/RocketMQ/bin 在该目录下有个mqadmin脚本 l 查看帮助： 在mqadmin下可以查看有哪些命令 shmqadmin l 查看具体命令的使用 sh mqadmin help 命令名称 例如，查看updateTopic的使用 sh mqadmin helpupdateTopic 1.2. 详细命令 1.2.1. 创建Topic 指updateTopic 类路com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand 令 参数 径 是否说明 必填 -b 如果 -broker地址，表示topic建在该broker c为空，则必填 -c 如果 -cluster名称，表示topic建在该集群（集群可通过clusterList查b为询） 空，则必填 -h -n -p -r -w -t 否 是 否 否 否 是 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 指定新topic的权限限制( W|R|WR ) 可读队列数（默认为8） 可写队列数（默认为8） topic名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ） 举在集群DefaultCluster上创建主题ZTEExample，nameserve地址为10.45.47.168:9876 例 sh mqadmin updateTopic –n 10.45.47.168 –c DefaultCluster –t ZTEExample 1.2.2. 删除Topic 指deleteTopic 类路com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand 令 参数 径 是否说明 必填 -c 是 cluster名称，表示删除某集群下的某个topic （集群可通过clusterList查询） -h -n -t 否 是 是 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;… topic名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ） 举在集群DefaultCluster上删除主题ZTEExample，nameserve地址为10.45.47.168:9876 例 sh mqadmin deleteTopic –n 10.45.47.168:9876 –c DefaultCluster –t ZTEExample 1.2.3. 创建（修订）订阅组 指updateSubGroup 类令 路径 参数 是否必填 -b 如果 broker地址，表示订阅组建在该broker –c为空，则必填 -c 如果 cluster名称，表示topic建在该集群（集群可通过clusterList查询） –b为空，则必填 -d -g -i 否 是否容许广播方式消费 是 订阅组名 否 从哪个broker开始消费 说明 com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand -m -q -r -s -w -h -n 举 例 否 是否容许从队列的最小位置开始消费，默认会设置为false 否 消费失败的消息放到一个重试队列，每个订阅组配置几个重试队列 否 重试消费最大次数，超过则投递到死信队列，不再投递，并报警 否 消费功能是否开启 否 发现消息堆积后，将Consumer的消费请求重定向到另外一台Slave机器 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 1.2.4. 删除订阅组配置 指deleteSubGroup 类令 路径 参数 是否必填 -b 如果 broker地址，表示订阅组建在该broker –c为空，则必填 说明 com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand-c 如果 cluster名称，表示topic建在该集群（集群可通过clusterList查询） –b为空，则必填 -g -h -n 举 例 是 订阅组名 否 打印帮助 是 nameserve服务地址列表，格式ip:port;ip:port;... 1.2.5. 更新Broker配置文件 指updateBrokerConfig 类令 路径 参数 是否必填 -b 如果 broker地址，表示订阅组建在该broker –c为空，说明 com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand