DefaultMQAdminExtImpl (rocketmq-tools 3.2.6 3.2.6 API)

概述

软件包

类

使用

树

已过时

索引

帮助

上一个类 下一个类

框架 无框架

摘要：嵌套 | 字段 | 构造方法 | 方法

详细信息：字段 | 构造方法 | 方法

com.alibaba.rocketmq.tools.admin
类 DefaultMQAdminExtImpl

java.lang.Object
  com.alibaba.rocketmq.tools.admin.DefaultMQAdminExtImpl

所有已实现的接口：: MQAdminExtInner, MQAdmin, MQAdminExt

public class DefaultMQAdminExtImpl
extends Object
implements MQAdminExt, MQAdminExtInner
extends Object
implements MQAdminExt, MQAdminExtInner

所有运维接口都在这里实现

从以下版本开始：: 2013-7-21
作者：: shijia.wxr

构造方法摘要
`DefaultMQAdminExtImpl(DefaultMQAdminExt defaultMQAdminExt)`
`DefaultMQAdminExtImpl(DefaultMQAdminExt defaultMQAdminExt, com.alibaba.rocketmq.remoting.RPCHook rpcHook)`

方法摘要
`boolean`	`cleanExpiredConsumerQueue(String cluster)` 触发清理失效的消费队列
`boolean`	`cleanExpiredConsumerQueueByAddr(String addr)` 触发指定的broker清理失效的消费队列
`boolean`	`cleanExpiredConsumerQueueByCluster(com.alibaba.rocketmq.common.protocol.body.ClusterInfo clusterInfo, String cluster)`
`void`	`cloneGroupOffset(String srcGroup, String destGroup, String topic, boolean isOffline)` 克隆某一个组的消费进度到新的组
`boolean`	`consumed(com.alibaba.rocketmq.common.message.MessageExt msg, String group)`
`com.alibaba.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult`	`consumeMessageDirectly(String consumerGroup, String clientId, String msgId)` 向指定Consumer发送某条消息
`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`	`createOrUpdateOrderConf(String key, String value, boolean isCluster)` 创建或更新顺序消息的分区配置
`void`	`createTopic(String key, String newTopic, int queueNum)`
`void`	`createTopic(String key, String newTopic, int queueNum, int topicSysFlag)`
`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.admin.ConsumeStats`	`examineConsumeStats(String consumerGroup, String topic)`
`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运行时数据
`com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo`	`getConsumerRunningInfo(String consumerGroup, String clientId, boolean jstack)` 查询Consumer内存数据结构
`Map<String,Map<com.alibaba.rocketmq.common.message.MessageQueue,Long>>`	`getConsumeStatus(String topic, String group, String clientAddr)` 通过客户端查看消费者的消费情况
`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)`
`List<MessageTrack>`	`messageTrackDetail(com.alibaba.rocketmq.common.message.MessageExt msg)` 查询消息被谁消费了
`long`	`minOffset(com.alibaba.rocketmq.common.message.MessageQueue mq)`
`void`	`putKVConfig(String namespace, String key, String value)` 向Name Server增加一个配置项
`Set<com.alibaba.rocketmq.common.protocol.body.QueueTimeSpan>`	`queryConsumeTimeSpan(String topic, String group)` 根据 topic 和 group 获取消息的时间跨度
`QueryResult`	`queryMessage(String topic, String key, int maxNum, long begin, long end)`
`com.alibaba.rocketmq.common.protocol.body.GroupList`	`queryTopicConsumeByWho(String topic)` 根据Topic查询被哪些订阅组消费
`Map<com.alibaba.rocketmq.common.message.MessageQueue,Long>`	`resetOffsetByTimestamp(String topic, String group, long timestamp, boolean isForce)` 按照时间回溯消费进度(客户端不需要重启)
`List<com.alibaba.rocketmq.common.admin.RollbackStats>`	`resetOffsetByTimestampOld(String consumerGroup, String topic, long timestamp, boolean force)` 按照时间回溯消费进度(客户端需要重启)
`void`	`resetOffsetNew(String consumerGroup, String topic, long timestamp)` 重置消费进度，无论Consumer是否在线，都可以执行。
`long`	`searchOffset(com.alibaba.rocketmq.common.message.MessageQueue mq, long timestamp)`
`void`	`shutdown()`
`void`	`start()`
`void`	`updateBrokerConfig(String brokerAddr, Properties properties)` 更新Broker配置
`com.alibaba.rocketmq.common.protocol.body.BrokerStatsData`	`ViewBrokerStatsData(String brokerAddr, String statsName, String statsKey)` 服务器统计数据输出
`com.alibaba.rocketmq.common.message.MessageExt`	`viewMessage(String msgId)`
`int`	`wipeWritePermOfBroker(String namesrvAddr, String brokerName)` 清除某个Broker的写权限，针对所有Name Server

从类 java.lang.Object 继承的方法
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

构造方法详细信息

DefaultMQAdminExtImpl

public DefaultMQAdminExtImpl(DefaultMQAdminExt defaultMQAdminExt)

DefaultMQAdminExtImpl

public DefaultMQAdminExtImpl(DefaultMQAdminExt defaultMQAdminExt,
                             com.alibaba.rocketmq.remoting.RPCHook rpcHook)

方法详细信息

start

public void start()
           throws MQClientException

指定者：: 接口 MQAdminExt 中的 start

抛出：: MQClientException

shutdown

public void shutdown()

指定者：: 接口 MQAdminExt 中的 shutdown

createAndUpdateTopicConfig

public void createAndUpdateTopicConfig(String addr,
                                       com.alibaba.rocketmq.common.TopicConfig config)
                                throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                       MQBrokerException,
                                       InterruptedException,
                                       MQClientException

从接口 MQAdminExt 复制的描述

向指定Broker创建或者更新Topic配置

指定者：: 接口 MQAdminExt 中的 createAndUpdateTopicConfig

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

createAndUpdateSubscriptionGroupConfig

public void createAndUpdateSubscriptionGroupConfig(String addr,
                                                   com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig config)
                                            throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                   MQBrokerException,
                                                   InterruptedException,
                                                   MQClientException

从接口 MQAdminExt 复制的描述

向指定Broker创建或者更新订阅组配置

指定者：: 接口 MQAdminExt 中的 createAndUpdateSubscriptionGroupConfig

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

examineSubscriptionGroupConfig

public com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr,
                                                                                                       String group)

从接口 MQAdminExt 复制的描述

查询指定Broker的订阅组配置

指定者：: 接口 MQAdminExt 中的 examineSubscriptionGroupConfig

返回：

examineTopicConfig

public com.alibaba.rocketmq.common.TopicConfig examineTopicConfig(String addr,
                                                                  String topic)

从接口 MQAdminExt 复制的描述

查询指定Broker的Topic配置

指定者：: 接口 MQAdminExt 中的 examineTopicConfig

返回：

examineTopicStats

public com.alibaba.rocketmq.common.admin.TopicStatsTable examineTopicStats(String topic)
                                                                    throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                           MQClientException,
                                                                           InterruptedException,
                                                                           MQBrokerException

从接口 MQAdminExt 复制的描述

查询Topic Offset信息

指定者：: 接口 MQAdminExt 中的 examineTopicStats

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

examineConsumeStats

public com.alibaba.rocketmq.common.admin.ConsumeStats examineConsumeStats(String consumerGroup,
                                                                          String topic)
                                                                   throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                          MQClientException,
                                                                          InterruptedException,
                                                                          MQBrokerException

指定者：: 接口 MQAdminExt 中的 examineConsumeStats

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

examineConsumeStats

public com.alibaba.rocketmq.common.admin.ConsumeStats examineConsumeStats(String consumerGroup)
                                                                   throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                          MQClientException,
                                                                          InterruptedException,
                                                                          MQBrokerException

从接口 MQAdminExt 复制的描述

查询消费进度

指定者：: 接口 MQAdminExt 中的 examineConsumeStats

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

examineBrokerClusterInfo

public com.alibaba.rocketmq.common.protocol.body.ClusterInfo examineBrokerClusterInfo()
                                                                               throws InterruptedException,
                                                                                      MQBrokerException,
                                                                                      com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
                                                                                      com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
                                                                                      com.alibaba.rocketmq.remoting.exception.RemotingConnectException

从接口 MQAdminExt 复制的描述

查看集群信息

指定者：: 接口 MQAdminExt 中的 examineBrokerClusterInfo

返回：
抛出：: InterruptedException; MQBrokerException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingConnectException

examineTopicRouteInfo

public com.alibaba.rocketmq.common.protocol.route.TopicRouteData examineTopicRouteInfo(String topic)
                                                                                throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                       MQClientException,
                                                                                       InterruptedException

从接口 MQAdminExt 复制的描述

查看Topic路由信息

指定者：: 接口 MQAdminExt 中的 examineTopicRouteInfo

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException

putKVConfig

public void putKVConfig(String namespace,
                        String key,
                        String value)

从接口 MQAdminExt 复制的描述

向Name Server增加一个配置项

指定者：: 接口 MQAdminExt 中的 putKVConfig

getKVConfig

public String getKVConfig(String namespace,
                          String key)
                   throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                          MQClientException,
                          InterruptedException

从接口 MQAdminExt 复制的描述

从Name Server获取一个配置项

指定者：: 接口 MQAdminExt 中的 getKVConfig

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException

createTopic

public void createTopic(String key,
                        String newTopic,
                        int queueNum)
                 throws MQClientException

指定者：: 接口 MQAdmin 中的 createTopic

抛出：: MQClientException

createTopic

public void createTopic(String key,
                        String newTopic,
                        int queueNum,
                        int topicSysFlag)
                 throws MQClientException

指定者：: 接口 MQAdmin 中的 createTopic

抛出：: MQClientException

searchOffset

public long searchOffset(com.alibaba.rocketmq.common.message.MessageQueue mq,
                         long timestamp)
                  throws MQClientException

指定者：: 接口 MQAdmin 中的 searchOffset

抛出：: MQClientException

maxOffset

public long maxOffset(com.alibaba.rocketmq.common.message.MessageQueue mq)
               throws MQClientException

指定者：: 接口 MQAdmin 中的 maxOffset

抛出：: MQClientException

minOffset

public long minOffset(com.alibaba.rocketmq.common.message.MessageQueue mq)
               throws MQClientException

指定者：: 接口 MQAdmin 中的 minOffset

抛出：: MQClientException

earliestMsgStoreTime

public long earliestMsgStoreTime(com.alibaba.rocketmq.common.message.MessageQueue mq)
                          throws MQClientException

指定者：: 接口 MQAdmin 中的 earliestMsgStoreTime

抛出：: MQClientException

viewMessage

public com.alibaba.rocketmq.common.message.MessageExt viewMessage(String msgId)
                                                           throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                  MQBrokerException,
                                                                  InterruptedException,
                                                                  MQClientException

指定者：: 接口 MQAdmin 中的 viewMessage

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

queryMessage

public QueryResult queryMessage(String topic,
                                String key,
                                int maxNum,
                                long begin,
                                long end)
                         throws MQClientException,
                                InterruptedException

指定者：: 接口 MQAdmin 中的 queryMessage

抛出：: MQClientException; InterruptedException

examineConsumerConnectionInfo

public com.alibaba.rocketmq.common.protocol.body.ConsumerConnection examineConsumerConnectionInfo(String consumerGroup)
                                                                                           throws InterruptedException,
                                                                                                  MQBrokerException,
                                                                                                  com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                                  MQClientException

从接口 MQAdminExt 复制的描述

查看Consumer网络连接、订阅关系

指定者：: 接口 MQAdminExt 中的 examineConsumerConnectionInfo

返回：
抛出：: InterruptedException; MQBrokerException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException

examineProducerConnectionInfo

public com.alibaba.rocketmq.common.protocol.body.ProducerConnection examineProducerConnectionInfo(String producerGroup,
                                                                                                  String topic)
                                                                                           throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                                  MQClientException,
                                                                                                  InterruptedException,
                                                                                                  MQBrokerException

从接口 MQAdminExt 复制的描述

查看Producer网络连接

指定者：: 接口 MQAdminExt 中的 examineProducerConnectionInfo

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

wipeWritePermOfBroker

public 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

从接口 MQAdminExt 复制的描述

清除某个Broker的写权限，针对所有Name Server

指定者：: 接口 MQAdminExt 中的 wipeWritePermOfBroker

返回：: 返回清除了多少个topic
抛出：: 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

getNameServerAddressList

public List<String> getNameServerAddressList()

从接口 MQAdminExt 复制的描述

获取Name Server地址列表

指定者：: 接口 MQAdminExt 中的 getNameServerAddressList

返回：

fetchAllTopicList

public com.alibaba.rocketmq.common.protocol.body.TopicList fetchAllTopicList()
                                                                      throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                             MQClientException,
                                                                             InterruptedException

从接口 MQAdminExt 复制的描述

从Name Server获取所有Topic列表

指定者：: 接口 MQAdminExt 中的 fetchAllTopicList

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException

fetchBrokerRuntimeStats

public 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

从接口 MQAdminExt 复制的描述

获取Broker运行时数据

指定者：: 接口 MQAdminExt 中的 fetchBrokerRuntimeStats

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; InterruptedException; MQBrokerException

deleteTopicInBroker

public void deleteTopicInBroker(Set<String> addrs,
                                String topic)
                         throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                MQBrokerException,
                                InterruptedException,
                                MQClientException

从接口 MQAdminExt 复制的描述

删除 broker 上的 topic 信息

指定者：: 接口 MQAdminExt 中的 deleteTopicInBroker

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

deleteTopicInNameServer

public void deleteTopicInNameServer(Set<String> addrs,
                                    String topic)
                             throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException

从接口 MQAdminExt 复制的描述

删除 broker 上的 topic 信息

指定者：: 接口 MQAdminExt 中的 deleteTopicInNameServer

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

deleteSubscriptionGroup

public void deleteSubscriptionGroup(String addr,
                                    String groupName)
                             throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException

从接口 MQAdminExt 复制的描述

删除 broker 上的 subscription group 信息

指定者：: 接口 MQAdminExt 中的 deleteSubscriptionGroup

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

createAndUpdateKvConfig

public void createAndUpdateKvConfig(String namespace,
                                    String key,
                                    String value)
                             throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException

从接口 MQAdminExt 复制的描述

在 namespace 上添加或者更新 KV 配置

指定者：: 接口 MQAdminExt 中的 createAndUpdateKvConfig

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

deleteKvConfig

public void deleteKvConfig(String namespace,
                           String key)
                    throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                           MQBrokerException,
                           InterruptedException,
                           MQClientException

从接口 MQAdminExt 复制的描述

删除 namespace 上的 KV 配置

指定者：: 接口 MQAdminExt 中的 deleteKvConfig

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

getProjectGroupByIp

public String getProjectGroupByIp(String ip)
                           throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                  MQBrokerException,
                                  InterruptedException,
                                  MQClientException

从接口 MQAdminExt 复制的描述

通过 server ip 获取 project 信息

指定者：: 接口 MQAdminExt 中的 getProjectGroupByIp

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

getIpsByProjectGroup

public String getIpsByProjectGroup(String projectGroup)
                            throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                   MQBrokerException,
                                   InterruptedException,
                                   MQClientException

从接口 MQAdminExt 复制的描述

通过 project 获取所有的 server ip 信息

指定者：: 接口 MQAdminExt 中的 getIpsByProjectGroup

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

deleteIpsByProjectGroup

public void deleteIpsByProjectGroup(String projectGroup)
                             throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException

从接口 MQAdminExt 复制的描述

删除 project group 对应的所有 server ip

指定者：: 接口 MQAdminExt 中的 deleteIpsByProjectGroup

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

resetOffsetByTimestampOld

public List<com.alibaba.rocketmq.common.admin.RollbackStats> resetOffsetByTimestampOld(String consumerGroup,
                                                                                       String topic,
                                                                                       long timestamp,
                                                                                       boolean force)
                                                                                throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                       MQBrokerException,
                                                                                       InterruptedException,
                                                                                       MQClientException

从接口 MQAdminExt 复制的描述

按照时间回溯消费进度(客户端需要重启)

指定者：: 接口 MQAdminExt 中的 resetOffsetByTimestampOld

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

getKVListByNamespace

public com.alibaba.rocketmq.common.protocol.body.KVTable getKVListByNamespace(String namespace)
                                                                       throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                              MQClientException,
                                                                              InterruptedException

从接口 MQAdminExt 复制的描述

获取指定Namespace下的所有kv

指定者：: 接口 MQAdminExt 中的 getKVListByNamespace

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException

updateBrokerConfig

public 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

从接口 MQAdminExt 复制的描述

更新Broker配置

指定者：: 接口 MQAdminExt 中的 updateBrokerConfig

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; UnsupportedEncodingException; InterruptedException; MQBrokerException

resetOffsetByTimestamp

public Map<com.alibaba.rocketmq.common.message.MessageQueue,Long> resetOffsetByTimestamp(String topic,
                                                                                         String group,
                                                                                         long timestamp,
                                                                                         boolean isForce)
                                                                                  throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                         MQBrokerException,
                                                                                         InterruptedException,
                                                                                         MQClientException

从接口 MQAdminExt 复制的描述

按照时间回溯消费进度(客户端不需要重启)

指定者：: 接口 MQAdminExt 中的 resetOffsetByTimestamp

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

getConsumeStatus

public Map<String,Map<com.alibaba.rocketmq.common.message.MessageQueue,Long>> getConsumeStatus(String topic,
                                                                                               String group,
                                                                                               String clientAddr)
                                                                                        throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                               MQBrokerException,
                                                                                               InterruptedException,
                                                                                               MQClientException

从接口 MQAdminExt 复制的描述

通过客户端查看消费者的消费情况

指定者：: 接口 MQAdminExt 中的 getConsumeStatus

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

createOrUpdateOrderConf

public void createOrUpdateOrderConf(String key,
                                    String value,
                                    boolean isCluster)
                             throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                    MQBrokerException,
                                    InterruptedException,
                                    MQClientException

从接口 MQAdminExt 复制的描述

创建或更新顺序消息的分区配置

指定者：: 接口 MQAdminExt 中的 createOrUpdateOrderConf

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

queryTopicConsumeByWho

public com.alibaba.rocketmq.common.protocol.body.GroupList queryTopicConsumeByWho(String topic)
                                                                           throws InterruptedException,
                                                                                  MQBrokerException,
                                                                                  com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                  MQClientException

从接口 MQAdminExt 复制的描述

根据Topic查询被哪些订阅组消费

指定者：: 接口 MQAdminExt 中的 queryTopicConsumeByWho

返回：
抛出：: InterruptedException; MQBrokerException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException

queryConsumeTimeSpan

public Set<com.alibaba.rocketmq.common.protocol.body.QueueTimeSpan> queryConsumeTimeSpan(String topic,
                                                                                         String group)
                                                                                  throws InterruptedException,
                                                                                         MQBrokerException,
                                                                                         com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                         MQClientException

从接口 MQAdminExt 复制的描述

根据 topic 和 group 获取消息的时间跨度

指定者：: 接口 MQAdminExt 中的 queryConsumeTimeSpan

返回：
抛出：: InterruptedException; MQBrokerException; com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException

resetOffsetNew

public void resetOffsetNew(String consumerGroup,
                           String topic,
                           long timestamp)
                    throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                           MQBrokerException,
                           InterruptedException,
                           MQClientException

从接口 MQAdminExt 复制的描述

重置消费进度，无论Consumer是否在线，都可以执行。不保证最终结果是否成功，需要调用方通过消费进度查询来再次确认

指定者：: 接口 MQAdminExt 中的 resetOffsetNew

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQBrokerException; InterruptedException; MQClientException

cleanExpiredConsumerQueueByCluster

public boolean cleanExpiredConsumerQueueByCluster(com.alibaba.rocketmq.common.protocol.body.ClusterInfo clusterInfo,
                                                  String cluster)
                                           throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException,
                                                  com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
                                                  com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
                                                  MQClientException,
                                                  InterruptedException

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; MQClientException; InterruptedException

cleanExpiredConsumerQueue

public boolean cleanExpiredConsumerQueue(String cluster)
                                  throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException,
                                         com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
                                         com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
                                         MQClientException,
                                         InterruptedException

从接口 MQAdminExt 复制的描述

触发清理失效的消费队列

指定者：: 接口 MQAdminExt 中的 cleanExpiredConsumerQueue

参数：: cluster - null则表示所有集群
返回：: 清理是否成功
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; MQClientException; InterruptedException

cleanExpiredConsumerQueueByAddr

public boolean cleanExpiredConsumerQueueByAddr(String addr)
                                        throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException,
                                               com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
                                               com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
                                               MQClientException,
                                               InterruptedException

从接口 MQAdminExt 复制的描述

触发指定的broker清理失效的消费队列

指定者：: 接口 MQAdminExt 中的 cleanExpiredConsumerQueueByAddr

返回：: 清理是否成功
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; MQClientException; InterruptedException

getConsumerRunningInfo

public com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup,
                                                                                            String clientId,
                                                                                            boolean jstack)
                                                                                     throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                            MQClientException,
                                                                                            InterruptedException

从接口 MQAdminExt 复制的描述

查询Consumer内存数据结构

指定者：: 接口 MQAdminExt 中的 getConsumerRunningInfo

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException

consumeMessageDirectly

public com.alibaba.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup,
                                                                                                     String clientId,
                                                                                                     String msgId)
                                                                                              throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                                                                                     MQClientException,
                                                                                                     InterruptedException,
                                                                                                     MQBrokerException

从接口 MQAdminExt 复制的描述

向指定Consumer发送某条消息

指定者：: 接口 MQAdminExt 中的 consumeMessageDirectly

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

consumed

public boolean consumed(com.alibaba.rocketmq.common.message.MessageExt msg,
                        String group)
                 throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                        MQClientException,
                        InterruptedException,
                        MQBrokerException

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

messageTrackDetail

public List<MessageTrack> messageTrackDetail(com.alibaba.rocketmq.common.message.MessageExt msg)
                                      throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                                             MQClientException,
                                             InterruptedException,
                                             MQBrokerException

从接口 MQAdminExt 复制的描述

查询消息被谁消费了

指定者：: 接口 MQAdminExt 中的 messageTrackDetail

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

cloneGroupOffset

public void cloneGroupOffset(String srcGroup,
                             String destGroup,
                             String topic,
                             boolean isOffline)
                      throws com.alibaba.rocketmq.remoting.exception.RemotingException,
                             MQClientException,
                             InterruptedException,
                             MQBrokerException

从接口 MQAdminExt 复制的描述

克隆某一个组的消费进度到新的组

指定者：: 接口 MQAdminExt 中的 cloneGroupOffset

抛出：: com.alibaba.rocketmq.remoting.exception.RemotingException; MQClientException; InterruptedException; MQBrokerException

ViewBrokerStatsData

public com.alibaba.rocketmq.common.protocol.body.BrokerStatsData ViewBrokerStatsData(String brokerAddr,
                                                                                     String statsName,
                                                                                     String statsKey)
                                                                              throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException,
                                                                                     com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
                                                                                     com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
                                                                                     MQClientException,
                                                                                     InterruptedException

从接口 MQAdminExt 复制的描述

服务器统计数据输出

指定者：: 接口 MQAdminExt 中的 ViewBrokerStatsData

返回：
抛出：: com.alibaba.rocketmq.remoting.exception.RemotingConnectException; com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException; com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException; MQClientException; InterruptedException

概述

软件包

类

使用

树

已过时

索引

帮助

上一个类 下一个类

框架 无框架

摘要：嵌套 | 字段 | 构造方法 | 方法

详细信息：字段 | 构造方法 | 方法

com.alibaba.rocketmq.tools.admin 类 DefaultMQAdminExtImpl

DefaultMQAdminExtImpl

DefaultMQAdminExtImpl

start

shutdown

createAndUpdateTopicConfig

createAndUpdateSubscriptionGroupConfig

examineSubscriptionGroupConfig

examineTopicConfig

examineTopicStats

examineConsumeStats

examineConsumeStats

examineBrokerClusterInfo

examineTopicRouteInfo

putKVConfig

getKVConfig

createTopic

createTopic

searchOffset

maxOffset

minOffset

earliestMsgStoreTime

viewMessage

queryMessage

examineConsumerConnectionInfo

examineProducerConnectionInfo

wipeWritePermOfBroker

getNameServerAddressList

fetchAllTopicList

fetchBrokerRuntimeStats

deleteTopicInBroker

deleteTopicInNameServer

deleteSubscriptionGroup

createAndUpdateKvConfig

deleteKvConfig

getProjectGroupByIp

getIpsByProjectGroup

deleteIpsByProjectGroup

resetOffsetByTimestampOld

getKVListByNamespace

updateBrokerConfig

resetOffsetByTimestamp

getConsumeStatus

createOrUpdateOrderConf

queryTopicConsumeByWho

queryConsumeTimeSpan

resetOffsetNew

cleanExpiredConsumerQueueByCluster

cleanExpiredConsumerQueue

cleanExpiredConsumerQueueByAddr

getConsumerRunningInfo

consumeMessageDirectly

consumed

messageTrackDetail

cloneGroupOffset

ViewBrokerStatsData

com.alibaba.rocketmq.tools.admin
类 DefaultMQAdminExtImpl