Java小强个人技术博客站点    手机版
当前位置: 首页 >> 开源 >> CentOS7安装RocketMQ

CentOS7安装RocketMQ

22250 开源 | 2022-3-2

RocketMQ是阿里巴巴开源的分布式消息中间件。支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。它里面有几个区别于标准消息中件间的概念,如Group、Topic、Queue等。系统组成则由Producer、Consumer、Broker、NameServer等。

RocketMQ.jpg


官方网站

https://rocketmq.apache.org/docs/quick-start/ 


下载、解压、编译

wget https://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-source-release.zip
unzip rocketmq-all-4.9.2-source-release.zip
cd rocketmq-all-4.9.2/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/rocketmq-4.9.2/rocketmq-4.9.2



启动 Name Server

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log


启动 Broker

nohup sh bin/mqbroker -n 0.0.0.0:9876 &
tail -f ~/logs/rocketmqlogs/broker.log


可以使用如下命令进行启动

nohup sh bin/mqnamesrv > mqnamesrv.log 2>&1 &
nohup sh bin/mqbroker -n 0.0.0.0:9876 > mqbroker.log 2>&1 &



测试连接

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


停止服务

sh bin/mqshutdown namesrv
sh bin/mqshutdown broker


如果是本地或者虚拟机测试,则要修改内存配置,分别修改如下两个文件

runserver.shrunbroker.sh



客户端

https://github.com/apache/rocketmq-dashboard.git 

安装方式参考官网

启动客户端,指定本地端口和MQ端口

java -jar rocketmq-dashboard-2.0.0.jar --server.port=10003 --rocketmq.config.namesrvAddr=localhost:9876  > rocketmq-dashboard.log 2>&1 &


END

推荐您阅读更多有关于“ linux 客户端 CentOS RocketMQ mq dashboard ”的文章

上一篇:Jenkins将代码Build到Tomcat8 下一篇:Jenkins首次Build,配置Git,Maven,JDK,凭证管理

猜你喜欢

发表评论: