7.3. 配置消息阻塞
以下流程演示了如何在给定地址达到您指定的最大大小限制时配置消息块。
您只能为 Core、OpenWire 和 AMQP 协议配置消息阻塞。
7.3.1. 阻塞内核和 OpenWire producers
以下流程演示了如何在给定地址达到您指定的最大大小限制时为 Core 和 OpenWire 消息制作器配置消息块。
先决条件
- 您应该熟悉如何配置地址和地址设置。更多信息请参阅 第 4 章 配置地址和队列。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 对于您为匹配地址 或一组 地址配置的
address-setting
元素,请添加配置元素以定义消息块行为。例如:<address-settings> <address-setting match="my.blocking.address"> ... <max-size-bytes>300000</max-size-bytes> <address-full-policy>BLOCK</address-full-policy> ... </address-setting> </address-settings>
max-size-bytes
在代理执行为
address-full-policy
指定的策略前,地址允许的内存的最大大小(以字节为单位)。您指定的值还支持字节表示法,如"K"、"MB"和"GB"。注意如果您在
address-setting
元素中指定max-size-bytes
,则该值将应用到 每个 匹配的地址。指定这个值 并不意味着 所有匹配地址 的总大小 限制为max-size-bytes
的值。address-full-policy
- 然后,达到地址的最大大小时代理要执行的操作。
在前面的示例中,当发送到内存中的地址
my.blocking.address
的消息超过 300000 字节时,代理开始阻止来自 Core 或 OpenWire 消息的进一步消息。
7.3.2. 阻塞 AMQP 生产者
Core 和 OpenWire 等协议使用窗口大小流控制系统。在此系统中,贡献度代表字节数,并且被分配给生产者。如果制作者想要发送消息,则生产者必须等到其有足够贡献度来获得消息的大小。
相反,AMQP 流控制度不代表字节数。相反,AMQP 学位代表允许发送者的消息数量,而不考虑消息大小。因此,在某些情况下 AMQP 生产者可能会显著超过地址的 max-size-bytes
值。
因此,要阻止 AMQP 制作者,您必须使用不同的配置元素 max-size-bytes-reject-threshold
。对于匹配的地址或一组地址,此元素指定内存中所有 AMQP 消息的最大值。当内存中的所有消息的总大小达到指定的限制时,代理会阻止 AMQP 生产者发送更多消息。
以下步骤演示了如何为 AMQP 消息制作者配置消息块。
先决条件
- 您应该熟悉如何配置地址和地址设置。更多信息请参阅 第 4 章 配置地址和队列。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 对于您为匹配地址 或一组 地址配置的
address-setting
元素,请指定内存中所有 AMQP 消息的最大值。例如:<address-settings> <address-setting match="my.amqp.blocking.address"> ... <max-size-bytes-reject-threshold>300000</max-size-bytes-reject-threshold> ... </address-setting> </address-settings>
max-size-bytes-reject-threshold
在代理阻止进一步的 AMQP 消息前允许的地址允许的内存的最大大小,以字节为单位。您指定的值还支持字节表示法,如"K"、"MB"和"GB"。默认情况下,
max-size-bytes-reject-threshold
设置为-1
,这意味着没有最大大小。注意如果您在
address-setting
元素中指定max-size-bytes-reject-threshold
,则该值将应用到 每个 匹配的地址。指定这个值 并不意味着 所有匹配地址 的总大小 限制为max-size-bytes-reject-threshold
的值。
在前面的示例中,当发送到地址 my.amqp.blocking.address
的消息超过 300000 字节时,代理开始阻止来自 AMQP producer 的进一步消息。