sir5kong/rocketmq

Apache RocketMQ Docker镜像文档

镜像概述

Apache RocketMQ是由Apache软件基金会开发的分布式消息中间件，提供高可用、高吞吐、低延迟的消息传递服务。本Docker镜像封装了RocketMQ核心组件（NameServer、Broker），可快速部署分布式消息系统，支持多种消息模式，满足企业级应用的消息通信需求。

核心功能与特性

• 多消息模型支持：支持普通消息、事务消息、定时/延时消息、顺序消息等多种消息类型
• 高可用架构：采用主从复制和多副本机制，确保消息不丢失，服务持续可用
• 高吞吐性能：单机支持百万级消息处理能力，适合高并发场景
• 低延迟通信：消息投递延迟低，满足实时性要求较高的业务场景
• 持久化存储：支持消息持久化到磁盘，确保系统重启后消息可恢复
• 灵活扩展：支持Broker集群横向扩展，适应业务增长需求
• 丰富的API：提供Java、C++、Python等多语言客户端SDK

使用场景与适用范围

• 异步通信：系统间非实时通信，如订单状态通知、日志上报
• 系统解耦：降低微服务间耦合度，提高系统弹性
• 流量削峰：应对突发流量（如秒杀、促销活动），保护后端服务
• 数据同步：跨系统数据复制与同步，如数据库变更同步
• 事件驱动架构：基于事件的系统集成，实现业务解耦与扩展
• 日志收集：分布式系统日志集中收集与处理

使用方法与配置说明

快速启动

1. 启动NameServer

bash
docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:latest sh mqnamesrv

2. 启动Broker

bash
docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 \
  -e "NAMESRV_ADDR=host.docker.internal:9876" \
  apache/rocketmq:latest sh mqbroker -c /home/rocketmq/rocketmq-4.9.4/conf/broker.conf

说明：host.docker.internal适用于本地开发环境，生产环境需替换为实际NameServer地址

Docker Compose配置

创建docker-compose.yml文件：

yaml
version: '3'
services:
  namesrv:
    image: apache/rocketmq:latest
    container_name: rmqnamesrv
    ports:
      - "9876:9876"
    volumes:
      - ./namesrv/logs:/root/logs
    command: sh mqnamesrv

  broker:
    image: apache/rocketmq:latest
    container_name: rmqbroker
    ports:
      - "10909:10909"
      - "10911:10911"
    volumes:
      - ./broker/logs:/root/logs
      - ./broker/store:/root/store
      - ./broker/conf/broker.conf:/home/rocketmq/rocketmq-4.9.4/conf/broker.conf
    environment:
      - NAMESRV_ADDR=namesrv:9876
      - JAVA_OPTS=-Duser.home=/root
    depends_on:
      - namesrv
    command: sh mqbroker -c /home/rocketmq/rocketmq-4.9.4/conf/broker.conf

启动服务：

bash
docker-compose up -d

环境变量说明

配置文件说明

Broker核心配置文件broker.conf关键参数：

properties
# 集群名称
brokerClusterName=DefaultCluster
# Broker名称
brokerName=broker-a
# Broker ID
brokerId=0
# 删除文件时间点，默认凌晨4点
deleteWhen=04
# 文件保留时间，默认48小时
fileReservedTime=48
# Broker角色：ASYNC_MASTER（异步复制主节点）、SYNC_MASTER（同步复制主节点）、SLAVE（从节点）
brokerRole=ASYNC_MASTER
# 刷盘策略：ASYNC_FLUSH（异步刷盘）、SYNC_FLUSH（同步刷盘）
flushDiskType=ASYNC_FLUSH

验证部署

1. 进入Broker容器：

bash
docker exec -it rmqbroker sh

2. 发送测试消息：

bash
cd /home/rocketmq/rocketmq-4.9.4/bin
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

3. 接收测试消息：

bash
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

若能正常发送和接收消息，说明部署成功。