前言

 记录linux安装部署RocketMQ

SpringBoot集成RocketMQ三步骤快速跑通_springboot集成rocketmq-spring-boot-starter-CSDN博客

服务版本

linux-Centos8

jdk8 

rocketmq-all-5.3.1(稳定兼容jdk8-17)

rocketmq-dashboard-master.zip (RocketMQ控制台

RocketMQ官方文档:本地部署 RocketMQ | RocketMQ

rocketmq-dashboard-master源码下载:https://github.com/apache/rocketmq-dashboard

部署所需压缩包下载链接: https://pan.baidu.com/s/1PYCQP7cMIELNHGqezs_q7Q?pwd=5ani#list/path=%2F

RocketMQ配置

上传压缩包到指定路径-  上传文件安装FinalShell连接服务器将文件拖拽至对应目录即可


 

# 进入对应压缩包目录命令

cd /zero/server/

# 解压压缩包-到当前目录

tar -zxvf rocketmq-all-5.3.1-bin-release.zip 

#解压压缩包-到指定目录   参数-C 目录按需修改  系统已安装jdk跳过

tar -zxvf jdk-8u441-linux-x64.tar.gz -C /zero/server/jdk

#添加jdk环境变量  系统已安装jdk跳过 从标红的内容开始添加即可

vi /etc/profile

export JAVA_HOME=/zero/server/jdk/jdk1.8.0_441

export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH

路径改为自己rocketmq安装路径实现 mqnamesrv 的命令直接执行

export PATH=$PATH:/zero/server/rocketmq-all-5.3.1-bin-release/bin

#修改 /etc/profile 后,你需要重新加载该文件才能使更改生效。可以通过以下命令来重新加载

source /etc/profile
 

RocketMQ修改启动参数-复制添加即可    内存够大的可以不用操作直接启动  默认需要大于4个G

编辑    rocketmq-all-5.3.1-bin-release/bin/runserver.sh

vi /zero/server/rocketmq-all-5.3.1-bin-release/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"

 图解

编辑   rocketmq-all-5.3.1-bin-release/bin/runbroker.sh

vi /zero/server/rocketmq-all-5.3.1-bin-release/bin/runbroker.sh
 

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=256m"

如图 

编辑   rocketmq-all-5.3.1-bin-release/conf/broker.conf

vi /zero/server/rocketmq-all-5.3.1-bin-release/conf/broker.conf

#允许自动创建topic
autoCreateTopicEnable=true

namesrvAddr=localhost:9876

如图

RocketMQ启动命令

 #创建logs目录
mkdir /zero/server/rocketmq-all-5.3.1-bin-release/logs
#启动mqnamesrv
nohup mqnamesrv >/zero/server/rocketmq-all-5.3.1-bin-release/logs/mqnamesrv.log 2>&1 &
#启动mqbroker  
nohup mqbroker -n localhost:9876 >/zero/server/rocketmq-all-5.3.1-bin-release/logs/broker.log 2>&1 &
#关闭 namesrv
mqshutdown namesrv
#关闭 broker
mqshutdown broker
#查询服务 namesrv
ps -ef | grep namesrv
#查询服务  mqbroker
ps -ef | grep mqbroker

扩展

namesrv和mqbroker区别

组件 功能 默认端口号
NameServer 提供服务发现与路由信息 9876
Broker 存储消息并处理消息生产与消费 10911
  • namesrv 通过端口 9876 提供路由信息。
  • mqbroker 通过端口 10911 处理消息存储与转发。

RocketMQ-可视化控制台

官方文档:https://rocketmq.apache.org/zh/docs/deploymentOperations/04Dashboard/

操作一-解压

解压:rocketmq-dashboard-master.zip

操作二-按maven项目导入idea

操作三-修改application.yml配置

rocketmq:
  config:
    namesrvAddrs:
      #改为自己RocketMQ的ip:端口                
      - 192.168.80.128:9876

操作四 -编译打包

注意:编译有个安装包yarn-1.22.10.tar.gz下载失败就复制链接到浏览器手动下载放入对应maven仓库目录即可解决

例:repositoryLuo\com\github\eirslett\yarn\1.22.10\yarn-1.22.10.tar.gz

 操作五-启动项目

访问路径:http://localhost:8080/#/

 

Logo

永洪科技,致力于打造全球领先的数据技术厂商,具备从数据应用方案咨询、BI、AIGC智能分析、数字孪生、数据资产、数据治理、数据实施的端到端大数据价值服务能力。

更多推荐