rocketchat/ddp-streamer-service

DDP Streamer 微服务 Docker 镜像文档

1. 镜像概述和主要用途

DDP Streamer 微服务 Docker 镜像是专为 Rocket.Chat 设计的组件，用于处理基于 DDP（Distributed Data Protocol）协议的实时数据流传输。该镜像封装了 DDP 协议的核心处理逻辑，支持 Rocket.Chat 系统中实时消息、状态同步、数据推送等场景的高效数据流转，是 Rocket.Chat 实时通信能力的关键支撑组件。

2. 核心功能和特性

2.1 核心功能

• DDP 协议原生支持：完整兼容 DDP 协议规范，实现客户端与服务端的双向实时数据交换。
• 实时数据流处理：低延迟传输 Rocket.Chat 系统中的消息、用户状态、会话更新等实时数据。
• 连接管理：动态维护客户端连接，支持连接建立、心跳检测、异常断开重连。

2.2 关键特性

• 高并发支持：优化的连接池设计，可处理数千级并发客户端连接。
• 可配置化：通过环境变量灵活调整服务端口、连接参数、日志级别等核心配置。
• 轻量级部署：基于 Alpine 基础镜像构建，镜像体积小，资源占用低。
• 日志与监控：支持标准输出日志（stdout/stderr），便于集成外部日志系统（如 ELK、Prometheus）。
• 容器化适配：原生支持 Docker 容器化部署，兼容 Kubernetes 等编排平台。

3. 使用场景和适用范围

3.1 典型使用场景

• Rocket.Chat 实时消息传输：作为消息中转站，处理用户间实时聊天、群聊消息的 DDP 协议数据流转。
• 状态同步：同步用户在线状态、会话状态（如“正在输入”）、未读消息计数等实时状态数据。
• 事件推送：向客户端推送系统事件（如用户加入/离开频道、角色权限变更）。

3.2 适用范围

• 部署环境：与 Rocket.Chat 主服务配合部署，支持单机、集群（多节点）、云环境（AWS/Azure/GCP）等场景。
• 用户规模：适用于中小型团队（数百用户）至大型企业（数万用户）的 Rocket.Chat 部署。
• 集成场景：可与 Rocket.Chat 主服务、数据库（如 MongoDB）、缓存系统（如 Redis）协同工作，构建完整实时通信链路。

4. 使用方法和配置说明

4.1 镜像获取

通过 Docker Hub 拉取官方镜像（假设镜像名称为 rocketchat/ddp-streamer）：

bash
docker pull rocketchat/ddp-streamer:latest

4.2 基本运行命令

4.2.1 单机快速启动

bash
docker run -d \
  --name ddp-streamer \
  -p 3000:3000 \
  -e DDP_SERVER_URL="http://rocketchat-server:3000" \
  -e LOG_LEVEL="info" \
  rocketchat/ddp-streamer:latest

4.2.2 参数说明

• -p 3000:3000：端口映射，将容器内 3000 端口（服务默认端口）映射到主机 3000 端口。
• DDP_SERVER_URL：Rocket.Chat 主服务的 DDP 接入地址（需确保容器可访问该地址）。

4.3 环境变量配置

通过环境变量调整服务行为，常用配置如下：

4.4 Docker Compose 部署示例

与 Rocket.Chat 主服务协同部署的 docker-compose.yml 示例：

yaml
version: '3.8'

services:
  rocketchat:
    image: rocketchat/rocket.chat:latest
    ports:
      - "3000:3000"
    environment:
      - MONGO_URL=mongodb://mongo:27017/rocketchat
      - MONGO_OPLOG_URL=mongodb://mongo:27017/local
    depends_on:
      - mongo
    networks:
      - rocketchat-network

  ddp-streamer:
    image: rocketchat/ddp-streamer:latest
    ports:
      - "3001:3000"  # DDP Streamer 服务端口
    environment:
      - PORT=3000
      - DDP_SERVER_URL="http://rocketchat:3000"  # 连接 Rocket.Chat 主服务的 DDP 地址
      - LOG_LEVEL=debug
      - MAX_CONCURRENT_CONNECTIONS=2000
      - HEARTBEAT_INTERVAL=20
    depends_on:
      - rocketchat
    networks:
      - rocketchat-network
    logging:
      driver: "json-file"
      options:
        max-size: "10m"
        max-file: "3"

  mongo:
    image: mongo:5.0
    volumes:
      - mongo-data:/data/db
    networks:
      - rocketchat-network

networks:
  rocketchat-network:
    driver: bridge

volumes:
  mongo-data:

启动命令：

bash
docker-compose up -d

4.5 高级配置

4.5.1 TLS 加密配置

若需启用 TLS，需挂载证书文件并配置环境变量：

bash
docker run -d \
  --name ddp-streamer-tls \
  -p 443:3000 \
  -e PORT=3000 \
  -e ENABLE_TLS=true \
  -e TLS_CERT_PATH=/etc/ssl/certs/server.crt \
  -e TLS_KEY_PATH=/etc/ssl/private/server.key \
  -v /host/path/to/certs:/etc/ssl/certs \
  -v /host/path/to/private:/etc/ssl/private \
  rocketchat/ddp-streamer:latest

4.5.2 持久化日志

通过挂载日志目录实现日志持久化：

bash
docker run -d \
  --name ddp-streamer \
  -v /host/logs/ddp-streamer:/var/log/ddp-streamer \
  -e LOG_FILE_PATH=/var/log/ddp-streamer/streamer.log \
  rocketchat/ddp-streamer:latest

5. 注意事项

• 网络连通性：确保 DDP Streamer 容器与 Rocket.Chat 主服务在同一网络（如通过 Docker Compose 网络或自定义桥接网络），避免因网络隔离导致连接失败。
• 资源限制：根据并发量调整容器 CPU/内存资源（通过 --cpus、--memory 参数），避免资源耗尽。
• 版本兼容性：需使用与 Rocket.Chat 主服务版本匹配的 DDP Streamer 镜像（参考 Rocket.Chat 官方版本说明）。
• 安全配置：生产环境中建议启用 TLS 加密，并限制容器权限（如使用非 root 用户运行）。