Apache Pulsar是一个分布式的消息发布/订阅传递平台,具有非常灵活的消息模型和一个直观的客户端API,具有多租户、高性能等优势。 Pulsar 最初由 Yahoo 开发,目前由 Apache 软件基金会管理。
Pulsar 采用 发布-订阅的设计模式(简称 pub-sub), 该设计模式中,producer 发布消息到 topic, Consumer 订阅 topic、处理发布的消息,并在处理完成后发送确认。
一旦创建订阅,即使 consumer 断开连接,Pulsar 仍然可以保存所有消息。 在 consumer 确认消息已处理成功后,才会删除消息。
单个 Pulsar 集群由以下三部分组成:
- 一个或者多个 broker 负责处理和负载均衡 producer 发出的消息,并将这些消息分派给 consumer;Broker 与 Pulsar 配置存储交互来处理相应的任务,并将消息存储在 BookKeeper 实例中(又称 bookies);Broker 依赖 ZooKeeper 集群处理特定的任务,等等。
- 包含一个或多个 bookie 的 BookKeeper 集群负责消息的持久化存储。
- 一个Zookeeper集群,用来处理多个Pulsar集群之间的协调任务。
本文暂时没有评论,来添加一个吧(●'◡'●)