前言

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

筹备工作

  • 装置 64bit JDK 1.8+
  • 参考 装置 Maven 3.2.x+
  • Linux 工夫同步
yum install ntpdate -yntpdate time.windows.com

部署步骤

下载 / 编译

  • 从 GitHub 下载 后编译(也能够从 Apache RocketMQ - releases 下载,或者走前面一步间接下载编译后的包)
echo "先创立独自目录" > /dev/nullmkdir -p ~/soft/rocketmqecho "从 GitHub 下载源码" > /dev/nullwget -P ~/soft/rocketmq https://github.com/apache/rocketmq/archive/refs/tags/rocketmq-all-4.9.1.tar.gzecho "解压到指定目录" > /dev/nulltar -xf ~/soft/rocketmq/rocketmq-all-4.9.1.tar.gz -C ~/soft/rocketmqecho "进入解压目录" > /dev/nullcd ~/soft/rocketmq/rocketmq-rocketmq-all-4.9.1echo "编译" > /dev/nullmvn -Prelease-all -DskipTests clean install -U -f ~/soft/rocketmq/rocketmq-rocketmq-all-4.9.1echo "拷贝编译后的目录到/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/nullwget -P ~/soft/rocketmq https://dlcdn.apache.org/rocketmq/4.9.1/rocketmq-all-4.9.1-bin-release.zipecho "解压" > /dev/nullunzip ~/test/rocketmq/rocketmq-all-4.9.1-bin-release.zip -d /opt/soft/echo "批改目录名" > /dev/nullmv /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 Servernohup sh /opt/soft/rocketmq-4.9.1/bin/mqnamesrv &# 后盾启动 Brokernohup sh /opt/soft/rocketmq-4.9.1/bin/mqnamesrv -n localhost:9876 &

进行

# 进行 Brokersh /opt/soft/rocketmq-4.9.1/bin/mqshutdown broker# 进行 Name Serversh /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 扩大我的项目