请解释ActiveMQ中的持久化订阅和非持久化订阅。

八股文_消息队列基础面试题 0 113

参考回答：

在ActiveMQ中，持久化订阅和非持久化订阅是两种不同的消息订阅方式，主要区别在于消息在消费者不在线时是否能够被保存。

持久化订阅（Persistent Subscription）：
持久化订阅是指当消费者订阅一个主题时，ActiveMQ会保存未消费的消息，直到消费者恢复并确认消费。这意味着即使消费者在一段时间内断开连接，ActiveMQ仍会保存消息，确保消息不丢失。
非持久化订阅（Non-Persistent Subscription）：
非持久化订阅是指当消费者订阅一个主题时，ActiveMQ不会保存消息。如果消费者在未连接期间错过了某条消息，那么该消息将丢失。非持久化订阅适用于对消息丢失容忍度较高的场景。

详细讲解与拓展：

1. 持久化订阅（Persistent Subscription）：

持久化订阅确保在消费者掉线或网络故障的情况下，未消费的消息会被保存在ActiveMQ的持久化存储中（如磁盘），并且在消费者重新连接时，这些消息会继续发送给消费者。

作用：
– 消息不丢失：即使消费者断开连接，消息也会被保存并且在消费者恢复时继续传送，确保消息不会丢失。
– 适用场景：持久化订阅非常适用于对消息可靠性要求高的场景，例如金融、订单处理、支付系统等，确保关键消息不会丢失。

举个例子：
假设有一个库存系统，当系统订阅了一个主题order-topic，如果库存系统正在处理其他请求并且无法及时消费order-topic中的消息，ActiveMQ会在磁盘中保存这些消息，直到库存系统恢复并连接到消息队列，然后继续将消息传递给它。

配置方法：
– 在消费者端创建订阅时，指定消息的持久化选项，确保每个消息在生产者发送时都标记为持久化。
– ActiveMQ会将这些消息存储在持久化存储中，如数据库或磁盘。

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <policyEntry topic=">" producerFlowControl="true" memoryLimit="1gb" persistent="true"/>
    </policyEntries>
  </policyMap>
</destinationPolicy>

2. 非持久化订阅（Non-Persistent Subscription）：

非持久化订阅是指当消费者订阅某个主题时，如果消费者离线或无法及时消费消息，ActiveMQ不会保存这些消息。未被及时消费的消息会在消息过期或消费者断开连接时丢失。

作用：
– 提高性能：非持久化订阅不需要存储消息，因此能减少存储和I/O操作，适用于对实时性要求较高的场景。
– 适用场景：适合于消息处理不重要或可以容忍消息丢失的应用场景，如实时日志收集、状态通知等。

举个例子：
假设有一个日志监控系统，消费者订阅了一个log-topic，该系统对消息的实时性要求非常高，但是并不关心日志是否在消费者离线时丢失。如果消费者离线，ActiveMQ不会保存消息，消费者只会收到连接时之后的消息。

配置方法：
– 在消费者端订阅时，不指定持久化选项，消息将默认为非持久化。
– 对于非持久化订阅，ActiveMQ不会将消息写入磁盘，而是直接将消息发送到消费者，消费者接收到后立即消费。

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <policyEntry topic=">" producerFlowControl="true" memoryLimit="1gb" persistent="false"/>
    </policyEntries>
  </policyMap>
</destinationPolicy>

3. 持久化与非持久化订阅的区别：

特性	持久化订阅	非持久化订阅
消息存储	未消费的消息会保存直到消费者恢复连接	未消费的消息会丢失
消费保障	确保消费者即使掉线也能收到未消费的消息	消费者丢失消息不可恢复
适用场景	需要保证消息不丢失的关键应用	对消息丢失容忍的应用
性能	消息存储在磁盘上，较为消耗存储和I/O	性能较好，不需要额外的存储开销

4. 如何选择持久化或非持久化订阅：

如果应用要求高可靠性，无法容忍消息丢失，应使用持久化订阅。例如，涉及金融交易、订单处理、支付等领域的应用。
如果应用不关心消息丢失，而更注重实时性和高吞吐量，使用非持久化订阅会更合适。比如，实时日志处理、事件通知等场景。

总结：

在RabbitMQ中，持久化订阅和非持久化订阅是两种主要的消息消费方式。持久化订阅确保即使消费者离线，未消费的消息也不会丢失，而非持久化订阅则提供了更高的性能，但在消费者断开连接时未消费的消息将丢失。选择哪种方式取决于系统对消息可靠性的需求。