rocketmq4.x快速入门指南

Posted 2020-12-27 peachyy

以下采用的是apache rocketmq 4.2.0版本 相关文档如下

• 快速体验： http://blog.seoui.com/2018/07/24/rocketmqinstall/
• rocketmq简单消息发送： http://blog.seoui.com/2018/07/24/rocketmq_simple_message/
• rocketmq有序消息： http://blog.seoui.com/2018/07/24/rocketmq_ordered_message/
• rocketmq广播消息： http://blog.seoui.com/2018/07/24/rocketmq_broadcast_message/
• rocketmq延时消息： http://blog.seoui.com/2018/08/01/rocketmq_delay_message/
• rocketmq批量消息： http://blog.seoui.com/2018/08/02/rocketmq_batch_message/

  下载源码并编译

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip   
unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.2.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

　　目录 distribution/target/apache-rocketmq 是编译后的产出 可复制这个目录安装MQ的机器上,这里复制到/usr/local/

  共享一份编译后的文件方便以后再次使用

https://pan.baidu.com/s/1ZyUOKFm-t8cJDQuH68QydQ

   启动NameServer

cd /usr/local/apache-rocketmq
nohup sh bin/mqnamesrv &

　　查看日志tail -f ~/logs/rocketmqlogs/namesrv.log 启动成功后打印The Name Server boot success…

   启动Broker

这里需要注意一下就是 如果当前机器上有多张网卡的情况,最好指定一个IP, 有可能消费端正好就和MQ选择的网卡不通

vim conf/broker.conf 指定IP 访问多网卡的情况 并配置好nameserver的地址 也可以使用mqbroker启动参数-n指定nameserver地址

brokerIP1=192.168.1.2
namesrvAddr=192.168.1.3:9876 

启动broker -c参数指定配置文件

nohup sh bin/mqbroker -c config/broker.properties &

　　查看一下集群列表

sh bin/mqadmin clusterList -n  localhost:9876

　　

发送/接收消息

Producer

export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

　　能发送表示OK

Consumer

 
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

　　能接收到之前发送的消息表示OK

  关闭MQ

 
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv