生产消费消息
更新时间：2024-01-04 08:19:58
本小节主要介绍如何在命令行模式下通过 RocketMQ 生产消费消息。
RocketMQ 4.7.1 - v1.1.0
RocketMQ 4.7.1 - v1.1.0 版本需要设置环境变量：
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64； export NAMESRV_ADDR=namesrv_node_ip:9876。
发送消息
$ /opt/rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer接收消息
$ /opt/rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.ConsumerßRocketMQ 4.3.1 - v1.0.0
RocketMQ 4.3.1 - v1.0.0 版本节点的环境变量已经内置了 Name Server 的地址列表。
如果在使用过程中，管理员对 Name Server 节点进行了调整（增删节点）：
-
可以退出重新登录以使环境变量生效。
-
或者通过命令重新加载环境变量：
source /etc/profile.d/rocketmq-path.sh。
发送消息
$ /opt/apache-rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer接收消息
$ /opt/apache-rocketmq/current/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer