RocketMQ—RocketMQ安装
在安装RocketMQ之前需要先安装Jdk,并配置JAVA_HOME环境变量。
在安装之前我们要先下载RocketMQ的安装包。
下载
到RocketMQ的官网https://rocketmq.apache.org/
选择Download。
本文使用4.9.2版本。
将下载页面拉到最后面,有一个Dashborad文件,也下载下来:
下载好的文件如下图:
source文件是源码文件,bin文件是打包后的文件。
打包Dashboard
Dashboard只提供了源码文件,解压后用IDEA打开,并打包。
安装RocketMQ
把下图两个文件上传到linux服务器。
上传到/root/rocketmq
文件夹下
解压zip包
unzip rocketmq-all-4.9.2-bin-release.zip
可以看到多出来一个目录
进入目录,查看文件如下:
配置环境变量
vi /etc/profile
添加如下内容:
export NAMESRV_ADDR=IP地址:9876
如果是本机,就写:
export NAMESRV_ADDR=IP地址:9876
刷新
source /etc/profile
修改nameServer的运行脚本
进入解压后的目录/rocketmq-4.9.2/bin
目录
找到mqnamesrv文件;
可以看到要跑runserver.sh文件
找到runserver.sh文件
因为我的服务器内存比较小,所以要调小这些配置。
修改broker的运行脚本
还是在bin目录,我们来看mqbroker文件。
可以看到他会跑runbroker.sh。
修改runbroker.sh文件。
修改成如下内容。
修改broker的配置脚本
来到解压后的目录/rocketmq-4.9.2/conf
目录。
找到broker.conf文件
添加如下内容:
namesrvAddr=localhost:9876
autoCreateTopicEnable=true
brokerIP1=broker所在机器的ip地址
添加参数解释
- namesrvAddr:nameSrv地址 可以写localhost因为nameSrv和broker在一个服务器
- autoCreateTopicEnable:自动创建主题,不然需要手动创建出来
- brokerIP1:broker需要一个ip,如果不指定,我们再本地无法连接使用;不能写localhost,因为注册到nameserver是
localhost
的话,生产者/消费者去nameserver找broker,找到的也是localhost。
启动
启动nameserver
进入bin目录。
nohup sh mqnamesrv > ../namesrv.log &
输出这个按回车。
可以看到启动成功了。
启动broker
进入bin目录。
指定配置文件启动broker。
nohup sh mqbroker -c ../conf/broker.conf > ../broker.log &
输出这个按回车。
启动dashboard
把dashboard的jar包也放到服务器上。
运行如下命令
nohup java -jar rocketmq-dashboard-1.0.0.jar --server.port=8081 --rocketmq.config.namesrvAddr=127.0.0.1:9876 > dashboard.log &
访问
在浏览器访问http://dashbrad的ip地址:8081
可以看到访问成功。至此,我们的rocketmq和dashboard就安装成功了。