rocketmq4.x快速入门指南

Posted peachyy

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketmq4.x快速入门指南相关的知识,希望对你有一定的参考价值。

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

   启动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

  技术分享图片

 

以上是关于rocketmq4.x快速入门指南的主要内容,如果未能解决你的问题,请参考以下文章

RocketMQ4.X 集群

rocketMQ RocketMQ4.X生产者核心配置和核心知识

RocketMQ4.x安装部署

基于云基础设施快速部署 RocketMQ 5.0 集群

c#代码片段快速构建代码

mybatis快速入门