java查看rocketmq的所有队列名
时间: 2023-07-06 22:39:08 浏览: 119
你可以使用 Apache RocketMQ 的 Admin API 来查看 RocketMQ 的所有队列名。下面是一个示例代码:
```java
import org.apache.rocketmq.common.admin.TopicStatsTable;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
public class ListRocketMQQueues {
public static void main(String[] args) throws Exception {
DefaultMQAdminExt admin = new DefaultMQAdminExt();
admin.start();
TopicStatsTable topicStatsTable = admin.examineTopicStats("TopicName");
for (String queueName : topicStatsTable.getOffsetTable().keySet()) {
System.out.println("Queue name: " + queueName);
}
admin.shutdown();
}
}
```
这段代码会连接到 RocketMQ 服务器,通过 `examineTopicStats()` 方法获取某个 Topic 的统计信息,然后遍历输出该 Topic 的所有队列名。
阅读全文