如何查看 RocketMQ TPS 命令

一、介绍
RocketMQ 是阿里巴巴开源的一款分布式消息中间件，具有高性能、高可靠、高扩展性等特点。在实际应用中，我们经常需要了解 RocketMQ 的消息发送和消费速度，也就是 TPS（每秒事务处理量）。下面将介绍如何查看 RocketMQ 的 TPS 命令。

二、使用命令查看 TPS
RocketMQ 提供了一个命令行工具，可以帮助我们查看 RocketMQ 的 TPS。使用该工具需要连接 RocketMQ 的 Name Server。

1. 首先，打开终端或命令行窗口，进入 RocketMQ 的安装目录。

2. 执行以下命令，连接到 Name Server：

./mqadmin tools addr -n
Bash

例如：

./mqadmin tools addr -n 127.0.0.1:9876
Bash

3. 连接成功后，执行以下命令查看 TPS：

./mqadmin meter topmsg -t
Bash

例如：

./mqadmin meter topmsg -t myTopic
Bash

4. 执行以上命令后，会显示实时的 TPS 信息，包括消息发送和消费的 TPS。

三、使用代码查看 TPS
除了命令行方式，我们还可以通过代码来查看 RocketMQ 的 TPS。

1. 首先，确保 RocketMQ 的 Java SDK 已经引入到项目中。

2. 在代码中添加以下依赖：

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.consumer.ConsumeStatus;
import org.apache.rocketmq.common.consumer.MessageSelector;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

public class ConsumerExample {
    public static void main(String[] args) throws Exception {
        // 创建一个 RocketMQ 的消费者实例
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
        // 指定 Name Server 地址
        consumer.setNamesrvAddr("127.0.0.1:9876");
        // 设置消费模式为集群模式
        consumer.setMessageModel(MessageModel.CLUSTERING);
        // 设置消费起始位置
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);

        // 订阅 Topic 和 Tag
        consumer.subscribe("myTopic", "*");

        // 注册消息监听器
        consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
            // 处理消息
            for (MessageExt msg : msgs) {
                System.out.println(new String(msg.getBody()));
            }
            return ConsumeStatus.CONSUME_SUCCESS;
        });

        // 启动消费者实例
        consumer.start();

        // 每秒打印一次消费速度
        while (true) {
            System.out.println("TPS: " + consumer.getDefaultMQPushConsumerImpl().getConsumeMessageService().getTps());
            Thread.sleep(1000);
        }
    }
}
Java

3. 替换 127.0.0.1:9876 为真实的 Name Server 地址，myToπc 为要消费的 Topic 名称。

4. 运行代码，会在控制台上输出实时的 TPS 信息。每秒钟打印一次消费速度。

通过以上两种方式，我们可以方便地查看 RocketMQ 的 TPS 信息，以便进行性能监控和调优。