在linux上安装RocketMQ
一、上传安装包
本文的演示的操作系统是ubuntu20.4,centos大同小异,远程连接工具xshell、xftp。在安装rocketmq之前,必须安装jdk,可以参考我的文章进行jdk的安装
安装包下载:百度网盘地址
提取码:n4gs
使用xftp将安装包上传到/opt/software目录下
二、解压安装包
使用unzip命令将安装包解压到/opt/module目录下
unzip -d /opt/module/ rocketmq-all-4.4.0-bin-release.zip
查看
使用mv命令将rocketmq-all-4.4.0-bin-release文件夹改名为rocketmq-4.4.0
mv rocketmq-all-4.4.0-bin-release/ /opt/module/rocketmq-4.4.0
查看
三、配置环境变量
使用vim命令编辑/etc/profile
#ROCKETMQ_HOME
ROCKETMQ_HOME=/opt/module/rocketmq-4.4.0
PATH=$PATH:$ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH
export NAMESRV_ADDR=公网ip:9876
保存并退出,使用source命令生效配置
source /etc/profile
四、修改配置
修改启动脚本JVM参数
修改namesrv启动脚本内存参数
vim /opt/module/rocketmq-4.4.0/bin/runserver.sh
可以看到原本要求的内存还是挺大的
这个根据实际情况而定,如果服务器的内存很大则不用担心,如果服务器是学生机,那么还是修改一下吧!根据之前的比例就行,笔者配置如下
修改broker启动脚本内存参数
vim /opt/module/rocketmq-4.4.0/bin/runbroker.sh
同样地根据实际情况而定,笔者配置如下
五、启动服务与测试
启动nameserver
进入rocketmq安装目录下
cd /opt/module/rocketmq-4.4.0/
后台启动namserver
nohup sh bin/mqnamesrv &
查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
大概看到这样就是启动成功了
启动broker
后台启动broker
nohup sh bin/mqbroker -n localhost:9876 &
查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
能够看到这样就证明你启动成功了
查看后台进程
jps
如果broker和nameserver启动不了,就去调整内存参数吧!调小一点就好了。
发送消息
这个时候需要开两个窗口(一个发送消息,一个收取消息)
发送消息执行(提供者)
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
可以看到发送了很多条消息
收取消息执行(消费者)
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
关闭nameserver
sh bin/mqshutdown namesrv
关闭Broker
sh bin/mqshutdown broker
六、单节点远程配置
需要打开端口10911、10909、9876
,避坑
基本配置
vim conf/broker.conf
添加如下配置
namesrvAddr = 公网ip:9876
brokerIP1 = 公网ip
启动脚本编写
vim start.sh
添加内容
echo "启动nameserer"
nohup sh bin/mqnamesrv &
sleep 5
echo "启动broker"
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
赋予执行权限
chmod +x start.sh
关闭脚本编写
vim stop.sh
添加内容
echo "关闭nameserver"
sh bin/mqshutdown namesrv
sleep 3
echo "关闭broker"
sh bin/mqshutdown broke
赋予执行权限
chmod +x stop.sh