关于java:在Linux部署RocketMQ完整过程

前言

本文讲述 RocketMQ 从源码编译到配置启动以及测试的残缺过程。

筹备工作

• 装置 64bit JDK 1.8+
• 参考 装置 Maven 3.2.x+
• Linux 工夫同步

yum install ntpdate -y
ntpdate time.windows.com

部署步骤

下载 / 编译

• 从 GitHub 下载 后编译（也能够从 Apache RocketMQ – releases 下载，或者走前面一步间接下载编译后的包）

echo "先创立独自目录" > /dev/null
mkdir -p ~/soft/rocketmq

echo "从 GitHub 下载源码" > /dev/null
wget -P ~/soft/rocketmq https://github.com/apache/rocketmq/archive/refs/tags/rocketmq-all-4.9.1.tar.gz

echo "解压到指定目录" > /dev/null
tar -xf ~/soft/rocketmq/rocketmq-all-4.9.1.tar.gz -C ~/soft/rocketmq

echo "进入解压目录" > /dev/null
cd ~/soft/rocketmq/rocketmq-rocketmq-all-4.9.1

echo "编译" > /dev/null
mvn -Prelease-all -DskipTests clean install -U -f ~/soft/rocketmq/rocketmq-rocketmq-all-4.9.1

echo "拷贝编译后的目录到/opt/soft"
cp -r ~/soft/rocketmq/rocketmq-rocketmq-all-4.9.1/distribution/target/rocketmq-4.9.1/rocketmq-4.9.1/ /opt/soft/

• 跳过源码编译，从 Apache 下载编译后的包

echo "从 Apache 下载编译后的包" > /dev/null
wget -P ~/soft/rocketmq https://dlcdn.apache.org/rocketmq/4.9.1/rocketmq-all-4.9.1-bin-release.zip

echo "解压" > /dev/null
unzip ~/test/rocketmq/rocketmq-all-4.9.1-bin-release.zip -d /opt/soft/

echo "批改目录名" > /dev/null
mv /opt/soft/rocketmq-all-4.9.1-bin-release/ /opt/soft/rocketmq-4.9.1

批改启动参数

启动脚本中设置的 JVM 内存参数很大，如果服务器内存不够的话能够按这一步调小一点。这里只是测试所以设置很小，生产环境能够默认或者更大一点。批改 Name Server 堆内存大小（比方 -Xms512m -Xmx512m -Xmn256m）。

vim /opt/soft/rocketmq-4.9.1/bin/runserver.sh 

批改 Broker 堆内存大小（比方 -Xms512m -Xmx512m）

vim /opt/soft/rocketmq-4.9.1/bin/runbroker.sh

批改 tools.sh 指定 Name Server 地址 export NAMESRV_ADDR=localhost:9876，设置堆内存大小 (比方 -Xms512m -Xmx512m）

vim /opt/soft/rocketmq-4.9.1/bin/tools.sh

启动 / 进行

启动

# 后盾形式启动 Name Server
nohup sh /opt/soft/rocketmq-4.9.1/bin/mqnamesrv &

# 后盾启动 Broker
nohup sh /opt/soft/rocketmq-4.9.1/bin/mqnamesrv -n localhost:9876 &

进行

# 进行 Broker
sh /opt/soft/rocketmq-4.9.1/bin/mqshutdown broker

# 进行 Name Server
sh /opt/soft/rocketmq-4.9.1/bin/mqshutdown namesrv

日志查看

# 查看 Name Server 日志
tail -f ~/logs/rocketmqlogs/namesrv.log

#查看 Broker 日志
tail -f ~/logs/rocketmqlogs/broker.log 

测试

测试发消息，最初 ctrl + c 完结。

sh /opt/soft/rocketmq-4.9.1/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

测试生产音讯，最初 ctrl + c 完结。

sh /opt/soft/rocketmq-4.9.1/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

参考

Apache RocketMQ

Apache RocketMQ – quick-start

GitHub – RocketMQ

GitHub – RocketMQ 中文文档

GitHub – rocketmq 扩大我的项目