etslabs/storm-cluster

自包含集群Docker镜像

镜像概述

本镜像提供一个集成了OpenJDK及多个Apache组件的自包含集群环境，包含Zookeeper、Nimbus、ActiveMQ、Supervisor和Storm。无需单独部署各组件，可快速搭建具备分布式协调、消息队列、实时计算能力的完整运行环境，适用于开发测试、小型生产部署及演示场景。

核心功能和特性

• OpenJDK：提供Java运行环境，支持所有Java-based组件运行
• Apache Zookeeper：分布式协调服务，负责集群节点管理和配置同步
• Apache Nimbus：Storm集群的主节点，负责分发任务和监控集群状态
• Apache ActiveMQ：高性能消息 broker，支持多种消息协议，实现系统间异步通信
• Supervisor：进程管理工具，确保集群组件持续运行并自动重启异常进程
• Apache Storm：分布式实时计算系统，支持流处理和批处理任务

使用场景和适用范围

• 开发测试环境：快速搭建本地分布式计算和消息处理集群，简化开发调试流程
• 小型生产部署：适用于数据量较小的实时数据处理场景，如日志分析、实时监控
• 教学与演示：展示分布式系统架构和实时计算原理的一体化环境
• 原型验证：在产品原型阶段快速验证基于Storm、ActiveMQ的业务逻辑

使用方法和配置说明

基本运行命令

bash
docker run -d \
  -p 2181:2181 \  # Zookeeper客户端端口
  -p 6627:6627 \  # Storm Nimbus端口
  -p 61616:61616 \ # ActiveMQ TCP端口
  -p 8080:8080 \  # Storm UI端口
  --name cluster-node \
  [镜像名称]

环境变量配置

数据持久化

通过挂载卷保存关键数据：

bash
docker run -d \
  -v /host/zookeeper/data:/opt/zookeeper/data \
  -v /host/activemq/data:/opt/activemq/data \
  -v /host/storm/logs:/opt/storm/logs \
  [镜像名称]

Docker Compose配置示例

yaml
version: '3'
services:
  cluster:
    image: [镜像名称]
    ports:
      - "2181:2181"
      - "6627:6627"
      - "61616:61616"
      - "8080:8080"
    environment:
      - ZOOKEEPER_PORT=2181
      - SUPERVISOR_WORKERS=3
    volumes:
      - zk-data:/opt/zookeeper/data
      - amq-data:/opt/activemq/data
      - storm-logs:/opt/storm/logs
volumes:
  zk-data:
  amq-data:
  storm-logs:

验证服务状态

1. 检查Zookeeper状态：echo stat | nc localhost 2181
2. 访问Storm UI：http://localhost:8080
3. 连接ActiveMQ管理界面：http://localhost:8161（默认账号admin/admin）

注意事项

• 本镜像为自包含集群，单节点部署，不适用于大规模生产环境
• 首次启动需等待30-60秒，待所有组件完成初始化
• 生产环境建议根据实际需求调整资源限制（内存、CPU）
• 敏感配置（如ActiveMQ账号密码）需通过环境变量或配置文件挂载自定义设置