第 8 章 处理大量消息
客户端可能会发送可能会超过代理内部缓冲区大小的大型消息，从而导致意外错误。要防止这种情况，您可以在消息大于指定最小值时将代理配置为存储消息作为文件。以这种方式处理大型消息意味着代理不会在内存中保存消息。相反，您可以在磁盘或代理存储大型消息文件的数据库表中指定一个目录。
当代理将消息存储为大型消息时，队列会在大型消息目录或数据库表中保留对该文件的引用。
大型消息处理可用于核心协议、AMQP、OpenWire 和 STOMP 协议。
对于核心协议和 OpenWire 协议，客户端在其连接配置中指定最小大消息大小。对于 AMQP 和 STOMP 协议，您可以在代理配置中为每个协议定义的 acceptor 中指定最小大消息大小。
建议您不要使用不同的协议 来生成和使用大量消息。要做到这一点，代理可能需要执行消息的多个转换。例如，假设您想使用 AMQP 协议发送消息，并使用 OpenWire 接收消息。在这种情况下，代理必须首先读取大型消息的整个正文，并将其转换为使用核心协议。然后，代理必须执行另一个转换，这一次到 OpenWire 协议。比如这些信息转换，比如在代理中造成大量处理开销。
您为上述任何协议指定的最少大消息大小会受到系统资源的影响，如可用的磁盘空间量以及消息的大小。建议您使用多个值运行性能测试来确定适当的大小。
本节中的步骤演示了如何：
- 配置代理以存储大型信息
- 为 AMQP 和 STOMP 协议配置接受器，以进行大型消息处理
本节还链接到有关配置 AMQ 核心协议和 AMQ OpenWire JMS 客户端的其他资源，以用于大型消息。
8.1. 为大型消息处理配置代理
以下流程演示了如何在磁盘或代理存储大型消息文件的数据库表上指定目录。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml配置文件。 指定您希望代理存储大型消息文件的位置。
如果您要在磁盘上存储大量消息，请在
core元素中添加large-messages-directory参数并指定文件系统位置。例如：<configuration> <core> ... <large-messages-directory>/path/to/my-large-messages-directory</large-messages-directory> ... </core> </configuration>注意如果没有为
large-messages-directory明确指定值，代理会使用默认值 <broker_instance_dir> /data/largemessages如果您要将大型消息存储在数据库表中，请将
large-message-table参数添加到database-store元素中，并指定一个值。例如：<store> <database-store> ... <large-message-table>MY_TABLE</large-message-table> ... </database-store> </store>注意如果没有为
large-message-table明确指定值，代理将使用默认值LARGE_MESSAGE_TABLE。
其他资源
- 有关配置数据库存储的详情，请参考 第 6.2 节 “在数据库中保留消息数据”。
