以下采用的是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
