apacherocketmq/rocketmq-operator

RocketMQ Operator 镜像文档

概述

RocketMQ Operator是一个基于Kubernetes Operator模式的工具，旨在自动化管理部署在Kubernetes集群上的RocketMQ服务实例全生命周期。通过自定义资源定义（CRD）和控制器，实现RocketMQ集群的声明式部署、扩展、升级及维护，简化Kubernetes环境中RocketMQ的运维复杂度。

核心功能与特性

• 声明式集群管理：通过Kubernetes CRD定义RocketMQ集群规格，支持NameServer、Broker等组件的配置
• 自动化运维：自动处理集群部署、扩缩容、故障检测与恢复
• 版本管理：支持RocketMQ版本升级，确保升级过程平滑无感知
• 资源优化：可配置CPU、内存等资源限制，适配不同规模的业务需求
• 高可用保障：支持Broker主从架构配置，提升消息服务可靠性

使用场景与适用范围

• 企业级消息队列服务部署与管理
• 微服务架构中需要可靠消息传递的场景
• 基于Kubernetes的云原生应用消息中间件需求
• 需要自动化运维、弹性扩展的RocketMQ集群环境

使用方法与配置说明

前置条件

• Kubernetes集群（1.16+版本）
• kubectl命令行工具
• 集群管理员权限

部署步骤

1. 部署CRD

bash
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/crds/rocketmq.apache.org_rocketmqclusters.yaml
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/crds/rocketmq.apache.org_brokers.yaml
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/crds/rocketmq.apache.org_nameservers.yaml

2. 部署Operator

bash
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/service_account.yaml
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/role.yaml
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/role_binding.yaml
kubectl apply -f https://raw.githubusercontent.com/apache/rocketmq-operator/master/deploy/operator.yaml

3. 创建RocketMQ集群

创建rocketmq-cluster.yaml文件，示例配置：

yaml
apiVersion: rocketmq.apache.org/v1alpha1
kind: RocketMQCluster
metadata:
  name: rocketmq-cluster
spec:
  nameServer:
    replicas: 2
    image: apache/rocketmq-namesrv:4.9.4
    resources:
      requests:
        memory: "512Mi"
        cpu: "500m"
      limits:
        memory: "1Gi"
        cpu: "1000m"
  broker:
    replicas: 2
    image: apache/rocketmq-broker:4.9.4
    resources:
      requests:
        memory: "1Gi"
        cpu: "1000m"
      limits:
        memory: "2Gi"
        cpu: "2000m"
    storageMode: PersistentVolume
    persistence:
      storageClassName: "standard"
      size: "10Gi"

应用配置：

bash
kubectl apply -f rocketmq-cluster.yaml

配置参数说明

查看集群状态

bash
kubectl get rocketmqclusters
kubectl get pods -l app=rocketmq

更多信息

完整文档和示例请参考：https://github.com/apache/rocketmq-operator