安装使用RocketMQ一套保姆全教程-最快完成SpringBoot使用消息队列demo

简介

官方地址：https://rocketmq.apache.org/
github地址：https://github.com/apache/rocketmq
gitee地址：https://gitee.com/apache/rocketmq
我整这玩意儿，整了两天。可能自己比较笨，也不会详细看官方文档，就想最快实现demo。全部整完后怕自己以后忘了，复现，然后记录，方便以后自己再使用。
因为要最快完成，所以所有的步骤都采用最简单的方式实现，比如安装包直接就是下载的二进制包。

安装

下载安装包

wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip
1

解压安装包

unzip rocketmq-all-4.9.4-bin-release.zip
1

启动mqserver

cd ${Dir}/bin
sh mqnamesrv  //启动
nohup sh mqnamesrv &  //后台启动
1
2
3

启动成功后：

验证是否成功

再开一个ssh终端

lsof -i:9876
1

看看这个端口是不是在占用了，占用了一般就问题不大

启动mqbroker

一定要修改runbroker.sh文件中的内存大小。当然你是大户的话，让我没说。

如果你的Springboot程序和rocket在一个主机上那么就用默认的启动方式，不然你就需要配置一下broker，不然你的程序找不到broker地址
默认启动方式：

nohup sh bin/mqbroker -n localhost:9876 &
1

自定义broker的方式

配置broker配置

使用情况：你的程序和你的rocket不在一个主机上。你需要吧brokerIp改成你可以访问到的地址，不能跟我写的一模一样！

cd ${Dir}/conf
1

编辑broker.conf

nano broker.conf
1

默认是这样的

自行修改
加上

#设置名称服务地址
namesrvAddr=localhost:9876
#设置brokerIP地址
brokerIP1= localhost
#关闭自动创建主题
autoCreateTopicEnable=true
#关闭自动创建订阅组
autoCreateSubscriptionGroup=true
1
2
3
4
5
6
7
8

执行命令，使用自定义的配置文件

sh mqbroker -c ../conf/broker.conf
1

验证broker是不是启动成功

tail -f ~/logs/rocketmqlogs/broker.log
1

看到这个页面显示成功

安装rocketMQ的可视化控制台

为了求最快开发，所以可视化的dashboard用docker实现。

docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest
1

访问8080端口，就可以看到界面了

注意:这里有个注意点，我这里docker的ip应该写为公网ip，如果想用localhost的情况下，docker命令需要配置和注意一个网络，具体命令自行查阅。
如果你之前的broker也正常启动了，那么这里应该显示：

使用rocketMQ

mqadmin使用

mqadmin是在安装包bin目录下的，官方提供的命令行的执行工具。
官方连接：https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md

SpringBoot集成mq

官方教程：https://github.com/apache/rocketmq-spring/wiki/%E7%94%A8%E6%88%B7%E6%89%8B%E5%86%8C
这个没什么难的，直接人家官方代码拉下来换个mqserver地址就ok。