RabbitMQ入门4—queue参数之durability

在 RabbitMQ 中，durability 参数用于控制队列是否能够在服务器重启后继续保持存在，以及队列中的消息是否能够持久化。了解这个参数有助于确保消息系统的可靠性和持久性。

Durability 参数的详细说明

durability 参数决定了 队列本身 是否会在 RabbitMQ 服务器重启后继续存在。它与消息的持久化是不同的概念，两者都需要正确配置才能保证消息的可靠持久存储。

1. 队列的持久性（Durability）

• 持久队列（Durable Queue）：
  • 当 durability 参数设置为 true 时，队列被标记为持久队列。
  • 效果：即使 RabbitMQ 服务器重启，这个队列仍然会存在，队列不会丢失。
• 非持久队列（Non-durable Queue）：
  • 当 durability 参数设置为 false 时，队列是非持久的。
  • 效果：RabbitMQ 服务器重启后，非持久队列会丢失，所有之前的队列定义和队列中的消息都不再存在。

2. 消息的持久性（Persistence）

• 消息的持久化 与队列的 durability 是两个不同的概念。即使队列是持久的，消息本身也必须设置为持久化，才能确保在 RabbitMQ 重启后消息仍然存在。
• 消息持久化需要通过在发布消息时将 deliveryMode 设置为持久化（2）来实现。

队列 durability 和消息持久化的组合

RabbitMQ 的消息持久化和队列持久性共同决定了系统的整体可靠性。以下是可能的组合和对应的行为：

1. 持久队列 + 持久消息：

   • 队列：队列在 RabbitMQ 重启后会继续存在。
   • 消息：队列中的消息也会在 RabbitMQ 重启后保留。
   • 使用场景：这是确保消息系统可靠性和持久化的最佳选择，适合需要高可靠性的生产环境。

2. 持久队列 + 非持久消息：

   • 队列：队列在 RabbitMQ 重启后会继续存在。
   • 消息：消息不会持久化，RabbitMQ 重启后消息会丢失。
   • 使用场景：适合需要队列长期存在，但消息本身不需要持久化的场景。

3. 非持久队列 + 持久消息：

   • 队列：队列在 RabbitMQ 重启后会丢失。
   • 消息：即使消息设置为持久化，由于队列已丢失，消息也无法恢复。
   • 使用场景：这种组合在大多数场景下没有实际意义，因为一旦队列丢失，持久化的消息也无从恢复。

4. 非持久队列 + 非持久消息：

   • 队列：队列在 RabbitMQ 重启后会丢失。
   • 消息：消息也不会持久化，RabbitMQ 重启后消息和队列都会丢失。
   • 使用场景：适用于消息临时性很强、不需要持久化的场景，比如临时数据或瞬时任务处理。

Go 语言中设置 durability

在使用 Go 语言的 amqp 包时，durability 参数通过 QueueDeclare 方法进行配置。以下是一个示例：

q, err := ch.QueueDeclare(
    "my_durable_queue", // 队列名称
    true,   // durable: 设置为 true 表示队列持久化
    false,  // delete when unused
    false,  // exclusive
    false,  // no-wait
    nil,    // arguments
)

在这个示例中，durable 设置为 true，表示队列是持久化的。如果 RabbitMQ 重启，这个队列将继续存在。

消息持久化示例

为了让消息也持久化，除了声明持久队列外，还需要在发布消息时设置消息的 DeliveryMode 为 2，如下所示：

err = ch.Publish(
    "",     // exchange
    q.Name, // routing key
    false,  // mandatory
    false,  // immediate
    amqp.Publishing{
        ContentType: "text/plain",
        Body:        []byte("Hello, RabbitMQ!"),
        DeliveryMode: amqp.Persistent, // 消息持久化
    })

• DeliveryMode: amqp.Persistent：设置消息的 deliveryMode 为 2，表示该消息是持久化的，RabbitMQ 重启后消息不会丢失。

持久队列 vs. 非持久队列

属性	持久队列（Durable Queue）	非持久队列（Non-durable Queue）
队列是否保留	是，RabbitMQ 重启后队列仍然存在	否，RabbitMQ 重启后队列会丢失
消息是否保留	仅在消息持久化时保留	RabbitMQ 重启后所有消息都会丢失
适用场景	需要队列和消息长时间存在的场景	短期或临时消息处理的场景

注意事项

1. 持久队列不等于持久消息：

   • durable 只保证队列的持久性，消息还需要单独设置为持久化（deliveryMode 设置为 2），才能确保 RabbitMQ 重启后消息仍然存在。

2. 持久化操作的性能开销：

   • 持久队列和持久消息虽然提供了高可靠性，但会带来一定的性能开销，因为消息和队列元数据都需要写入磁盘。

3. 持久化的队列和消息会增加磁盘使用：

   • RabbitMQ 需要将持久化队列和消息存储到磁盘，因此你需要确保磁盘空间足够。

总结

• durability：控制队列的持久性，决定了 RabbitMQ 重启后队列是否继续存在。
• 消息持久化：消息需要单独设置持久化，以确保 RabbitMQ 重启后消息不会丢失。
• 使用 持久队列 和 持久消息 是确保消息系统高可靠性的重要配置。

原文地址：https://blog.csdn.net/LONG_Yi_1994/article/details/142730583

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！