4.16. 启用消息迁移以支持集群缩减

1. 当部署中的代理 Pod 因有意缩减部署而关闭时，Operator 会自动部署 scaledown 自定义资源以准备消息迁移。

2. 要检查已孤立的持久性卷(PV)，scaledown 控制器会查看卷声明的普通卷(PV)。控制器将卷声明中的普通与仍然在 StatefulSet （即代理集群）中运行的代理 Pod 进行对比。

   如果卷声明中的普通对象高于代理集群中仍在运行的任何代理 Pod 上，则缩减控制器决定代理 Pod 已关闭，并且该消息数据必须迁移到另一个代理 Pod。

3. scaledown 控制器启动一个 drainer Pod。drainer Pod 连接到集群中的其他 live 代理 Pod，并将信息迁移到该 live 代理 Pod。

流程

1. 编辑代理部署的 CR 实例。

   1. 使用 OpenShift 命令行界面：

      1. 以有权在代理部署的项目中部署 CR 的用户身份登录 OpenShift Container Platform。

      2. 编辑部署的 CR。

          oc edit ActiveMQArtemis <CR instance name> -n <namespace>

         Copy to Clipboard Toggle word wrap

   2. 使用 OpenShift Container Platform Web 控制台：

      1. 以有权在代理部署的项目中部署 CR 的用户身份登录 OpenShift Container Platform。
      2. 在左侧窗格中，单击 Administration Custom Resource Definitions。
      3. 单击 ActiveMQArtemis CRD。
      4. 点 实例 选项卡。
      5. 点代理部署的实例。

      6. 点 YAML 标签。

         在控制台中，会打开 YAML 编辑器，允许您编辑 CR 实例。

2. 在 CR 的 deploymentPlan 部分中，添加一个 messageMigration 属性，并设置为 true。如果尚未配置，请添加 persistenceEnabled 属性，并设置为 true。例如：

   spec:
     deploymentPlan:
       messageMigration: true
       persistenceEnabled: true
     ...

   Copy to Clipboard Toggle word wrap

   这些设置意味着，当您稍后缩减集群代理部署的大小时，Operator 会自动启动一个 scaledown 控制器，并将信息迁移到仍然运行的代理 Pod。

3. 保存 CR。

4. （可选）完成以下步骤来缩减集群并查看消息迁移过程。

   1. 在现有代理部署中，验证哪些 Pod 正在运行。

      $ oc get pods

      Copy to Clipboard Toggle word wrap

      您会看到类似如下的输出：

      activemq-artemis-operator-8566d9bf58-9g25l   1/1   Running   0   3m38s
      ex-aao-ss-0                                  1/1   Running   0   112s
      ex-aao-ss-1                                  1/1   Running   0   8s

      Copy to Clipboard Toggle word wrap

      前面的输出显示，有三个 Pod 正在运行；一个用于代理 Operator 本身，另一个用于部署中每个代理的独立 Pod。

   2. 登录到每个 Pod 并将一些消息发送到每个代理。

      1. 使用 Pod ex-aao-s-0 的集群 IP 地址 172.17.0.6，运行以下命令：

         $ /opt/amq/bin/artemis producer --url tcp://172.17.0.6:61616 --user admin --password admin

         Copy to Clipboard Toggle word wrap

   3. 使用 Pod ex-aao-s-1 的集群 IP 地址 172.17.0.7，运行以下命令：

      $ /opt/amq/bin/artemis producer --url tcp://172.17.0.7:61616 --user admin --password admin

      Copy to Clipboard Toggle word wrap

      前面的命令在每个代理上创建一个名为 TEST 的队列，并将 1000 个消息添加到每个队列。

   4. 将集群从两个代理扩展到一。

      1. 打开主代理 CR broker_activemqartemis_cr.yaml。
      2. 在 CR 中，将 deploymentPlan.size 设置为 1。

      3. 在命令行中应用更改：

         $ oc apply -f deploy/crs/broker_activemqartemis_cr.yaml

         Copy to Clipboard Toggle word wrap

         您会看到 Pod ex-aao-s-1 启动关闭。scaledown 控制器启动相同名称的新 drainer Pod。这个 drainer Pod 也会在将信息从代理 Pod ex-ao-s-1 中迁移到集群（ex-aao-ss-0）中的其他代理 Pod 中后关闭。

   5. 当 drainer Pod 关闭时，检查代理 Pod ex-aao-ss-0 的 TEST 队列中的消息计数。您可以看到，队列中的消息数量为 2000，表示排空程序 Pod 从关闭的代理 Pod 中成功迁移了 1000 个信息。