kubemq/kubemq-community

镜像概述

该镜像是一款企业级消息代理，专为Docker和Kubernetes环境设计，原生支持容器化部署。作为消息中间件，它提供可靠的异步消息传递机制，帮助构建松耦合的分布式系统，确保不同服务间的高效通信与数据交换。

核心功能与特性

• 企业级可靠性：支持消息持久化、故障自动恢复和高可用集群配置，保障消息传递的一致性和零丢失。
• 云原生架构支持：针对Docker容器和Kubernetes编排环境优化，支持自动扩缩容、滚动更新和容器健康检查，无缝集成云原生生态。
• 多协议兼容：支持AMQP、MQTT、STOMP等多种消息协议，满足不同应用场景的通信需求。
• 灵活消息模式：提供队列、主题、发布/订阅、点对点等多种消息传递模式，适应同步和异步通信场景。
• 安全机制：内置身份认证、权限控制和数据加密功能，保障消息传输和存储的安全性。

使用场景

• 微服务通信：作为微服务架构中的通信枢纽，实现服务间解耦和异步协作。
• 分布式系统集成：连接跨平台、跨语言的系统和服务，实现异构环境下的消息互通。
• 高可靠业务场景：在***交易、订单处理、日志收集等需要确保消息不丢失的业务中提供支撑。
• 流量控制：在高并发场景下缓冲请求，削峰填谷，平衡系统负载。

使用方法

基本Docker部署

通过以下命令快速启动消息代理容器：

bash
docker run -d \
  --name message-broker \
  -p 5672:5672 \  # 消息通信端口（默认AMQP端口）
  -p 15672:15672 \ # 管理界面端口（如适用）
  <image-name>

Docker Compose配置

创建docker-compose.yml文件进行多容器协同部署：

yaml
version: '3'
services:
  message-broker:
    image: <image-name>
    ports:
      - "5672:5672"   # 消息端口
      - "15672:15672" # 管理界面端口
    environment:
      - BROKER_USER=admin          # 管理员用户名
      - BROKER_PASSWORD=Secure@123 # 管理员密码
      - PERSISTENCE_ENABLED=true   # 启用消息持久化
      - LOG_LEVEL=info             # 日志级别
    volumes:
      - broker-data:/var/lib/message-broker # 持久化数据卷
    restart: always

volumes:
  broker-data:

Kubernetes部署

Deployment配置

yaml
apiVersion: apps/v1
kind: Deployment
metadata:
  name: message-broker
spec:
  replicas: 3  # 3节点高可用集群
  selector:
    matchLabels:
      app: message-broker
  template:
    metadata:
      labels:
        app: message-broker
    spec:
      containers:
      - name: message-broker
        image: <image-name>
        ports:
        - containerPort: 5672
        env:
        - name: BROKER_USER
          value: "admin"
        - name: BROKER_PASSWORD
          valueFrom:
            secretKeyRef:
              name: broker-secrets
              key: password
        - name: PERSISTENCE_ENABLED
          value: "true"
        volumeMounts:
        - name: broker-data
          mountPath: /var/lib/message-broker
  volumes:
  - name: broker-data
    persistentVolumeClaim:
      claimName: broker-pvc

Service配置

yaml
apiVersion: v1
kind: Service
metadata:
  name: message-broker
spec:
  selector:
    app: message-broker
  ports:
  - port: 5672
    targetPort: 5672
  type: ClusterIP  # 集群内部访问

环境变量说明