介紹：

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

官網(wǎng)：

https://pulsar.apache.org/

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

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

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

1.Being acknowledged individually. With individual acknowledgment, the consumer acknowledges each message and sends an acknowledgment request to the broker.
被單獨(dú)承認(rèn)。通過(guò)單獨(dú)的確認(rèn)，消費(fèi)者確認(rèn)每條消息，并向代理發(fā)送確認(rèn)請(qǐng)求。
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.
被累計(jì)承認(rèn)的。對(duì)于累積確認(rèn)，消費(fèi)者只確認(rèn)其接收到的最后一條消息。流中直到（包括）所提供消息的所有消息都不會(huì)重新傳遞給該消費(fèi)者。

兩種方式的API確定（單條，累計(jì)）

consumer.acknowledge(msg);

consumer.acknowledgeCumulative(msg);

值的注意的是：
累積確認(rèn)不能在共享訂閱類型中使用，因?yàn)楣蚕碛嗛嗩愋蜕婕坝袡?quán)訪問(wèn)同一訂閱的多個(gè)使用者。在共享訂閱類型中，消息是單獨(dú)確認(rèn)的。

部署安裝講解:

pulsar支持單節(jié)點(diǎn)以及集群模式都可以，支持使用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.
在該圖中，連接客戶端需要使用單個(gè)URL與Pulsar集群進(jìn)行通信。在這種情況下，pulser-cluster.ame.com對(duì)所有消息處理代理進(jìn)行了抽象。Pulsar消息代理(broker經(jīng)紀(jì)人)與BookKeeper博彩公司(bookie)一起在機(jī)器上運(yùn)行；而經(jīng)紀(jì)人和博彩公司則依賴ZooKeeper。

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

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

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

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

安裝單機(jī)版本測(cè)試（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.開(kāi)兩個(gè)窗口在pulsar安裝目錄下的bin目錄執(zhí)行生產(chǎn)和消費(fèi)操作：
生產(chǎn)者

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

消費(fèi)者

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

先投遞消息，后消費(fèi)，日志打印消費(fèi)成功。