修改消息 - 压缩及更多

存在许多扩展点。它们允许您在消息发送到 RabbitMQ 之前或接收到消息后立即对消息执行一些处理。

如消息转换器中所示，其中一个扩展点在AmqpTemplate的convertAndReceive操作中，您可以在其中提供一个MessagePostProcessor。例如，在您的 POJO 转换后，MessagePostProcessor 允许您在Message上设置自定义头或属性。

从版本 1.4.2 开始，RabbitTemplate中添加了额外的扩展点 - setBeforePublishPostProcessors() 和 setAfterReceivePostProcessors()。前者允许在发送到 RabbitMQ 之前立即运行后处理器。当使用批处理（请参见批处理）时，此操作在批处理组装后和批处理发送前调用。后者在接收到消息后立即调用。

这些扩展点用于诸如压缩之类的功能，为此目的，提供了几种MessagePostProcessor实现。GZipPostProcessor、ZipPostProcessor 和 DeflaterPostProcessor 在发送前压缩消息，而 GUnzipPostProcessor、UnzipPostProcessor 和 InflaterPostProcessor 解压缩接收到的消息。

从版本 2.1.5 开始，GZipPostProcessor 可以配置 copyProperties = true 选项，以复制原始消息属性。默认情况下，为了性能原因，这些属性会被重用，并用压缩内容编码和可选的 MessageProperties.SPRING_AUTO_DECOMPRESS 头进行修改。如果您保留了对原始出站消息的引用，其属性也会改变。因此，如果您的应用程序保留了带有这些消息后处理器之一的出站消息的副本，请考虑开启 copyProperties 选项。

从版本 2.2.12 开始，您可以配置压缩后处理器在内容编码元素之间使用的分隔符。在 2.2.11 及之前的版本中，这被硬编码为 :，现在默认为 `, `。解压缩器将同时支持这两种分隔符。但是，如果您使用 2.3 或更高版本发布消息，并使用 2.2.11 或更早版本消费，则必须将压缩器上的 encodingDelimiter 属性设置为 :。当您的消费者升级到 2.2.11 或更高版本时，您可以恢复为默认的 `, `。

类似地，SimpleMessageListenerContainer 也具有 setAfterReceivePostProcessors() 方法，允许在容器接收到消息后执行解压缩。

从版本 2.1.4 开始，RabbitTemplate 中添加了 addBeforePublishPostProcessors() 和 addAfterReceivePostProcessors()，分别允许将新的后处理器附加到发布前和接收后后处理器列表中。还提供了移除后处理器的方法。类似地，AbstractMessageListenerContainer 也添加了 addAfterReceivePostProcessors() 和 removeAfterReceivePostProcessor() 方法。有关详细信息，请参阅 RabbitTemplate 和 AbstractMessageListenerContainer 的 Javadoc。