4.14. 为 AMQP 消息配置大型消息处理
客户端可能会发送可能会超过代理内部缓冲区大小的大型 AMQP 消息，从而导致意外错误。要防止这种情况，您可以将代理配置为当消息大于指定最小值时将消息存储为文件。以这种方式处理大型消息意味着代理不会在内存中保存消息。相反，代理会将消息存储在用于存储大型消息文件的专用目录中。
对于 OpenShift Container Platform 上的代理部署，大型消息目录为 /opt/ <custom_resource_name> /data/large-messages，代理用于消息存储的持久性卷(PV)。当代理将消息存储为大消息时，队列会在大型消息目录中保留对文件的引用。
您只能在 AMQP 协议的代理配置中配置大型消息大小限制。对于 AMQ Core 和 Openwire 协议，您可以在客户端连接配置中配置大量消息大小限制。如需更多信息，请参阅 Red Hat AMQ 客户端文档。
4.14.1. 为大型消息处理配置 AMQP 接受器
以下流程演示了如何配置接受者来处理大于指定大小的 AMQP 消息作为大消息。
先决条件
- 您应该熟悉如何为基于 Operator 的代理部署配置 acceptors。请参阅 第 4.12.1 节 “配置接收器”。
要将大型 AMQP 消息存储在专用的大型消息目录中，您的代理部署必须使用持久性存储（即
persistenceEnabled在用于创建部署的自定义资源(CR)实例中设为true）。有关配置持久性存储的更多信息，请参阅：
流程
打开您之前在其中定义 AMQP 接受器的自定义资源(CR)实例。
使用 OpenShift 命令行界面：
$ oc edit -f <path/to/custom_resource_instance>.yaml使用 OpenShift Container Platform Web 控制台：
-
在左侧导航菜单中点
-
单击
ActiveMQArtemisCRD。 -
点
Instances选项卡。 - 找到与项目命名空间对应的 CR 实例。
-
在左侧导航菜单中点
之前配置的 AMQP 接受者可能类似如下：
spec: ... acceptors: - name: my-acceptor protocols: amqp port: 5672 connectionsAllowed: 5 expose: true sslEnabled: true ...指定代理作为大消息处理的 AMQP 消息的最小大小（以字节为单位）。例如：
spec: ... acceptors: - name: my-acceptor protocols: amqp port: 5672 connectionsAllowed: 5 expose: true sslEnabled: true amqpMinLargeMessageSize: 204800 ... ...在上例中，代理配置为接受端口 5672 上的 AMQP 消息。根据
amqpMinLargeMessageSize的值，如果接受者收到一个大于或等于 204800 字节的正文的 AMQP 消息（即 200 KB），代理将消息存储为大消息。代理将消息存储在大型消息目录中(
/opt/ <custom_resource_name> /data/large-messages，默认为代理用于消息存储的持久性卷(PV))。如果您没有为
amqpMinLargeMessageSize属性显式指定值，代理会使用默认值 102400 （即 100 KB）。如果将
amqpMinLargeMessageSize设置为 -1，则 AMQP 消息的大量消息处理被禁用。
