一、 官方下载地址

1. rocketmq

https://rocketmq.apache.org/download

选择
在这里插入图片描述

2. dashboard(控制台)

https://github.com/apache/rocketmq-dashboard/tags

二、安装

1. 安装jdk

我这里用的是jdk-8u431-linux-x64,把文件上传到root

cd /etc
tar -xvf jdk-8u431-linux-x64.tar.gz
vi /etc/profile
export JAVA_HOME=/etc/jdk1.8.0_431
export PATH=$JAVA_HOME/bin:$PATH

export LC_ALL=zh_CN.utf8
export LANG=zh_CN.utf8
source /etc/profile
java -version

显示jdk版本后,安装成功

2. 安装rocketmq

mkdir /etc/rocketmq

将下载的二进制文件上传到root目录

```bash
sudo yum update -y
sudo yum install unzip -y
cd /etc/rocketmq
unzip ~/rocketmq-all-5.3.1-bin-release.zip

修改内存(如果安装的服务器是8G内存)和jdk配置

sed -i "s|${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m|${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m|g" /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/runserver.sh
sed -i "s|JAVA_HOME=\$HOME/jdk/java|JAVA_HOME=/etc/jdk1.8.0_431|g" /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/runserver.sh
sed -i "s|${JAVA_OPT} -server -Xms8g -Xmx8g|${JAVA_OPT} -server -Xms4g -Xmx4g|g" /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/runbroker.sh
sed -i "s|JAVA_HOME=\$HOME/jdk/java|JAVA_HOME=/etc/jdk1.8.0_431|g" /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/runbroker.sh

创建systemctl nameServer启动脚本

vi /etc/systemd/system/runserver.service
[Unit]
Description=runserver
After=network-online.target syslog.target

[Service]
User=root

ExecStart=/etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/mqnamesrv
ExecStop=/etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/mqshutdown namesrv
Restart=always
LimitNOFILE=65536
TasksMax=infinity
TimeoutStopSec=infinity
SendSIGKILL=no

[Install]
WantedBy=multi-user.target
vi /etc/systemd/system/runbroker.service
[Unit]
Description=runbroker
After=network-online.target syslog.target runserver

[Service]
User=root

ExecStart=/etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/mqbroker -n localhost:9876 --enable-proxy
ExecStop=/etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/mqshutdown broker
Restart=always
LimitNOFILE=65536
TasksMax=infinity
TimeoutStopSec=infinity
SendSIGKILL=no

[Install]
WantedBy=multi-user.target
systemctl daemon-reload
systemctl enable runserver runbroker
systemctl start runserver runbroker

测试发送

 export NAMESRV_ADDR=localhost:9876
 sh /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

测试消费

sh /etc/rocketmq/rocketmq-all-5.3.1-bin-release/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

这里需要注意下,消费完毕不会自动退出,自己手动退一下

3. 安装rocketmq-dashboard

  1. docker安装
docker run -d --name rocketmq-admin -p 8080:8080 -e NAMESRV_ADDR=192.168.101.101:9876 apache/rocketmq-dashboard
  1. jar包
    将文件夹全部上传到opt下面,设置权限
chmod +x core.jar
vi /etc/systemd/system/rocketmq-admin.service
[Unit]
Description=rocketmq-admin
After=syslog.target runserver runbroker

[Service]
User=root 
ExecStart=/opt/rocketmq-dashboard/core.jar
SuccessExitStatus=143 

[Install]
WantedBy=multi-user.target 
systemctl daemon-reload
systemctl enable rocketmq-admin
systemctl start rocketmq-admin
Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐