Kubernetes (K8s) 部署 RocketMQ 集群：双主双从+同步模式

RocketMQ 是一款开源的分布式消息中间件，广泛用于处理大量消息的可靠传输。在分布式系统中，RocketMQ 可用于解耦生产者和消费者，提高系统的可扩展性和容错性。本文将介绍如何在 Kubernetes (K8s) 上部署 RocketMQ 集群，实现双主双从+同步模式的高可用性。
一、环境准备
在开始之前，请确保您已经具备以下条件：

• 一台已安装并正常运行 Kubernetes 的服务器或集群。
• 拥有足够的权限在 Kubernetes 上创建和管理资源。
  二、RocketMQ 配置
  首先，我们需要对 RocketMQ 进行一些必要的配置。在此我们以双主双从+同步模式为例进行说明：

1. 主节点配置（Broker）
   在每个 RocketMQ Broker 的配置文件（通常是 broker.conf）中，进行如下设置：

   broker.name=broker-${broker.id}
   broker.master=true

2. 从节点配置（Slave）
   同样在每个 RocketMQ Broker 的配置文件中，进行如下设置：

   broker.name=broker-${broker.id}
   slave.同步模式=true

3. 同步复制配置（Sync Replication）
   为了实现同步复制，我们需要确保每个主节点都有至少一个从节点。同时，每个从节点都与一个主节点关联。这样，当消息被写入主节点时，它会同步到关联的从节点。为了实现这一点，我们需要在 Broker 配置文件中设置：

   slave.sync.master=true

   三、Kubernetes 资源定义
   接下来，我们将使用 Kubernetes 的自定义资源定义 (CRD) 来定义 RocketMQ 的部署和配置。首先，确保您已经安装了 RocketMQ 的 CRD 和 Operator。您可以从 RocketMQ 的 GitHub 仓库中找到这些资源。
4. 部署 RocketMQ Broker
   在 Kubernetes 中部署 RocketMQ Broker，我们需要创建一个 Deployment 资源。以下是一个示例 Deployment 资源的 YAML 文件：
   ```yaml
   apiVersion: apps/v1
   kind: Deployment
   metadata:
   name: mq-broker-deployment
   spec:
   replicas: 3 # 根据实际需求设置副本数，这里以3个为例
   selector:
   matchLabels:
   app: rocketmq-broker
   template:
   metadata:
   labels:
   app: rocketmq-broker
   spec:
   containers:

• name: rocketmq-broker
  image: alibaba/rocketmq:latest # 使用 RocketMQ 的镜像，请根据实际情况选择版本号或自定义镜像地址
  ports:
• containerPort: 9876 # RocketMQ 的默认端口是 9876，可以根据需要调整端口号。
  volumeMounts: # 如果您需要持久化存储数据，请配置 volumeMounts 和 volumes。这里省略持久化配置示例。 # 注意：请根据您的实际需求进行持久化存储配置。 - name: mq-data mountPath: /data/rocketmq subPath: rocketmq readOnly: false volumes: - name: mq-data emptyDir: {}```请注意，上述示例中的镜像地址和版本号仅用于说明目的。在实际应用中，您需要使用最新版本的镜像或根据您的需求选择适当的版本。同时，根据您的需求和环境配置持久化存储。上面的示例中省略了持久化存储的配置部分，您需要根据实际情况进行相应的配置。 3. 在实际应用中，根据您的需求和环境配置持久化存储。上面的示例中省略了持久化存储的配置部分，您需要根据实际情况进行相应的配置。例如，您可以使用 Kubernetes 的 Persistent Volume Claim (PVC) 和 Persistent Volume