?

在?最佳開源數(shù)據(jù)庫與數(shù)據(jù)分析平臺(tái)獎(jiǎng)?中，之前曾連續(xù)兩年入選的 Kafka 意外滑鐵盧落選，取而代之的是新興項(xiàng)目 Pulsar，Bossie Awards中對(duì) Pulsar 點(diǎn)評(píng)如下：“Pulsar 旨在取代 Apache Kafka 多年的主宰地位。Pulsar在很多情況下提供了比 Kafka 更快的吞吐量和更低的延遲，并為開發(fā)人員提供了一組兼容的 API，讓他們可以很輕松地從 Kafka 切換到 Pulsar。Pulsar 的最大優(yōu)點(diǎn)在于它提供了比 Apache Kafka 更簡(jiǎn)單明了、更健壯的一系列操作功能，特別在解決可觀察性、地域復(fù)制和多租戶方面的問題。在運(yùn)行大型 Kafka 集群方面感覺有困難的企業(yè)可以考慮轉(zhuǎn)向使用 Pulsar。”

Pulsar中文文檔：https://pulsar.apache.org/docs/zh-CN/standalone/

1，系統(tǒng)環(huán)境

a，操作系統(tǒng)? ?CentOS Linux release 7.6.1810 (Core)? 64位，必須確保你的內(nèi)存是4G以上，雙核CPU！否則將無法新建默認(rèn)命名空間。

b，確保jdk環(huán)境已經(jīng)安裝，具體教程請(qǐng)看??CentOS7 shell腳本安裝jdk??

c，確保Python3和對(duì)應(yīng)的pip已經(jīng)安裝，具體教程請(qǐng)看?CentOS7 源碼編譯安裝Python3.5

2，執(zhí)行以下命令，啟動(dòng)Pulsar

wget https://archive.apache.org/dist/pulsar/pulsar-2.3.0/apache-pulsar-2.3.0-bin.tar.gz # 下載pulsar安裝包 tar xvfz apache-pulsar-2.3.0-bin.tar.gz # 解壓安裝包 cd apache-pulsar-2.3.0 # 打開pulsar目錄 bin/pulsar standalone # 啟動(dòng)單機(jī)pulsar bin/pulsar-client produce my-topic --messages "hello-pulsar" # 發(fā)送一條消息

如圖，消息已經(jīng)成功發(fā)送?

3，執(zhí)行命令? ? ?pip3 install pulsar-client==2.3.1

4，創(chuàng)建Pulsar消費(fèi)者監(jiān)聽python3程序 consumer.py

import pulsar client = pulsar.Client('pulsar://localhost:6650') consumer = client.subscribe('my-topic2', 'my-subscription') while True:msg = consumer.receive()try:print("Received message '{}' id='{}'".format(msg.data(), msg.message_id()))consumer.acknowledge(msg)except:consumer.negative_acknowledge(msg) client.close()

?運(yùn)行? python3 consumer.py

5，?創(chuàng)建Pulsar生產(chǎn)者python3程序 producer.py

import pulsar client = pulsar.Client('pulsar://localhost:6650') producer = client.create_producer('my-topic2') for i in range(10):producer.send(('Hello-%d' % i).encode('utf-8')) client.close()

?運(yùn)行? ?python3 producer.py

看到 消費(fèi)者監(jiān)聽界面，出現(xiàn)如下消息

?

總結(jié)

以上是生活随笔為你收集整理的CentOS7 搭建Pulsar 消息队列环境，CentOS（Linux）部署Pulsar，亲测成功，以及Python操作Pulsar实例驱动的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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