RabbitMQ如何保证消息可靠性，看完这篇文章佬会有新的理解

RabbitMQ 保证消息可靠性的方法主要包括以下几个方面：

1. 持久化：将队列、交换器和消息都标记为持久化（durable），这样可以保证消息不会因服务器宕机而丢失。
2. 消息确认：生产者发送消息后，等待消息接收方确认收到消息。如果未收到确认，可以重发。
3. 消息持久化与存储：RabbitMQ 会将所有消息存储在磁盘上，以确保消息在服务器重启后不会丢失。
4. 高可用性策略：通过镜像队列（ha-policy）实现高可用性，确保在RabbitMQ服务器宕机时，消息不会丢失。
5. 超时和重试机制：设置合理的网络超时时间，并实现重试逻辑，确保网络问题不会导致消息丢失。

以下是使用 RabbitMQ 的 Python 代码示例，演示如何确保消息的可靠性：

import pika
 
# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
# 声明队列为持久化
channel.queue_declare(queue='hello', durable=True)
 
# 发送消息
channel.basic_publish(
    exchange='',
    routing_key='hello',
    body='Hello World!',
    properties=pika.BasicProperties(
        delivery_mode=2,  # 将消息标记为持久化
    ),
)
 
# 定义一个回调函数来处理消息确认
def callback(ch, method, properties, body):
    print(f"Received {body}")
 
# 消费消息，并等待消息者确认
channel.basic_consume(
    queue='hello',
    on_message_callback=callback,
    auto_ack=False,  # 关闭自动确认
)
 
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

在这个示例中，队列被声明为持久化，消息也被设置为持久化，并且消费者在处理完消息后需要手动发送确认信号给RabbitMQ。这样可以确保消息至少被消费者处理一次，从而提高消息的可靠性。