Apache Pulsar是一個開源的分布式pub-sub消息傳遞系統(tǒng)，最初由Yahoo創(chuàng)建，并且是Apache Software Foundation的一部分 。

Pulsar是用于服務器到服務器消息傳遞的多租戶高性能解決方案。

脈沖星的主要功能包括[4]：

• 對Pulsar實例中的多個集群的本地支持，跨集群的消息無縫地域復制
• 極低的發(fā)布和端到端延遲
• 無縫擴展可擴展到超過一百萬個主題
• 一個帶有Java ， Python和C ++綁定的簡單客戶端API
• 主題的多種訂閱模式 （ 獨占 ， 共享和故障轉(zhuǎn)移 ）
• 由Apache BookKeeper提供的持久性消息存儲保證了消息的傳遞

架構(gòu)概述

在最高級別，一個Pulsar實例由一個或多個Pulsar簇組成。 一個實例中的集群可以在它們之間復制數(shù)據(jù)[4]。

下圖提供了一個脈沖星團的圖示：

與Apache Kafka的Pulsar比較

下表列出了Apache Pulsar和Apache Kafka [5]之間的異同：

卡夫卡 脈沖星

概念	生產(chǎn)者主題消費者組消費者	生產(chǎn)者主題訂閱消費者
消費	更側(cè)重于流，分區(qū)上的獨占消息傳遞。 沒有共享的消費。	統(tǒng)一消息傳遞模型和API。 通過獨家故障轉(zhuǎn)移訂閱進行流式傳輸 通過共享訂閱排隊
king	簡單的膠印管理 在Kafka 0.8之前，偏移量存儲在ZooKeeper中 在Kafka 0.8之后，偏移量存儲在偏移量主題上	統(tǒng)一消息傳遞模型和API。 通過獨家故障轉(zhuǎn)移訂閱進行流式傳輸 通過共享訂閱排隊
保留	郵件將根據(jù)保留時間被刪除。 如果使用者在保留期之前沒有閱讀郵件，它將丟失數(shù)據(jù)。	僅在所有訂閱使用完郵件后，郵件才會被刪除。 即使訂閱的使用者長時間停機也不會造成數(shù)據(jù)丟失。 即使所有訂閱都使用了郵件，郵件也可以保留配置的保留期限。
TTL	不支持TTL	支持消息TTL

結(jié)論

Apache Pulsar是由Apache Incubator PMC贊助的Apache Software Foundation（ASF） [3]進行孵化的一項工作。 由于其獨特的功能，它似乎可以替代Apache Kafka。

資源：

[1] https://pulsar.apache.org/ [2] https://developer.yahoo.com/open-source/ [3] https://apache.org / [4] https：// pulsar。 apache.org/docs/latest/getting-started/ConceptsAndArchitecture/ [5] https://streaml.io/blog/pulsar-streaming-queuing/

翻譯自: https://www.javacodegeeks.com/2017/12/apache-pulsar-distributed-pub-sub-messaging-system.html

總結(jié)

以上是生活随笔為你收集整理的Apache Pulsar：分布式发布订阅消息系统的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。