MQ常用命令集合
1、分配MQ
./mqadmin allocateMQ -n localhost:9876 -t tst-topic -i ipList
ipList 以逗号分隔
2、删除topic
./mqadmin deleteTopic -n localhost:9876 -t zto-example -c DefultCluster
3、获取topic的cluster
./mqadmin topicClusterList -n 192.168.1.x:9876 -t SCANRECORD
4、查看Topic列表信息
./mqadmin topicList -n localhost:9876
5、查看Topic路由信息
./mqadmin topicRoute -n 192.168.1.x:9876 -t SCANRECORD
6、查看topic状态
./mqadmin topicStatus -n 192.168.1.174:9876 -t SCANRECORD
7、更改Topic权限
./mqadmin updateTopicPerm -t SCANRECORD -p put -n 192.168.1.x:9876
8、创建/修改Topic
./mqadmin updateTopic -c DefaultCluster -n localhost:9876 -t threezto-test -r 12 -w 12
# 查看堆积
./mqadmin brokerConsumeStats -b 10.30.12.55:10911 -n 127.0.0.1:9876
# 查看所有消费进度
./mqadmin consumerProgress -n localhost:9876
# 查看具体消费者名字
./mqadmin consumerProgress -g comsumerName -n localhost:9876
RocketMq:响应码列表
package org.apache.rocketmq.common.protocol;
import org.apache.rocketmq.remoting.protocol.RemotingSysResponseCode;
public class ResponseCode extends RemotingSysResponseCode {
public static final int FLUSH_DISK_TIMEOUT = 10;
public static final int SLAVE_NOT_AVAILABLE = 11;
public static final int FLUSH_SLAVE_TIMEOUT = 12;
public static final int MESSAGE_ILLEGAL = 13;
public static final int SERVICE_NOT_AVAILABLE = 14;
public static final int VERSION_NOT_SUPPORTED = 15;
public static final int NO_PERMISSION = 16;
public static final int TOPIC_NOT_EXIST = 17;
public static final int TOPIC_EXIST_ALREADY = 18;
public static final int PULL_NOT_FOUND = 19;
public static final int PULL_RETRY_IMMEDIATELY = 20;
public static final int PULL_OFFSET_MOVED = 21;
public static final int QUERY_NOT_FOUND = 22;
public static final int SUBSCRIPTION_PARSE_FAILED = 23;
public static final int SUBSCRIPTION_NOT_EXIST = 24;
public static final int SUBSCRIPTION_NOT_LATEST = 25;
public static final int SUBSCRIPTION_GROUP_NOT_EXIST = 26;
public static final int FILTER_DATA_NOT_EXIST = 27;
public static final int FILTER_DATA_NOT_LATEST = 28;
public static final int TRANSACTION_SHOULD_COMMIT = 200;
public static final int TRANSACTION_SHOULD_ROLLBACK = 201;
public static final int TRANSACTION_STATE_UNKNOW = 202;
public static final int TRANSACTION_STATE_GROUP_WRONG = 203;
public static final int NO_BUYER_ID = 204;
public static final int NOT_IN_CURRENT_UNIT = 205;
public static final int CONSUMER_NOT_ONLINE = 206;
public static final int CONSUME_MSG_TIMEOUT = 207;
public static final int NO_MESSAGE = 208;
public static final int UPDATE_AND_CREATE_ACL_CONFIG_FAILED = 209;
public static final int DELETE_ACL_CONFIG_FAILED = 210;
public static final int UPDATE_GLOBAL_WHITE_ADDRS_CONFIG_FAILED = 211;
}
标签:int,mqadmin,public,9876,MQ,常用命令,集合,static,final
From: https://www.cnblogs.com/hsyw/p/17525388.html