使用RocketMQ命令行工具

RocketMQ提供了一个命令行工具mqadmin，可以通过它来获取集群的状态信息。以下是一些常用命令的示例：

# 查看集群信息
./mqadmin clusterList -n localhost:9876

# 查看所有主题信息
./mqadmin topicList -n localhost:9876

# 查看Broker信息
./mqadmin brokerStatus -b localhost:10911 -n localhost:9876

# 查看消费者状态
./mqadmin consumerStatus -g groupName -n localhost:9876

使用JMX监控

RocketMQ支持JMX，你可以使用JConsole或者其他JMX客户端来连接到RocketMQ的JMX服务。以下是一个使用Java代码通过JMX获取RocketMQ信息的示例：

import javax.management.Attribute;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import java.util.Set;

public class RocketMQJMXMonitor {

    public static void main(String[] args) throws Exception {
        // JMX连接地址，RocketMQ默认的JMX端口是1099
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");
        JMXConnector jmxc = JMXConnectorFactory.connect(url, null);
        MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();

        // 查询所有RocketMQ相关的MBean
        Set<ObjectName> objectNames = mbsc.queryNames(new ObjectName("org.apache.rocketmq:*"), null);

        for (ObjectName objectName : objectNames) {
            System.out.println("ObjectName: " + objectName);

            // 获取MBean的所有属性
            Set<String> keys = mbsc.getMBeanInfo(objectName).getAttributes().stream()
                    .map(Attribute::getName)
                    .collect(Collectors.toSet());

            for (String key : keys) {
                Object value = mbsc.getAttribute(objectName, key);
                System.out.println("\t" + key + " = " + value);
            }
        }

        jmxc.close();
    }
}

运行上述Java程序，你需要确保RocketMQ的JMX服务已经启动，并且你的Java程序具有访问JMX服务的权限。

使用Prometheus和Grafana

如果你已经部署了Prometheus和Grafana，你可以使用RocketMQ的Exporter来收集数据。

首先，你需要运行RocketMQ Exporter，这可以通过以下命令启动：

java -jar rocketmq-exporter.jar

然后，配置Prometheus来抓取RocketMQ Exporter的数据，在Prometheus的配置文件中添加以下内容：

scrape_configs:
  - job_name: 'rocketmq'
    static_configs:
      - targets: ['localhost:5557'] # RocketMQ Exporter监听的端口

最后，在Grafana中添加Prometheus数据源，并创建相应的Dashboard来展示RocketMQ的监控数据。

以上代码和方法可以帮你监控RocketMQ集群的状态，但请根据你的实际环境（如RocketMQ版本、配置等）进行相应的调整。