4.11. 高可用性和消息迁移

1. 当部署中的代理 Pod 因部署的意图而关闭时，Operator 会自动启动缩减控制器以准备消息迁移。scaledown 控制器在与代理集群相同的 OpenShift 项目名称中运行。
2. scaledown 控制器注册自己，并侦听项目中与持久性卷声明(PVC)相关的 Kubernetes 事件。

3. 要检查已经孤立的持久性卷(PV)，扩展控制器会在卷声明上查看 或dinal。控制器将卷声明上的 ordinal 与项目中仍然在 StatefulSet 中运行的代理 Pod（即代理集群）进行比较。

   如果卷声明上的 ordinal 大于仍在代理集群中任何代理 Pod 的 ordinal，则 scaledown 控制器会确定代理 Pod 已关闭，且消息传递数据必须迁移到另一个代理 Pod。

4. scaledown 控制器启动一个 drainer Pod。drainer Pod 运行代理并执行消息迁移。然后，drainer Pod 标识可迁移到孤立消息的替代代理 Pod。

   注意

   部署中必须至少有一个代理 Pod 仍在部署中运行，才能进行消息迁移。

流程

1. 在您最初下载并提取的 Operator 存储库的 deploy/crs 目录中，打开主代理 CR broker_activemqartemis_cr.yaml。

2. 在主代理 CR 中，将 messageMigration 和 persistenceEnabled 设置为 true。

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

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

   $ oc get pods

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

   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

   前面的输出显示，有三个 Pod 正在运行：一个用于 broker Operator 本身，以及部署中每个代理一个单独的 Pod。

4. 登录到每个 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

   2. 作为 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

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

5. 将集群从两个代理缩减为一个。

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

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

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

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

6. 当 drainer Pod 关闭时，检查 broker Pod ex-aao-ss-0 的 TEST 队列的消息数。您会看到队列中的消息数量为 2000，表示 drainer Pod 已成功迁移了关闭的代理 Pod 中的 1000 信息。