4.9. 为 AMQP 消息配置大型消息处理

流程

1. 打开您之前定义 AMQP acceptor 的自定义资源(CR)实例。

   1. 使用 OpenShift 命令行界面：

      $ oc edit -f <path/to/custom_resource_instance>.yaml

      Copy to Clipboard Toggle word wrap

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

      1. 在左侧导航菜单中点 Administration Custom Resource Definitions
      2. 单击 ActiveMQArtemis CRD。
      3. 点 Instances 选项卡。
      4. 查找与项目命名空间对应的 CR 实例。

   之前配置的 AMQP 接受程序可能类似如下：

   spec:
   ...
     acceptors:
     - name: my-acceptor
       protocols: amqp
       port: 5672
       connectionsAllowed: 5
       expose: true
       sslEnabled: true
   ...

   Copy to Clipboard Toggle word wrap

2. 指定代理作为较大消息的 AMQP 消息的最小大小，以字节为单位。例如：

   spec:
   ...
     acceptors:
     - name: my-acceptor
       protocols: amqp
       port: 5672
       connectionsAllowed: 5
       expose: true
       sslEnabled: true
       amqpMinLargeMessageSize: 204800
       ...
   ...

   Copy to Clipboard Toggle word wrap

   在前面的示例中，代理配置为接受端口 5672 上的 AMQP 信息。根据 amqpMinLargeMessageSize 的值，如果 acceptor 收到一个大于 204800 字节的 AMQP 消息（即 200 KB），代理会将消息存储为大消息。

   代理将消息存储在大型消息目录中（/opt/ <custom_resource_name> /data/large-messages，默认为代理用于消息存储的持久性卷(PV)）。

   如果您没有显式指定 amqpMinLargeMessageSize 属性的值，则代理使用默认值 102400（即 100 KB）。

   如果将 amqpMinLargeMessageSize 设置为 -1，则会禁用 AMQP 消息的大型消息处理。