java - RabbitMQ 消息属性

Question

我在 RabbitMQ 中有这样的代码:

byte[] rawBytes = serialize(trxEntities);    
byte[] zipped = rawBytes;  
if (shouldBeCompress) {  
zipped = compressor.compress(rawBytes);  
}  
BasicProperties persistentBasic = MessageProperties.PERSISTENT_BASIC;  
channel.basicPublish("", queueName, persistentBasic, zipped);  

如您所见，我的一些消息应该被压缩，而另一些则不应该。
有什么方法可以设置任何属性来告诉消费者“嘿!这是一条压缩消息”？

附言。 “com.rabbitmq.client.AMQP.BasicProperties.BasicProperties(..., Map headers, ...)”对我有帮助吗？我的意思是我可以在 BasicProperties.header 中设置任何参数吗？

Answer 1

我认为您可以在页眉中添加您喜欢的任何内容。但是，有一个名为“contentEncoding”的字段，我认为它更适合这种情况。您可以只在该字段中输入“gzip”、“deflate”或压缩算法，查看此页面以了解为 HTTP 定义的那些编码:http://www.w3.org/Protocols/rfc2616/rfc2616-sec3.html#sec3.5