分布式消息服务ROCKETMQ版-使用客户端连接RocketMQ(关闭SSL):命令行模式连接实例

时间:2024-10-17 15:19:15

命令行模式连接实例

  1. 登录客户端所在服务器。
  2. 下载“rocketmq-tutorial”示例软件包。

    wget https://dms-demos.obs.cn-north-1.myhuaweicloud.com/rocketmq-tutorial.zip

  3. 解压“rocketmq-tutorial”。

    unzip rocketmq-tutorial.zip

  4. (可选)如果RocketMQ实例开启了ACL访问控制,执行mqadmin命令时,需要鉴权。

    切换到解压后的软件包目录下,在“conf/tools.yml”文件中,增加如下内容。
    accessKey:*******
    secretKey:*******

    accessKey和secretKey表示在控制台“用户管理”页面,创建的用户名和密钥,具体可参见创建用户

  5. 进入“rocketmq-tutorial/bin”目录。

    cd rocketmq-tutorial/bin

  6. 运行生产普通消息示例。

    sh mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq"

    参数说明如下:

    • 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
    • Topic名称:RocketMQ实例下创建的Topic名称。

    示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。

    sh mqadmin sendMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq"

    使用Ctrl+C命令退出。

  7. 运行消费普通消息示例。

    sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称}

    参数说明如下:

    • 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
    • Topic名称:RocketMQ实例下创建的Topic名称。

    示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。

    sh mqadmin consumeMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test

    如需停止消费使用Ctrl+C命令退出。

  8. 运行生产带消息轨迹的消息示例。

    sh mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" -m true

    参数说明如下:

    • 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
    • Topic名称:RocketMQ实例下创建的Topic名称。

    示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。

    sh mqadmin sendMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -p "hello rocketmq" -m true

    使用Ctrl+C命令退出。

  9. 运行消费消息示例,并发送消息轨迹。

    sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称} -m true

    参数说明如下:

    • 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
    • Topic名称:RocketMQ实例下创建的Topic名称。

    示例如下,其中“11.xxx.xxx.89:8200;11.xxx.xxx.144:8200”为RocketMQ实例的元数据公网连接地址,“topic-test”为Topic名称。

    sh mqadmin consumeMessage -n "11.xxx.xxx.89:8200;11.xxx.xxx.144:8200" -t topic-test -m true

    使用Ctrl+C命令退出。

support.huaweicloud.com/usermanual-hrm/hrm-ug-039.html