public class DefaultMQAdminExt extends ClientConfig implements MQAdminExt
| 构造器和说明 |
|---|
DefaultMQAdminExt() |
DefaultMQAdminExt(String adminExtGroup) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
createAndUpdateKvConfig(String namespace,
String key,
String value)
在 namespace 上添加或者更新 KV 配置
|
void |
createAndUpdateSubscriptionGroupConfig(String addr,
com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig config)
向指定Broker创建或者更新订阅组配置
|
void |
createAndUpdateTopicConfig(String addr,
com.alibaba.rocketmq.common.TopicConfig config)
向指定Broker创建或者更新Topic配置
|
void |
createTopic(String key,
String newTopic,
int queueNum) |
void |
deleteIpsByProjectGroup(String projectGroup)
删除 project group 对应的所有 server ip
|
void |
deleteKvConfig(String namespace,
String key)
删除 namespace 上的 KV 配置
|
void |
deleteSubscriptionGroup(String addr,
String groupName)
删除 broker 上的 subscription group 信息
|
void |
deleteTopicInBroker(Set<String> addrs,
String topic)
删除 broker 上的 topic 信息
|
void |
deleteTopicInNameServer(Set<String> addrs,
String topic)
删除 broker 上的 topic 信息
|
long |
earliestMsgStoreTime(com.alibaba.rocketmq.common.message.MessageQueue mq) |
com.alibaba.rocketmq.common.protocol.body.ClusterInfo |
examineBrokerClusterInfo()
查看集群信息
|
com.alibaba.rocketmq.common.protocol.body.ConsumerConnection |
examineConsumerConnectionInfo(String consumerGroup)
查看Consumer网络连接、订阅关系
|
com.alibaba.rocketmq.common.admin.ConsumeStats |
examineConsumeStats(String consumerGroup)
查询消费进度
|
com.alibaba.rocketmq.common.protocol.body.ProducerConnection |
examineProducerConnectionInfo(String producerGroup,
String topic)
查看Producer网络连接
|
com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig |
examineSubscriptionGroupConfig(String addr,
String group)
查询指定Broker的订阅组配置
|
com.alibaba.rocketmq.common.TopicConfig |
examineTopicConfig(String addr,
String topic)
查询指定Broker的Topic配置
|
com.alibaba.rocketmq.common.protocol.route.TopicRouteData |
examineTopicRouteInfo(String topic)
查看Topic路由信息
|
com.alibaba.rocketmq.common.admin.TopicStatsTable |
examineTopicStats(String topic)
查询Topic Offset信息
|
com.alibaba.rocketmq.common.protocol.body.TopicList |
fetchAllTopicList()
从Name Server获取所有Topic列表
|
com.alibaba.rocketmq.common.protocol.body.KVTable |
fetchBrokerRuntimeStats(String brokerAddr)
获取Broker运行时数据
|
String |
getAdminExtGroup() |
String |
getCreateTopicKey() |
String |
getIpsByProjectGroup(String projectGroup)
通过 project 获取所有的 server ip 信息
|
String |
getKVConfig(String namespace,
String key)
从Name Server获取一个配置项
|
com.alibaba.rocketmq.common.protocol.body.KVTable |
getKVListByNamespace(String namespace)
获取指定Namespace下的所有kv
|
List<String> |
getNameServerAddressList()
获取Name Server地址列表
|
String |
getProjectGroupByIp(String ip)
通过 server ip 获取 project 信息
|
long |
maxOffset(com.alibaba.rocketmq.common.message.MessageQueue mq) |
long |
minOffset(com.alibaba.rocketmq.common.message.MessageQueue mq) |
void |
putKVConfig(String namespace,
String key,
String value)
向Name Server增加一个配置项
|
QueryResult |
queryMessage(String topic,
String key,
int maxNum,
long begin,
long end) |
List<com.alibaba.rocketmq.common.admin.RollbackStats> |
resetOffsetByTimestamp(String consumerGroup,
String topic,
long timestamp,
boolean force)
按照时间回溯消费进度
|
long |
searchOffset(com.alibaba.rocketmq.common.message.MessageQueue mq,
long timestamp) |
void |
setAdminExtGroup(String adminExtGroup) |
void |
setCreateTopicKey(String createTopicKey) |
void |
shutdown() |
void |
start() |
void |
updateBrokerConfig(String brokerAddr,
Properties properties)
更新Broker配置
|
com.alibaba.rocketmq.common.message.MessageExt |
viewMessage(String msgId) |
com.alibaba.rocketmq.common.protocol.body.ConsumeByWho |
whoConsumeTheMessage(String msgId)
查看某个订阅组被谁消费了
|
int |
wipeWritePermOfBroker(String namesrvAddr,
String brokerName)
清除某个Broker的写权限,针对所有Name Server
|
buildMQClientId, cloneClientConfig, getClientCallbackExecutorThreads, getClientIP, getHeartbeatBrokerInterval, getInstanceName, getNamesrvAddr, getPersistConsumerOffsetInterval, getPollNameServerInteval, resetClientConfig, setClientCallbackExecutorThreads, setClientIP, setHeartbeatBrokerInterval, setInstanceName, setNamesrvAddr, setPersistConsumerOffsetInterval, setPollNameServerInteval, toStringpublic DefaultMQAdminExt()
public DefaultMQAdminExt(String adminExtGroup)
public void createTopic(String key, String newTopic, int queueNum) throws MQClientException
createTopic 在接口中 MQAdminMQClientExceptionpublic long searchOffset(com.alibaba.rocketmq.common.message.MessageQueue mq,
long timestamp)
throws MQClientException
searchOffset 在接口中 MQAdminMQClientExceptionpublic long maxOffset(com.alibaba.rocketmq.common.message.MessageQueue mq)
throws MQClientException
maxOffset 在接口中 MQAdminMQClientExceptionpublic long minOffset(com.alibaba.rocketmq.common.message.MessageQueue mq)
throws MQClientException
minOffset 在接口中 MQAdminMQClientExceptionpublic long earliestMsgStoreTime(com.alibaba.rocketmq.common.message.MessageQueue mq)
throws MQClientException
earliestMsgStoreTime 在接口中 MQAdminMQClientExceptionpublic com.alibaba.rocketmq.common.message.MessageExt viewMessage(String msgId) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
viewMessage 在接口中 MQAdmincom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end) throws MQClientException, InterruptedException
queryMessage 在接口中 MQAdminMQClientExceptionInterruptedExceptionpublic void start()
throws MQClientException
start 在接口中 MQAdminExtMQClientExceptionpublic void shutdown()
shutdown 在接口中 MQAdminExtpublic void createAndUpdateTopicConfig(String addr, com.alibaba.rocketmq.common.TopicConfig config) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtcreateAndUpdateTopicConfig 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void createAndUpdateSubscriptionGroupConfig(String addr, com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig config) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtcreateAndUpdateSubscriptionGroupConfig 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr, String group)
MQAdminExtexamineSubscriptionGroupConfig 在接口中 MQAdminExtpublic com.alibaba.rocketmq.common.TopicConfig examineTopicConfig(String addr, String topic)
MQAdminExtexamineTopicConfig 在接口中 MQAdminExtpublic com.alibaba.rocketmq.common.admin.TopicStatsTable examineTopicStats(String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
MQAdminExtexamineTopicStats 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionMQBrokerExceptionpublic com.alibaba.rocketmq.common.admin.ConsumeStats examineConsumeStats(String consumerGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
MQAdminExtexamineConsumeStats 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionMQBrokerExceptionpublic com.alibaba.rocketmq.common.protocol.body.ClusterInfo examineBrokerClusterInfo()
throws InterruptedException,
com.alibaba.rocketmq.remoting.exception.RemotingConnectException,
com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
MQBrokerException
MQAdminExtexamineBrokerClusterInfo 在接口中 MQAdminExtInterruptedExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptionMQBrokerExceptionpublic com.alibaba.rocketmq.common.protocol.route.TopicRouteData examineTopicRouteInfo(String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException
MQAdminExtexamineTopicRouteInfo 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionpublic void putKVConfig(String namespace, String key, String value)
MQAdminExtputKVConfig 在接口中 MQAdminExtpublic String getKVConfig(String namespace, String key)
MQAdminExtgetKVConfig 在接口中 MQAdminExtpublic com.alibaba.rocketmq.common.protocol.body.ConsumerConnection examineConsumerConnectionInfo(String consumerGroup) throws InterruptedException, MQBrokerException, com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException
MQAdminExtexamineConsumerConnectionInfo 在接口中 MQAdminExtInterruptedExceptionMQBrokerExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionpublic com.alibaba.rocketmq.common.protocol.body.ProducerConnection examineProducerConnectionInfo(String producerGroup, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
MQAdminExtexamineProducerConnectionInfo 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionMQBrokerExceptionpublic int wipeWritePermOfBroker(String namesrvAddr, String brokerName) throws com.alibaba.rocketmq.remoting.exception.RemotingCommandException, com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, InterruptedException, MQClientException
MQAdminExtwipeWritePermOfBroker 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingCommandExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptionInterruptedExceptionMQClientExceptionpublic String getAdminExtGroup()
public void setAdminExtGroup(String adminExtGroup)
public String getCreateTopicKey()
public void setCreateTopicKey(String createTopicKey)
public List<String> getNameServerAddressList()
MQAdminExtgetNameServerAddressList 在接口中 MQAdminExtpublic com.alibaba.rocketmq.common.protocol.body.ConsumeByWho whoConsumeTheMessage(String msgId)
MQAdminExtwhoConsumeTheMessage 在接口中 MQAdminExtpublic com.alibaba.rocketmq.common.protocol.body.TopicList fetchAllTopicList()
throws com.alibaba.rocketmq.remoting.exception.RemotingException,
MQClientException,
InterruptedException
MQAdminExtfetchAllTopicList 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionpublic com.alibaba.rocketmq.common.protocol.body.KVTable fetchBrokerRuntimeStats(String brokerAddr) throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, InterruptedException, MQBrokerException
MQAdminExtfetchBrokerRuntimeStats 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptionInterruptedExceptionMQBrokerExceptionpublic void deleteTopicInBroker(Set<String> addrs, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtdeleteTopicInBroker 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void deleteTopicInNameServer(Set<String> addrs, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtdeleteTopicInNameServer 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void deleteSubscriptionGroup(String addr, String groupName) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtdeleteSubscriptionGroup 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void createAndUpdateKvConfig(String namespace, String key, String value) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtcreateAndUpdateKvConfig 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void deleteKvConfig(String namespace, String key) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtdeleteKvConfig 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic String getProjectGroupByIp(String ip) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtgetProjectGroupByIp 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic String getIpsByProjectGroup(String projectGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtgetIpsByProjectGroup 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic void deleteIpsByProjectGroup(String projectGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtdeleteIpsByProjectGroup 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic List<com.alibaba.rocketmq.common.admin.RollbackStats> resetOffsetByTimestamp(String consumerGroup, String topic, long timestamp, boolean force) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
MQAdminExtresetOffsetByTimestamp 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionpublic com.alibaba.rocketmq.common.protocol.body.KVTable getKVListByNamespace(String namespace) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException
MQAdminExtgetKVListByNamespace 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionpublic void updateBrokerConfig(String brokerAddr, Properties properties) throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, UnsupportedEncodingException, InterruptedException, MQBrokerException
MQAdminExtupdateBrokerConfig 在接口中 MQAdminExtcom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptionUnsupportedEncodingExceptionInterruptedExceptionMQBrokerExceptionCopyright © 2012–2013. All rights reserved.