在linux上安装RocketMQ

• 一、上传安装包
• 二、解压安装包
• 三、配置环境变量
• 四、修改配置
• • 修改启动脚本JVM参数
  • • 修改namesrv启动脚本内存参数
    • 修改broker启动脚本内存参数
• 五、启动服务与测试
• • 启动nameserver
  • 启动broker
  • 发送消息
  • 关闭nameserver
  • 关闭Broker
• 六、单节点远程配置
• • 基本配置
  • 启动脚本编写
• 关闭脚本编写

一、上传安装包

本文的演示的操作系统是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