4. 第3节 如何使用Java发送和消费消息
本教程将简单演示如何使用纯java client发送和消费消息。当前环境已经安装了一个1Namesrv + 1Broker的集群, 演示代码路径:
cd /data/demos
1. 下载java代码demo
git clone https://github.com/ApacheRocketMQ/01-java-demos.git cd 01-java-demos/
2. 打包,执行代码demo
如下图,找到当前实验环境的公网ip
替换mvn exec:java命令中的namesrv ip地址后,再执行命令, 可以看到正常生产和消费输出
mvn clean package mvn exec:java -Dexec.args="xxx.xxx.xxx.xxx:9876" -Dexec.mainClass="org.apache.rocketmqdemos.Startup" -Dexec.classpathScope=runtime
3. Demo代码说明
RocketMQ Java Client使用的套路分为三个步骤
步骤1: 创建生产者、消费者实例
步骤2: 设置实例属性或者参数
步骤3: 启动
比如消费代码如下
全部代码可以查看实验本地或者github