暗无天日
·
订阅语义与 Ack 边界：Pulsar 消息投递的设计逻辑
内容提要
Pulsar 是一个分布式消息平台，设计上将消息路由与存储分开，提供独占、共享、主备和按键共享四种订阅语义，适应不同场景。消费者通过 ack 机制确认消息处理，支持累积确认和事务性确认。Pulsar 的 cursor 机制确保消费者掉队时消息不丢失，允许不同消费速度的订阅互不干扰。这些设计使 Pulsar 在灵活性和控制上优于其他消息中间件。
关键要点
-
Pulsar 是一个分布式消息平台，设计上将消息路由与存储分开。
-
Pulsar 提供四种订阅语义：独占、共享、主备和按键共享，适应不同场景。
-
消费者通过 ack 机制确认消息处理，支持累积确认和事务性确认。
-
Pulsar 的 cursor 机制确保消费者掉队时消息不丢失，允许不同消费速度的订阅互不干扰。
-
Pulsar 的设计使其在灵活性和控制上优于其他消息中间件。
延伸解读
Pulsar 的架构优势
Pulsar 将消息路由和存储分开，这种设计使得在高流量时可以独立扩展 broker，而在数据堆积时则可以增加存储节点。这种灵活性在处理不同负载时显得尤为重要，避免了其他系统中计算能力与存储容量的相互制约。
多样化的订阅语义
Pulsar 提供四种订阅语义，适应不同的应用场景。比如，独占订阅适合需要严格顺序的场景，而共享订阅则追求高吞吐量。用户在选择时应根据具体需求，权衡消息顺序与处理效率之间的关系。
Ack 机制的影响
Pulsar 的 ack 机制确保消息处理的可靠性，但也带来了重复数据的风险。开发者需确保处理逻辑的幂等性，以避免因消息重复投递而导致的数据不一致。理解这一点对于设计高可用的系统至关重要。
消费者掉队的处理
Pulsar 的 cursor 机制允许每个订阅独立维护消费位置，这意味着不同消费速度的消费者不会互相影响。这一设计在处理实时与离线任务时尤为重要，确保了消息不会因慢消费者的掉队而丢失。
延伸问答
Pulsar 的消息路由和存储是如何设计的？
Pulsar 将消息路由和存储分开，broker 负责消息接收和路由，而 BookKeeper 负责消息持久化。
Pulsar 提供了哪些订阅语义？
Pulsar 提供四种订阅语义：独占、共享、主备和按键共享，适应不同的使用场景。
Pulsar 的 ack 机制是如何工作的？
消费者通过 ack 机制确认消息处理，处理成功后发送 ack，处理失败则发送 negative ack，允许 broker 重新投递消息。
Pulsar 的 cursor 机制有什么作用？
Pulsar 的 cursor 机制确保消费者掉队时消息不丢失，允许消费者从最后一次 ack 的位置继续消费。
Pulsar 的四种订阅语义适合哪些场景？
独占适合顺序敏感场景，共享适合无状态处理，主备适合高可用场景，按键共享适合有状态处理的并行扩展。
Pulsar 如何处理消费者的处理速度差异？
Pulsar 允许不同消费速度的订阅互不干扰，每个订阅有独立的 cursor，确保慢消费者不会影响快消费者。
