分布式消息服务ROCKETMQ版-快速连接RocketMQ并生产消费消息:步骤四:连接RocketMQ实例生产和消费消息

时间:2024-11-20 17:14:42

步骤四:连接RocketMQ实例生产和消费消息

  1. 在E CS 环境中进入“rocketmq-tutorial/bin”目录。

    cd rocketmq-tutorial/bin

  2. 运行生产普通消息命令。

    命令示例如下:
    JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "10.xxx.xxx.89:8100;10.xxx.xxx.144:8100" -t Topic01 -p "hello rocketmq"
    • 10.xxx.xxx.89:8100;10.xxx.xxx.144:8100:表示RocketMQ实例的“连接地址”,即7中记录的连接地址。
    • Topic01:表示RocketMQ实例下创建的Topic名称,即4中创建的Topic名称。
    • hello rocketmq:表示生产消息的内容。

  3. 运行消费普通消息命令。

    命令示例如下:
    JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "10.xxx.xxx.89:8100;10.xxx.xxx.144:8100" -t Topic01

    如上图中BODY显示的内容即为消费消息的内容。

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

support.huaweicloud.com/qs-hrm/hrm-qs-001.html