访问RocketMQ集群

更新时间：2025-01-03

快速入门流程

命令行工具部署所在网络环境需要能访问待访问的RocketMQ集群，可以通过如下方式验证，下图所示表示网络连通：

12.27.png

其中集群接入点需要在集群详情中的访问配置下访问地址查看。

请选择JDK 1.8及以上版本进行下载和安装，以下以JDK 21版本为例。下载对应环境的JDK 21安装包并上传到测试环境上，解压到/opt目录：

tar -zxf jdk-21_linux-x64_bin.tar.gz -C /opt/

解压后目录结构如下所示：

12.27c.png

将解压后的JDK目录写入环境变量并使生效：

echo 'export JAVA_HOME=/opt/jdk-21.0.5' >> ~/.bashrc
echo 'export PATH=$JAVA_HOME/bin:$PATH' >> ~/.bashrc
source ~/.bashrc

命令执行完成之后，执行如下命令得到所示的输出可以确定JDK是否正常安装：

java -version

RocketMQ服务版本向下兼容，请选择与集群大版本兼容的工具版本进行测试。下载安装包后，将安装包上传到RocketMQ集群所在的同一VPC网络环境下并进行解压。以下示例将访问RocketMQ 4.9.8版本集群，因此将下载和安装4.9.8版本的发布包。

解压之后，将解压路径设置为ROCKETMQ_HOME环境变量：

echo 'ROCKETMQ_HOME=/root/rocketmq-all-4.9.8-bin-release/' >> ~/.bashrc
echo 'PATH=$ROCKETMQ_HOME/bin:$PATH' >> ~/.bashrc
source ~/.bashrc

mqadmin

假设已经创建了用于测试的主题example-topic和用于测试的消费组example-group，并且主题和消费组都有响应的读写权限。

mqadmin sendMessage --namesrvAddr <RocketMQ接入点> --topic <主题名> --body <消息内容>

生产成功后客户端会输出消息写入的节点名、队列ID、发送结果以及消息ID，如下所示：

image (2).png

生产成功后客户端会输出消息写入的节点名、队列ID、发送结果以及消息ID，如下所示：

image (3).png

mqadmin consumeMessage --namesrvAddr <RocketMQ接入点> --topic <主题名> --consumerGroup <消费组名>

消费成功后，客户端会输出每个队列消费到的消息信息，如下所示：

image (4).png

输入consumeMessage命令不带任何参数可以查看consumeMessage命令的更多参数配置：

image (5).png