gennyproject/messages

Messaging Service 镜像文档

镜像概述

Messaging Service 是一个轻量级消息服务Docker镜像，专为分布式系统设计，提供可靠的异步通信能力。该镜像封装了消息队列核心功能，支持多种消息传递模式，可无缝集成到微服务架构中，解决服务间实时通信、异步任务处理及系统解耦问题。

核心功能与特性

核心功能

• 多协议支持：兼容AMQP 0-9-1、MQTT 3.1.1及HTTP协议，满足不同场景通信需求
• 消息队列管理：支持点对点队列、发布/订阅模式及主题路由
• 消息持久化：提供内存存储与磁盘持久化两种模式，保障消息不丢失
• 高可用性：支持主从复制与集群部署，实现服务无单点故障

关键特性

• 低延迟通信：消息传递延迟≤10ms，满足实时性要求
• 消息重试机制：自动重试失败消息，支持自定义重试策略
• 流量控制：内置消息速率限制与背压处理，防止系统过载
• 安全认证：支持基于用户名/密码及JWT的身份验证机制

使用场景与适用范围

典型使用场景

• 微服务间通信：解耦服务依赖，实现跨服务异步消息传递
• 异步任务处理：将耗时任务（如数据处理、邮件发送）放入队列异步执行
• 实时通知系统：推送订单状态、系统告警等实时消息
• 分布式事件总线：作为事件驱动架构的核心组件，传递系统事件

适用范围

• 中小型分布式系统
• 微服务架构应用
• 需要异步通信的业务系统
• 对消息可靠性有要求的场景

使用方法与配置说明

基本部署（Docker Run）

快速启动（内存模式）

bash
docker run -d \
  --name messaging-service \
  -p 5672:5672 \  # AMQP端口
  -p 1883:1883 \  # MQTT端口
  -p 8080:8080 \  # HTTP API端口
  messaging-service:latest

持久化部署（挂载数据卷）

bash
docker run -d \
  --name messaging-service \
  -p 5672:5672 \
  -p 1883:1883 \
  -p 8080:8080 \
  -v /host/path/messaging-data:/app/data \  # 持久化数据目录
  -e STORAGE_TYPE=persistent \  # 启用持久化存储
  -e MAX_MESSAGE_SIZE=1048576 \  # 最大消息大小1MB
  messaging-service:latest

Docker Compose配置

yaml
version: '3.8'
services:
  messaging-service:
    image: messaging-service:latest
    container_name: messaging-service
    ports:
      - "5672:5672"   # AMQP协议端口
      - "1883:1883"   # MQTT协议端口
      - "8080:8080"   # HTTP管理API端口
    environment:
      - PORT=8080
      - STORAGE_TYPE=persistent
      - STORAGE_PATH=/app/data
      - AUTH_ENABLED=true
      - ADMIN_USER=admin
      - ADMIN_PASSWORD=securepassword
      - MAX_CONCURRENT_CONNECTIONS=1000
    volumes:
      - ./messaging-data:/app/data  # 本地持久化卷
    restart: unless-stopped

环境变量说明

数据持久化

为防止容器重启导致消息丢失，建议通过数据卷挂载持久化目录：

bash
-v /host/path/messaging-data:/app/data

当STORAGE_TYPE=persistent时，所有消息将存储在该目录下的LevelDB数据库中。

注意事项

• 生产环境建议启用AUTH_ENABLED=true并设置强密码
• 高并发场景下推荐使用persistent存储类型并配置数据卷
• 集群部署需额外配置CLUSTER_MODE=true及节点通信参数
• 超过MAX_MESSAGE_SIZE的消息将被拒绝并返回413错误