Java 生产环境 RocketMQ 架构与部署指南
目录
一、生产环境标准架构（必用）
1. 整体架构图（极简版）
2. 核心组件说明
二、生产环境推荐部署规格
最小高可用集群（最常用）
中型集群（业务量较大）
三、部署步骤（生产可直接照做）
环境准备
步骤 1：下载解压
步骤 2：修改 JVM 内存（非常重要）
步骤 3：配置 NameServer 集群（2 台）
步骤 4：配置 Broker 主从集群（核心）
机器规划
1）配置 broker1-master
2）配置 broker1-slave
3）broker2-master 和 broker2-slave
四、Java 生产环境客户端配置
生产者
消费者
五、生产环境关键配置（必看）
六、集群检查命令
七、高可用保障机制
总结
RocketMQ 是阿里开源的分布式消息队列，生产环境必须用分布式高可用架构，绝对不能单节点部署。本文会用最清晰、生产可直接落地的方式，给你讲透架构和部署步骤。
一、生产环境标准架构（必用）
生产环境核心目标：高可用、无单点故障、可水平扩容。
1. 整体架构图（极简版）
生产者集群 → NameServer 集群（2~3台） → Broker 主从集群 → 消费者集群2. 核心组件说明
NameServer（注册中心）
- 轻量级无状态服务，必须集群部署（2~3 台）
- 作用：Broker 注册、路由发现、心跳检测
- 无主从、无选举，随便挂一台不影响整体
Broker（消息存储核心）
- 真正负责消息收发、持久化、高可用
- 生产必须：主从架构（Master-Slave）
- 支持异步刷盘 + 异步复制（性能最高）
- 支持同步双写（金融级可靠性）
生产者 / 消费者
- 都是客户端集群，无状态，可随意扩容
- 通过 NameServer 自动发现 Broker
二、生产环境推荐部署规格
最小高可用集群（最常用）
- NameServer：2 台（2C4G）
- Broker：2 主 2 从（4 台，4C8G+SSD）
- broker1-master + broker1-slave
- broker2-master + broker2-slave
中型集群（业务量较大）
- NameServer：3 台
- Broker：3 主 3 从（6 台）
磁盘必须用SSD，机械盘会导致严重性能瓶颈。
三、部署步骤（生产可直接照做）
环境准备
- Linux（CentOS 7+/Ubuntu 20+）
- JDK 8+（必须）
- 关闭防火墙 / 开放端口：9876 (NameServer)、10911/10912 (Broker)
- 磁盘：SSD，预留 50GB+
步骤 1：下载解压
# 下载稳定版 4.9.5 / 5.1.0（生产推荐 4.9.x） wget https://archive.apache.org/dist/rocketmq/4.9.5/rocketmq-all-4.9.5-bin-release.zip unzip rocketmq-all-4.9.5-bin-release.zip mv rocketmq-4.9.5 /usr/local/rocketmq cd /usr/local/rocketmq步骤 2：修改 JVM 内存（非常重要）
默认内存太大，服务器会直接挂！
- 修改 NameServer 启动内存
vim bin/runserver.sh找到：
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g"改为：
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"- 修改 Broker 启动内存
vim bin/runbroker.sh找到：
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"改为：
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"步骤 3：配置 NameServer 集群（2 台）
每台 NameServer 都执行：
nohup sh bin/mqnamesrv & # 查看日志 tail -f ~/logs/rocketmqlogs/namesrv.log看到：
The Name Server boot success即启动成功。
步骤 4：配置 Broker 主从集群（核心）
我们以2 主 2 从为例：
机器规划
- 192.168.1.10：broker1-master
- 192.168.1.11：broker1-slave
- 192.168.1.12：broker2-master
- 192.168.1.13：broker2-slave
- NameServer：192.168.1.20, 192.168.1.21
1）配置 broker1-master
mkdir -p /data/rocketmq/store mkdir -p /data/rocketmq/logs vim conf/broker.conf写入：
properties
brokerClusterName = DefaultCluster brokerName = broker1 brokerId = 0 # 0=master deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER # 异步主（高性能） flushDiskType = ASYNC_FLUSH # 异步刷盘 listenPort=10911 namesrvAddr=192.168.1.20:9876;192.168.1.21:9876 storePathRootDir=/data/rocketmq/store storePathCommitLog=/data/rocketmq/store/commitlog storePathConsumeQueue=/data/rocketmq/store/consumequeue storePathIndex=/data/rocketmq/store/index storeCheckpoint=/data/rocketmq/store/checkpoint abortFile=/data/rocketmq/store/abort启动：
nohup sh bin/mqbroker -c conf/broker.conf &2）配置 broker1-slave
properties
brokerClusterName = DefaultCluster brokerName = broker1 brokerId = 1 # 非0=slave deleteWhen = 04 fileReservedTime = 48 brokerRole = SLAVE # 从节点 flushDiskType = ASYNC_FLUSH listenPort=10911 namesrvAddr=192.168.1.20:9876;192.168.1.21:9876 storePathRootDir=/data/rocketmq/store ...3）broker2-master 和 broker2-slave
- brokerName = broker2
- brokerId=0/master，brokerId=1/slave
- 其他完全一样
四、Java 生产环境客户端配置
生产者
@Bean public DefaultMQProducer producer() { DefaultMQProducer producer = new DefaultMQProducer("ProducerGroup"); // 填所有 NameServer producer.setNamesrvAddr("192.168.1.20:9876;192.168.1.21:9876"); producer.setRetryTimesWhenSendFailed(2); producer.setSendMsgTimeout(3000); return producer; }消费者
@Bean public DefaultMQPushConsumer consumer() throws MQClientException { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup"); consumer.setNamesrvAddr("192.168.1.20:9876;192.168.1.21:9876"); consumer.subscribe("TOPIC_TEST", "*"); consumer.setMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(...) { return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); return consumer; }五、生产环境关键配置（必看）
- brokerRole = ASYNC_MASTER（高性能）
- flushDiskType = ASYNC_FLUSH（高性能）
- 金融级可用：
- brokerRole = SYNC_MASTER
- flushDiskType = SYNC_FLUSH
- 磁盘保留 48 小时
- 开启自动删除过期文件
六、集群检查命令
# 查看集群状态 sh bin/mqadmin clusterList -n 192.168.1.20:9876 # 查看 Topic 路由 sh bin/mqadmin topicRoute -n 192.168.1.20:9876 -t TOPIC_TEST七、高可用保障机制
- NameServer 集群 → 无单点
- Broker 主从 → Master 挂了，Slave 自动升主（RocketMQ 4.x 需要手动切换；5.x 自动切换）
- 生产者 / 消费者自动重试、自动发现
- 消息持久化到磁盘
总结
- 生产架构：NameServer 集群（2~3 台） + Broker 主从集群（2 主 2 从起步）
- 部署核心：修改 JVM 内存 + 配置 broker.conf 主从 + 用 SSD
- 高可用：无单点、主从自动切换、消息不丢失
- Java 客户端：配置所有 NameServer 地址即可自动负载