3.4. 创建基于 Operator 的代理部署
3.4.1. 部署基本代理实例 复制链接链接已复制到粘贴板!
以下流程演示了如何使用自定义资源(CR)实例创建基本代理部署。
虽然您可以通过部署多个自定义资源(CR)实例在给定 OpenShift 项目中创建多个代理部署,但通常在项目中创建单个代理部署,然后为地址部署多个 CR 实例。
红帽建议在单独的项目中创建代理部署。
在 AMQ Broker 7.11 中,如果要配置以下项目,则必须在首次部署 CR 前 将适当的配置添加到主代理 CR 实例中。
先决条件
您必须已安装了 AMQ Broker Operator。
- 要使用 OpenShift 命令行界面(CLI)安装 AMQ Broker Operator,请参阅 第 3.2 节 “使用 CLI 安装 Operator”。
- 要使用 OperatorHub 图形界面安装 AMQ Broker Operator,请参阅 第 3.3 节 “使用 OperatorHub 安装 Operator”。
- 您应该了解 Operator 如何选择代理容器镜像以用于代理部署。更多信息请参阅 第 2.6 节 “Operator 如何选择容器镜像”。
- 从 AMQ Broker 7.3 开始,您可以使用 Red Hat Ecosystem Catalog 的新版本来访问容器镜像。此新版本的 registry 要求您成为经过身份验证的用户,然后才能访问镜像。在按照本节中的步骤前,您必须首先完成 Red Hat Container Registry 身份验证 中所述的步骤。
流程
当成功安装 Operator 时,Operator 会运行并侦听与 CR 相关的更改。本例流程演示了如何使用 CR 实例在项目中部署基本代理。
为代理部署配置自定义资源(CR)实例。
使用 OpenShift 命令行界面:
以具有特权的用户身份登录 OpenShift,以便在您要在其中创建部署的项目中部署 CR。
oc login -u <user> -p <password> --server=<host:port>-
打开名为
broker_activemqartemis_cr.yaml的示例 CR 文件,该文件包含在您下载和提取的 Operator 安装存档的deploy/crs目录中。
使用 OpenShift Container Platform Web 控制台:
- 以有权在您要创建部署的项目中部署 CR 的用户身份登录控制台。
-
根据主代理 CRD 启动一个新的 CR 实例。在左侧窗格中,点
。 - 单击 ActiveMQArtemis CRD。
- 点 实例 选项卡。
单击 Create ActiveMQArtemis。
在控制台中,会打开 YAML 编辑器,供您配置 CR 实例。
对于基本的代理部署,配置可能类似如下。
apiVersion: broker.amq.io/v1beta1 kind: ActiveMQArtemis metadata: name: ex-aao spec: deploymentPlan: size: 1 image: placeholder requireLogin: false persistenceEnabled: true journalType: nio messageMigration: true观察
broker_activemqartemis_cr.yaml示例 CR 文件中的,image属性被设置为占位符的默认值。这个值表示,默认情况下image属性没有指定用于部署的代理容器镜像。要了解 Operator 如何确定要使用的适当代理容器镜像,请参阅 第 2.6 节 “Operator 如何选择容器镜像”。注意broker_activemqartemis_cr.yaml示例 CR 使用ex-aao的命名规则。这种命名约定表示 CR 是 AMQ Broker Operator 的示例 资源。AMQ Broker 基于 ActiveMQ Artemis 项目。当您部署此示例 CR 时,生成的 StatefulSet 使用名称ex-aao-ss。另外,部署中的代理 Pod 直接基于 StatefulSet 名称,如ex-aao-ss-0、ex-aao-ss-1等等。CR 中的应用程序名称会出现在部署中作为 StatefulSet 上的标签。例如,您可以在 Pod 选择器中使用该标签。-
size属性指定要部署的代理数量。值2或更高指定了集群代理部署。但是,要部署单个代理实例,请确保值设为1。 部署 CR 实例。
使用 OpenShift 命令行界面:
- 保存 CR 文件。
切换到您要在其中创建代理部署的项目。
$ oc project <project_name>创建 CR 实例。
$ oc create -f <path/to/custom_resource_instance>.yaml
使用 OpenShift Web 控制台:
- 配置完 CR 后,点 Create。
在 OpenShift Container Platform web 控制台中,点
。您会看到一个名为 ex-aao-ss的新 StatefulSet。- 点 ex-aao-ss StatefulSet。您会看到有一个 Pod,对应于您在 CR 中定义的单个代理。
- 在 StatefulSet 中,点 Pods 选项卡。点 ex-aao-ss Pod。在运行 Pod 的 Events 选项卡中,您会看到代理容器已启动。Logs 选项卡显示代理本身正在运行。
要测试代理是否正常运行,请访问代理 Pod 上的 shell 来发送一些测试信息。
使用 OpenShift Container Platform Web 控制台:
-
单击
。 - 点 ex-aao-ss Pod。
- 点击 Terminal 选项卡。
-
单击
使用 OpenShift 命令行界面:
获取项目的 Pod 名称和内部 IP 地址。
$ oc get pods -o wide NAME STATUS IP amq-broker-operator-54d996c Running 10.129.2.14 ex-aao-ss-0 Running 10.129.2.15访问代理 Pod 的 shell。
$ oc rsh ex-aao-ss-0
从 shell,使用
artemis命令发送一些测试消息。在 URL 中指定代理 Pod 的内部 IP 地址。例如:sh-4.2$ ./amq-broker/bin/artemis producer --url tcp://10.129.2.15:61616 --destination queue://demoQueue以上命令会在代理上自动创建一个名为
demoQueue的队列,并将默认数量 1000 个消息发送到队列。您应该看到类似如下的输出:
Connection brokerURL = tcp://10.129.2.15:61616 Producer ActiveMQQueue[demoQueue], thread=0 Started to calculate elapsed time ... Producer ActiveMQQueue[demoQueue], thread=0 Produced: 1000 messages Producer ActiveMQQueue[demoQueue], thread=0 Elapsed time in second : 3 s Producer ActiveMQQueue[demoQueue], thread=0 Elapsed time in milli second : 3492 milli seconds
其他资源
- 有关主代理自定义资源(CR)的完整配置参考,请参阅 第 8.1 节 “自定义资源配置参考”。
- 要了解如何将正在运行的代理连接到 AMQ 管理控制台,请参阅 第 5 章 为基于 Operator 的代理部署连接到 AMQ 管理控制台。
3.4.2. 部署集群代理 复制链接链接已复制到粘贴板!
如果项目中有两个或更多代理 Pod,则 Pod 会自动组成代理集群。集群配置可让代理互相连接并根据需要重新分发信息,以进行负载平衡。
以下流程演示了如何部署集群代理。默认情况下,此部署中的代理用于 需求 负载平衡,这意味着代理仅将消息转发到具有匹配消费者的其他代理。
先决条件
- 已部署了基本代理实例。请参阅 第 3.4.1 节 “部署基本代理实例”。
流程
- 打开用于基本代理部署的 CR 文件。
对于集群部署,请确保
deploymentPlan.size的值为2或更高。例如:apiVersion: broker.amq.io/v1beta1 kind: ActiveMQArtemis metadata: name: ex-aao spec: deploymentPlan: size: 4 image: placeholder ...注意在
metadata部分中,您需要包含namespace属性,且仅在 使用 OpenShift Container Platform Web 控制台创建 CR 实例时才指定值。您应指定的值是代理部署的 OpenShift 项目的名称。- 保存修改后的 CR 文件。
以具有特权在之前创建的基本代理部署的项目中部署 CR 的用户身份登录 OpenShift。
$ oc login -u <user> -p <password> --server=<host:port>切换到之前创建的基本代理部署的项目。
$ oc project <project_name>在命令行中应用更改:
$ oc apply -f <path/to/custom_resource_instance>.yaml在 OpenShift Container Platform web 控制台中,其他代理 Pod 根据 CR 中指定的数量在项目中启动。默认情况下,在项目中运行的代理集群。
打开每个 Pod 的 Logs 选项卡。日志显示 OpenShift 在每个代理上建立了集群连接网桥。具体来说,日志输出包括类似如下的行:
targetConnector=ServerLocatorImpl (identity=(Cluster-connection-bridge::ClusterConnectionBridge@6f13fb88
3.4.3. 将自定义资源更改应用到正在运行的代理部署 复制链接链接已复制到粘贴板!
以下是将自定义资源(CR)应用到运行代理部署的一些重要事项:
-
您无法动态更新 CR 中的
persistenceEnabled属性。要更改此属性,请将集群缩减为零个代理。删除现有 CR。然后,使用您的更改重新创建 CR,同时指定部署大小。 -
如 第 3.2.2 节 “使用 CLI 部署 Operator” 所述,如果您创建了一个带有持久性存储的代理部署(即,通过在 CR 中设置
persistenceEnabled=true),您可能需要为 AMQ Broker Operator 置备持久性卷(PV)以声明代理 Pod。如果您缩减代理部署的大小,Operator 会释放之前为代理 Pod 声明的所有 PV。但是,如果您通过删除 CR 来删除代理部署,AMQ Broker Operator 不会为在删除时仍在部署中的代理 Pod 释放 PVC。另外,任何新部署都无法使用这些未发布的 PV。在这种情况下,您需要手动释放卷。如需更多信息,请参阅 OpenShift 文档中的 发布持久性卷。 在 AMQ Broker 7.11 中,如果要配置以下项目,则必须在首次部署 CR 前 将适当的配置添加到主 CR 实例中。
- 在活跃的扩展事件中,您应用的任何进一步更改都会由 Operator 排队,且仅在扩展完成后执行。例如,假设您将部署的大小从四个代理缩减为一。然后,在进行缩减时,您也会更改代理管理员用户名和密码的值。在这种情况下,Operator 会排队用户名和密码更改,直到部署使用一个活跃代理运行为止。
-
所有 CR 更改 - 除了更改部署的大小外,或更改接受器、连接器或控制台的
expose属性的值外,都会导致重启现有代理。如果您的部署中有多个代理,则一次只有一个代理重启。