介紹：

PulsarMQ 現(xiàn)托管于apache Apache 軟件基金會頂級項目，2016年由雅虎公司開源的分布式多租戶消息中間件 ，是下一代云原生分布式消息流平臺，集消息、存儲、輕量化函數(shù)計算為一體，采用計算與存儲分離架構(gòu)設(shè)計，支持多租戶、持久化存儲、跨區(qū)域復(fù)制、具有強一致性、高吞吐、低延遲及高可擴展性等流數(shù)據(jù)存儲特性。支持 Pub/Sub 模型和消息隊列模型。

官網(wǎng)：

https://pulsar.apache.org/

Pulsar的關(guān)鍵特性如下：

1.云原生架構(gòu)（計算與存儲分離），無縫支持跨集群復(fù)制
2.比kafka更高的吞吐量和低延遲
3.無縫支持上百萬個topics
4.支持多種消息訂閱模式 (exclusive & shared & failover)
5.通過持久化存儲BookKeeper保障消息的傳遞
6.輕量級Serverless計算框架Pulsar Functions提供了流式數(shù)據(jù)處理能力。
7.提供分層存儲能力，釋放BookKeeper的空間：將老數(shù)據(jù)or長期不用的數(shù)據(jù)放到AWS S3等

消息ACK確定機制:
兩種主要是由于pulsar單條，也可以批處理。

1.Being acknowledged individually. With individual acknowledgment, the consumer acknowledges each message and sends an acknowledgment request to the broker.
被單獨承認。通過單獨的確認，消費者確認每條消息，并向代理發(fā)送確認請求。
2.Being acknowledged cumulatively. With cumulative acknowledgment, the consumer only acknowledges the last message it received. All messages in the stream up to (and including) the provided message are not redelivered to that consumer.
被累計承認的。對于累積確認，消費者只確認其接收到的最后一條消息。流中直到（包括）所提供消息的所有消息都不會重新傳遞給該消費者。

兩種方式的API確定（單條，累計）

consumer.acknowledge(msg);

consumer.acknowledgeCumulative(msg);

值的注意的是：
累積確認不能在共享訂閱類型中使用，因為共享訂閱類型涉及有權(quán)訪問同一訂閱的多個使用者。在共享訂閱類型中，消息是單獨確認的。

部署安裝講解:

pulsar支持單節(jié)點以及集群模式都可以，支持使用docker或者k8s，以下是官網(wǎng)的經(jīng)典圖：

In this diagram, connecting clients need to communicate with the Pulsar cluster using a single URL. In this case, pulsar-cluster.acme.com abstracts over all of the message-handling brokers. Pulsar message brokers run on machines alongside BookKeeper bookies; brokers and bookies, in turn, rely on ZooKeeper.
在該圖中，連接客戶端需要使用單個URL與Pulsar集群進行通信。在這種情況下，pulser-cluster.ame.com對所有消息處理代理進行了抽象。Pulsar消息代理(broker經(jīng)紀人)與BookKeeper博彩公司(bookie)一起在機器上運行；而經(jīng)紀人和博彩公司則依賴ZooKeeper。

乍一看很復(fù)雜，怎么說呢，比起其他MQ確實是很復(fù)雜，且更加抽象化和組件化，一個完整的pulsar服務(wù)需要以上的支持。而zookeeper和broker，bookkeeper的聯(lián)系如下：

在 Pulsar 中，ZooKeeper 的作用是存儲 Pulsar 集群的元數(shù)據(jù)，例如租戶、命名空間、主題等信息。Pulsar Broker 則負責處理客戶端的請求，并將消息傳遞給相應(yīng)的 BookKeeper 副本進行持久化。而 BookKeeper Bookie 則是實際進行數(shù)據(jù)存儲和檢索操作的組件。
具體來說，當客戶端發(fā)送消息到 Pulsar Broker 時，Broker 會首先將消息寫入內(nèi)存緩沖區(qū)，并返回 Acknowledgment（ACK）給客戶端。然后，Broker 將消息異步地提交給 BookKeeper 進行持久化。BookKeeper 接收到消息后，會將其寫入磁盤，并返回 ACK 給 Broker。當 Broker 接收到來自大多數(shù)（通常是半數(shù)以上） BookKeeper 副本的 ACK 后，就會確認消息已經(jīng)成功持久化，并將其從內(nèi)存緩沖區(qū)中刪除。
在此過程中，ZooKeeper 負責管理 Pulsar 集群的元數(shù)據(jù)，例如 Broker 和 BookKeeper 的位置信息、租戶的配置信息等。Broker 和 BookKeeper 通過 ZooKeeper 進行注冊和發(fā)現(xiàn)，并獲取集群的配置信息。需要注意的是，Pulsar 支持多個 ZooKeeper 實例進行共享存儲，以提高集群的可伸縮性和可用性。

當然ZooKeeper 也是可替換的，可以換成一些其他的注冊中心，還有etcd,nacos等等取舍可看一下比較：

etcd、ZooKeeper 和 Nacos 都是分布式存儲和協(xié)調(diào)工具，用于管理和維護分布式系統(tǒng)中的元數(shù)據(jù)信息，例如配置信息、服務(wù)發(fā)現(xiàn)、任務(wù)調(diào)度等。它們各自有一些優(yōu)點和適用場景，下面進行簡要對比：
1)etcd：etcd 是一個高可用的鍵值存儲系統(tǒng)，支持分布式部署和數(shù)據(jù)復(fù)制，并且擁有以下特點：
簡單易用：API 設(shè)計清晰明了，操作簡單；
性能高效：讀寫性能均較優(yōu)；
可靠性高：支持多數(shù)派復(fù)制機制，保證數(shù)據(jù)的可靠性和一致性；
安全性好：支持 TLS 加密傳輸和訪問控制。
2)ZooKeeper：ZooKeeper 是一個分布式協(xié)調(diào)服務(wù)，提供共享配置管理和分布式鎖等功能，具有以下特點：
一致性高：采用 ZooKeeper Atomic Broadcast（ZAB）協(xié)議，可以保證分布式系統(tǒng)中各個節(jié)點間的數(shù)據(jù)一致性；
功能強大：提供了多種 API 和工具，支持分布式鎖、選舉、任務(wù)調(diào)度等常見的分布式應(yīng)用場景；
生態(tài)豐富：已經(jīng)被廣泛應(yīng)用于 Hadoop、Kafka、Pulsar 等開源項目和商業(yè)產(chǎn)品中。
3)Nacos：Nacos 是一個分布式的配置中心和服務(wù)發(fā)現(xiàn)平臺，旨在幫助企業(yè)實現(xiàn)微服務(wù)的構(gòu)建和管理，具有以下特點：
功能全面：支持服務(wù)注冊、配置管理、服務(wù)發(fā)現(xiàn)、流量管理等多個功能；
可擴展性好：支持集群部署和主從復(fù)制，可以提高系統(tǒng)的可用性和容錯性；
易用性強：提供了豐富的客戶端和工具，可以快速地接入和使用。
綜上所述，etcd 適合對性能要求較高的應(yīng)用場景；ZooKeeper 適合需要高一致性和更多功能的應(yīng)用場景；而 Nacos 則適合構(gòu)建和管理微服務(wù)架構(gòu)。選擇使用哪種工具應(yīng)該根據(jù)具體需求和場景進行綜合考慮，并進行權(quán)衡取舍。

安裝單機版本測試（Linux下）：

根據(jù)我們要使用的PulsarMQ版本選擇jdk,本案例使用3.0.0，故先先安裝jdk17，可參考帖子：https://blog.csdn.net/xtho62/article/details/131229216

1.下載

## 官方鏈接，如果直接shell中下載較慢，建議使用迅雷下載后傳上去
wget https://archive.apache.org/dist/pulsar/pulsar-3.0.0/apache-pulsar-3.0.0-bin.tar.gz

2.解壓安裝

mkdir /usr/local/pulsar
tar -zxvf apache-pulsar-3.0.0-bin.tar.gz -C pulsar/

3.開兩個窗口在pulsar安裝目錄下的bin目錄執(zhí)行生產(chǎn)和消費操作：
生產(chǎn)者

可以使用命令行客戶端生產(chǎn)消息、消費消息，執(zhí)行./pulsar-client produce my-topic --messages “hello-pulsar”，即往"my-topic"這個topic生產(chǎn)了一條消息，內(nèi)容是"hello-pulsar"。

消費者

執(zhí)行./pulsar-client consume my-topic -s “first-subscription”，即可從"my-topic"這個topic消費消息。生產(chǎn)者客戶端和消費者客戶端都會自動創(chuàng)建topic，如果操作的topic不存在的話

先投遞消息，后消費，日志打印消費成功。