RabbitMQ支持多种消息压缩方式，包括插件内置压缩（推荐，简化流程）和自定义代码压缩（灵活，需手动处理）。以下是Linux系统下的具体操作步骤：
确保已安装RabbitMQ（版本≥3.8，推荐3.11及以上）及对应开发工具（如gcc、make）。可通过rabbitmqctl status验证RabbitMQ服务状态。
RabbitMQ自带rabbitmq_message_compression插件，支持gzip、zlib等算法，无需修改代码即可自动处理压缩与解压。
在Linux终端执行以下命令激活插件：
rabbitmq-plugins enable rabbitmq_message_compression 执行后，插件会自动加载并生效。
通过以下命令确认插件已成功加载：
rabbitmq-plugins list 输出中应包含rabbitmq_message_compression [enabled]字样。
使用编程语言（如Python）发送消息时，通过properties参数指定压缩算法（以pika库为例）：
import pika import zlib # 连接RabbitMQ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() # 声明队列 channel.queue_declare(queue='compressed_queue') # 原始消息 message = "This is a large message that needs compression..." # 压缩消息（使用zlib算法） compressed_message = zlib.compress(message.encode('utf-8')) # 发送消息，指定compression参数 channel.basic_publish( exchange='', routing_key='compressed_queue', body=compressed_message, properties=pika.BasicProperties(compression='zlib') # 关键：声明压缩算法 ) print(" [x] Sent compressed message") connection.close() 说明：compression='zlib'告知RabbitMQ需用zlib算法压缩消息，插件会自动处理。
消费者无需手动解压，RabbitMQ会自动解压消息并传递给回调函数：
import pika import zlib def callback(ch, method, properties, body): # 自动解压（若生产者设置了compression参数） decompressed_message = zlib.decompress(body).decode('utf-8') print(f" [x] Received: {decompressed_message}") # 连接RabbitMQ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() # 声明队列 channel.queue_declare(queue='compressed_queue') # 设置QoS（可选，优化消费性能） channel.basic_qos(prefetch_count=1) # 开始消费 channel.basic_consume(queue='compressed_queue', on_message_callback=callback) print(' [*] Waiting for messages. To exit press CTRL+C') channel.start_consuming() 说明：zlib.decompress(body)用于解压消息，若生产者未设置compression参数，body为原始数据。
若需更灵活的压缩策略（如调整压缩级别、使用其他算法），可在生产者端手动压缩消息，消费者端手动解压。
以Python为例，使用gzip库（支持更高压缩比）：
import pika import gzip # 连接RabbitMQ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() # 声明队列 channel.queue_declare(queue='custom_compressed_queue') # 原始消息 message = '{"user": "Bob", "action": "upload", "data": "large file..."}' # 手动压缩（gzip算法，level=6为默认压缩级别） compressed_message = gzip.compress(message.encode('utf-8')) # 发送消息，设置content_encoding标识 channel.basic_publish( exchange='', routing_key='custom_compressed_queue', body=compressed_message, properties=pika.BasicProperties( content_encoding='gzip', # 告知消费者编码方式 content_type='application/json' # 可选：声明消息类型 ) ) print(" [x] Sent custom compressed message") connection.close() 说明：gzip.compress()用于压缩，content_encoding='gzip'需与消费者端解压逻辑一致。
import pika import gzip def callback(ch, method, properties, body): # 手动解压（需与生产者压缩算法一致） if properties.content_encoding == 'gzip': decompressed_message = gzip.decompress(body).decode('utf-8') else: decompressed_message = body.decode('utf-8') print(f" [x] Received: {decompressed_message}") # 连接RabbitMQ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() # 声明队列 channel.queue_declare(queue='custom_compressed_queue') # 设置QoS channel.basic_qos(prefetch_count=1) # 开始消费 channel.basic_consume(queue='custom_compressed_queue', on_message_callback=callback) print(' [*] Waiting for messages. To exit press CTRL+C') channel.start_consuming() 说明：通过properties.content_encoding判断消息是否需要解压，确保兼容性。
若需全局默认压缩策略，可修改RabbitMQ配置文件（rabbitmq.conf），添加以下内容：
# 使用LZ4算法（默认压缩级别为1，范围1-12，数字越大压缩比越高） message_compressor = lz4 message_compressor_options = [{'compression_level': 3}] # 或使用Zstandard算法（推荐，压缩比优于LZ4） # message_compressor = zstd # message_compressor_options = [{'compression_level': 3}] 修改后需重启RabbitMQ使配置生效：
systemctl restart rabbitmq-server 说明：全局配置会应用于所有队列，优先级低于代码中的compression参数。
gzip压缩比高但速度慢，zlib速度适中，lz4速度快但压缩比低，zstd兼顾速度与压缩比（推荐）。zlib.error），处理损坏的压缩数据。通过以上步骤，即可在Linux环境下实现RabbitMQ消息压缩，有效减少网络带宽占用和存储成本。
