欢迎来到尧图网

客户服务 关于我们

您的位置：首页 > 新闻 > 国际 > Ubuntu 上安装和配置 Apache RocketMQ 4.7.1

Ubuntu 上安装和配置 Apache RocketMQ 4.7.1

2025/2/13 23:23:12 来源：https://blog.csdn.net/weixin_39285027/article/details/145594208  浏览:  次   关键词：Ubuntu 上安装和配置 Apache RocketMQ 4.7.1

在 Ubuntu 上安装和配置 Apache RocketMQ 4.7.1 需要以下步骤。RocketMQ 是一个分布式消息队列系统，通常需要安装 Namesrv（Name Server）和 Broker 组件。

1. 系统准备

更新系统和安装依赖

运行以下命令更新系统并安装必要的依赖项：

sudo apt update && sudo apt upgrade -y
sudo apt install -y openjdk-8-jdk wget unzip

RocketMQ 4.7.1 要求 JDK 1.8，确保安装正确版本的 Java：

java -version
# 确保输出显示 Java 8

2. 下载 RocketMQ 4.7.1

从 Apache 官方下载 RocketMQ 4.7.1：

wget https://archive.apache.org/dist/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

解压文件：

unzip rocketmq-all-4.7.1-bin-release.zip
mv rocketmq-all-4.7.1-bin-release /opt/rocketmq

3. 配置环境变量

为 RocketMQ 添加环境变量，方便使用命令：

echo "export ROCKETMQ_HOME=/opt/rocketmq" >> ~/.bashrc
echo "export PATH=\$PATH:\$ROCKETMQ_HOME/bin" >> ~/.bashrc
source ~/.bashrc

验证配置：

echo $ROCKETMQ_HOME

4. 启动 Name Server

  1. 进入 RocketMQ 目录：

    cd /opt/rocketmq

  2. 启动 Name Server：

    sh bin/mqnamesrv > logs/namesrv.log 2>&1 &

  3. 检查 Name Server 是否启动成功：

    查看日志文件是否有启动成功的信息：

    tail -f logs/namesrv.log

    如果日志中包含 The Name Server boot success，说明 Name Server 启动成功。

5. 启动 Broker

  1. 启动 Broker：

    sh bin/mqbroker -n localhost:9876 > logs/broker.log 2>&1 &sh bin/mqbroker -n 18.142.120.189:9876 > logs/broker.log 2>&1 &

    注意：-n localhost:9876 表示使用本地的 Name Server 地址。

namesrvAddr=10.1.1.117:9876 
brokerIP1=10.1.1.117nohup /usr/local/rocketmq-5.0.0/bin/mqnamesrv & nohup /usr/local/rocketmq-5.0.0/bin/mqbroker -c /usr/local/rocketmq-5.0.0/conf/broker.conf &nohup sh bin/mqnamesrv > logs/namesrv.log 2>&1 &tail -f -n 20 logs/namesrv.lognohup sh bin/mqbroker -n 13.229.140.142:9876 autoCreateTopicEnable=true -c conf/broker.conf > logs/broker.log 2>&1 &nohup sh bin/mqbroker -n 13.229.140.142:9876 -c conf/broker.conf > logs/broker.log 2>&1 &nohup sh bin/mqbroker -n 127.0.0.1:9876 -c conf/broker.conf > logs/broker.log 2>&1 &nohup sh bin/mqbroker autoCreateTopicEnable=true -c conf/broker.conf > logs/broker.log 2>&1 &nohup sh bin/mqbroker -c conf/broker.conf > logs/broker.log 2>&1 &tail -f -n 20 logs/broker.lognohup sh bin/mqbroker -c conf/broker.conf &
tail -f -n 100 ~/logs/rocketmqlogs/broker.log 

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH

设置 Broker 的内网地址

brokerClusterName=DefaultCluster
brokerName=broker-a
brokerIP1=172.31.14.54

brokerIP2=13.229.140.142

autoCreateTopicEnable=truesudo sh bin/mqshutdown broker
sudo sh bin/mqshutdown namesrvps aux | grep rocketmqsudo netstat -anp | grep 9876
sudo nano /opt/rocketmq-all-4.9.6-bin-release/conf/broker.confsh bin/mqadmin brokerStatus -b 172.31.14.54:10911
sh bin/mqadmin clusterList -n 172.31.14.54:9876
sh bin/mqadmin brokerStatus -b 13.229.140.142:10911
sh bin/mqadmin clusterList -n 13.229.140.142:9876sudo nohup sh bin/mqnamesrv > /opt/rocketmq-all-4.9.6-bin-release/logs/namesrv.log 2>&1 &
tail -f -n 20 logs/namesrv.log
sudo nohup sh bin/mqbroker -n 172.31.14.54:9876 -c /opt/rocketmq-all-4.9.6-bin-release/conf/broker.conf > /opt/rocketmq-all-4.9.6-bin-release/logs/broker.log 2>&1 &
tail -f -n 20 logs/broker.lognohup sh bin/mqnamesrv > /home/rocketmq-all-4.7.1-bin-release/logs/namesrv.log 2>&1 &
tail -f -n 20 logs/namesrv.log
nohup sh bin/mqbroker -n 192.168.110.66:9876 -c /home/rocketmq-all-4.7.1-bin-release/conf/broker.conf > /home/rocketmq-all-4.7.1-bin-release/logs/broker.log 2>&1 &
tail -f -n 20 logs/broker.logsh bin/mqadmin brokerStatus -b 192.168.110.66:10911
sh bin/mqadmin clusterList -n 192.168.110.66:9876nohup sh bin/mqnamesrv -Djava.net.preferIPv4Stack=true > logs/namesrv.log 2>&1 &export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
export PATH=$JAVA_HOME/bin:$PATH

  1. 检查 Broker 是否启动成功：

    查看日志文件：

    tail -f logs/broker.log

    如果日志中包含 The broker[brokerName, brokerId] boot success，说明 Broker 启动成功。

6. 测试 RocketMQ

RocketMQ 自带了测试脚本，可以验证安装是否成功。

  1. 发送测试消息：

    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

  2. 接收测试消息：

    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

如果 Producer 和 Consumer 都能正常运行，说明 RocketMQ 已经安装成功。

7. 设置为系统服务（可选）

可以将 RocketMQ 的 Name Server 和 Broker 设置为系统服务，以便开机自启。

Name Server 服务配置

创建服务文件：

sudo nano /etc/systemd/system/rocketmq-namesrv.service

写入以下内容：

[Unit]
Description=RocketMQ Name Server
After=network.target[Service]
Type=forking
ExecStart=/opt/rocketmq/bin/mqnamesrv
ExecStop=/bin/kill -s TERM $MAINPID
User=root
Restart=always[Install]
WantedBy=multi-user.target
Broker 服务配置

创建服务文件：

sudo nano /etc/systemd/system/rocketmq-broker.service

写入以下内容：

[Unit]
Description=RocketMQ Broker
After=network.target rocketmq-namesrv.service[Service]
Type=forking
ExecStart=/opt/rocketmq/bin/mqbroker -n localhost:9876
ExecStop=/bin/kill -s TERM $MAINPID
User=root
Restart=always[Install]
WantedBy=multi-user.target
启动服务

启用并启动服务：

sudo systemctl daemon-reload
sudo systemctl enable rocketmq-namesrv
sudo systemctl enable rocketmq-brokersudo systemctl start rocketmq-namesrv
sudo systemctl start rocketmq-brokersudo systemctl stop rocketmq-namesrv
sudo systemctl stop rocketmq-broker

检查服务状态：

sudo systemctl status rocketmq-namesrv
sudo systemctl status rocketmq-broker

8. Web Console（可选）

如果需要可视化界面，可以安装 RocketMQ 的 Web Console。

下载 Web Console
git clone https://github.com/apache/rocketmq-externals.git
cd rocketmq-externals/rocketmq-console
启动 Web Console

编译并运行 Web Console（需要 Maven 和 JDK 1.8）：

mvn clean package -DskipTests
java -jar target/rocketmq-console-ng-2.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876

访问 http://<你的服务器IP>:8080 查看 RocketMQ 的状态。

RocketMQ 4.7.1 已成功在 Ubuntu 上安装并运行！

RocketMQ 4.7.1 运行在 Java 8 上最佳，因此如果你的系统上默认使用的是 Java 11，可能会导致兼容性问题。以下是解决方法：

方法一：降级到 Java 8

  1. 卸载 Java 11（如果需要）：

    sudo apt remove openjdk-11-jdk
sudo apt autoremove

  2. 安装 Java 8：

    sudo apt update
sudo apt install openjdk-8-jdk

  3. 验证 Java 版本：

    java -version

    确保显示类似以下内容：

    openjdk version "1.8.0_xxx"

方法二：使用 update-alternatives 切换默认版本

如果你同时安装了 Java 8 和 Java 11，可以通过 update-alternatives 命令选择 Java 8：

  1. 列出已安装的 Java 版本：

    sudo update-alternatives --config java

  2. 选择 Java 8：系统会列出所有可用的 Java 版本，你可以通过输入对应编号选择 Java 8。

  3. 再次验证：

    java -version

方法三：指定 Java 环境变量

如果不想改变系统默认 Java 版本，可以在 RocketMQ 的启动脚本中指定 Java 8 的路径：

  1. 查找 Java 8 安装路径：

    sudo update-alternatives --display java

    你会看到类似以下输出：

    /usr/lib/jvm/java-8-openjdk-amd64/bin/java

  2. 修改 runserver.sh 和 runbroker.sh 脚本：
    找到 RocketMQ 的安装目录，编辑启动脚本，在顶部添加以下行：

export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
export PATH=$JAVA_HOME/bin:$PATH
  1. 重新启动 RocketMQ：
   ./bin/mqnamesrv &./bin/mqbroker -n localhost:9876 &

方法四：使用 Docker

如果不想修改系统环境，可以使用官方提供的 Docker 镜像，它已经包含了合适的 Java 环境：

docker pull apache/rocketmq:4.7.1

运行 RocketMQ：

docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.7.1 sh mqnamesrv
docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv apache/rocketmq:4.7.1 sh mqbroker -n namesrv:9876

通过上述方法，你可以在 Ubuntu 上成功运行 RocketMQ 4.7.1。如果仍有问题，可以告诉我具体的报错信息，我会进一步帮助你！

cd /opt/rocketmq-all-4.7.1-bin-release167  ll168  cd bin/169  ll170  nohup sh bin/mqnamesrv &171  ps aux | grep java172  cd ..173  ll174  nohup sh bin/mqnamesrv &175  tail -f ~/logs/rocketmqlogs/namesrv.log176  nohup sh bin/mqbroker -n 192.168.0.57:9876 autoCreateTopicEnable=true -c conf/broker.conf &nohup sh bin/mqbroker -n 13.229.140.142:9876 autoCreateTopicEnable=true -c conf/broker.conf &177  tail -f -n 100 ~/logs/rocketmqlogs/broker.logsh bin/mqshutdown broker
sh bin/mqshutdown namesrv

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

相关资讯

热文排行

最新新闻

推荐新闻

热搜词

使用bucardo实现postgresql数据库双主同步 你是否想过，让AI像人类一样协作竞争?——展望智能体协作新范式 IEEE 802.3/802.2 | LLC / SNAP 【Elasticsearch】diversified sampler AJAX笔记进阶篇 ZZNUOJ(C/C++)基础练习1041——1050(详解版)