标签：otto consumer 1.2 quick none 消费 href shutdown exp
以下采用的是apache rocketmq 4.2.0版本 相关文档如下
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
cd /usr/local/apache-rocketmq nohup sh bin/mqnamesrv &
查看日志tail -f ~/logs/rocketmqlogs/namesrv.log 启动成功后打印The Name Server boot success…
这里需要注意一下就是 如果当前机器上有多张网卡的情况,最好指定一个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
sh bin/mqshutdown broker sh bin/mqshutdown namesrv
标签：otto consumer 1.2 quick none 消费 href shutdown exp
原文地址：https://www.cnblogs.com/peachyy/p/9406526.html
