0

消费者队列是在客户端分配的,代理对此一无所知。

那么我们如何监控哪个队列分配给哪个消费者客户端呢?

4

1 回答 1

1

虽然没有退出命令,但对于每个消费者组的每个消息队列,您可以使用提供的管理基础设施找到客户端。这是实现此目的的代码段:

private Map<MessageQueue, String> getClientConnection(DefaultMQAdminExt defaultMQAdminExt, String groupName){
    Map<MessageQueue, String> results = new HashMap<MessageQueue, String>();
    try{
        ConsumerConnection consumerConnection = defaultMQAdminExt.examineConsumerConnectionInfo(groupName);
        for (Connection connection : consumerConnection.getConnectionSet()){
            String clinetId = connection.getClientId();
            ConsumerRunningInfo consumerRunningInfo = defaultMQAdminExt.getConsumerRunningInfo(groupName, clinetId, false);
            for(MessageQueue messageQueue : consumerRunningInfo.getMqTable().keySet()){
                results.put(messageQueue, clinetId + " " + connection.getClientAddr());
            }
        }
    }catch (Exception e){

    }
    return results;
}

如果您还没有使用 RocketMQ-Console 项目,请尝试运行它:https ://github.com/rocketmq/rocketmq-console-ng

在 Consumer 选项卡中,点击“consumer detail”按钮,可以直观地看到消息队列分配结果如下: 消息队列分配结果

于 2017-02-08T10:11:10.373 回答