1. 程式人生 > >Pulsar本地單機(偽)叢集 (裸機安裝與docker方式安裝) 2.2.0

Pulsar本地單機(偽)叢集 (裸機安裝與docker方式安裝) 2.2.0

為了本地開發和測試,我們可以建立一個偽叢集。偽叢集一樣包含 Pulsar broker, ZooKeeper, BookKeeper.

生產環境

如果想執行一個完整的生產pulsar安裝, 檢視http://pulsar.apache.org/docs/en/deploy-bare-metal

手動安裝Pulsar偽叢集

系統要求:

Pulsar當前可以執行在Macos與linux系統,而且必須安裝java8.

安裝:

通過以下方法下載二進位制包

  • 從Apache官網的映象下載:

    • https://archive.apache.org/dist/pulsar/pulsar-2.2.0/apache-pulsar-2.2.0-bin.tar.gz
  • 從Pulsar官網下載頁下載 pulsar.apache.org/download/

  • 從Pulsar的github釋出頁下載:https://github.com/apache/pulsar/releases/tag/v2.2.0

  • 使用wget:

    $ wget https://archive.apache.org/dist/pulsar/pulsar-2.2.0/apache-pulsar-2.2.0-bin.tar.gz
    Copy複製程式碼

下載完成後解壓到自定目錄:

$ tar xvfz apache-pulsar-2.2.0-bin.tar.gz
$ cd apache-pulsar-2.2.0
複製程式碼

包內都包含哪些內容:

二進位制包最初包含以下目錄:

Directory Contains
bin Pulsar的命令列工具, 如 pulsar 和 pulsar-admin
conf Pulsar的配置檔案, 包含配置 broker configuration, ZooKeeper configuration, 等
examples 一個關於Pulsar Functions的例子
lib Pulsar所依賴的一些jar包
licenses 一些許可檔案

一旦執行Pulsar,一下資料夾會被建立:

Directory Contains
data ZooKeeper and BookKeeper 資料儲存目錄
instances Pulsar Functions 需要的目錄
logs 安裝時建立的一些日誌

安裝內建的聯結器(connector):

從2.1.0-incubating開始,connector單獨釋出。如果想要使用需要單獨下載。通過以下方式下載

  • 從Apache映象下載:

  • 從Pulsar 下載頁下載:http://pulsar.apache.org/download

  • 從 Pulsar的github的釋出頁下載:https://github.com/apache/pulsar/releases/latest 

  • 使用 wget:

    $ wget https://archive.apache.org/dist/pulsar/pulsar-2.2.0/apache-pulsar-io-connectors-2.2.0-bin.tar.gz
    複製程式碼

一旦下載完成,解壓下載的壓縮包,並把下載的東西拷貝到 pulsar 資料夾下的connectors下(如果沒有此目錄,可以直接建立):

/pulsar

         /bin

         /lib

          /conf

          /data

          /connectors

$ tar xvfz /path/to/apache-pulsar-io-connectors-2.2.0-bin.tar.gz

// you will find a directory named `apache-pulsar-io-connectors-2.2.0` in the pulsar directory
// then copy the connectors

$ cd apache-pulsar-io-connectors-2.2.0/connectors connectors

$ ls connectors
pulsar-io-aerospike-2.2.0.nar
pulsar-io-cassandra-2.2.0.nar
pulsar-io-kafka-2.2.0.nar
pulsar-io-kinesis-2.2.0.nar
pulsar-io-rabbitmq-2.2.0.nar
pulsar-io-twitter-2.2.0.nar
...
Copy複製程式碼


啟動:

進入我們剛才解壓pulsar/bin/ 資料夾下,執行如下的命令

$ bin/pulsar standalone
複製程式碼

如果正常啟動會看到類似下面的資訊:

2017-06-01 14:46:29,192 - INFO  - [main:[email protected]] - Global Zookeeper cache started
2017-06-01 14:46:29,192 - INFO  - [main:[email protected]] - Authentication is disabled
2017-06-01 14:46:29,192 - INFO  - [main:[email protected]] - Pulsar WebSocket Service started
Copy複製程式碼


使用Docker安裝pulsar的偽叢集

我們也可以通過docker安裝一個pulsar的偽叢集

docker run -it -p 80:80 -p 8080:8080 -p 6650:6650 apachepulsar/pulsar-standalone
Copy複製程式碼

幾個埠的作用:

  • 80: pulsar的儀表板
  • 8080: pulsar通過http對外提供服務的埠
  • 6650: pulsar通過二進位制協議對完提供的埠

啟動完成後,我們通過瀏覽器就可以訪問http://localhost .

測試Pulsar的叢集

Pulsar提供了一個命令列的 pulsar-client工具,下面的語句使用pulsar-client 往my-topic傳送一條訊息:

$ bin/pulsar-client produce my-topic --messages "hello-pulsar"複製程式碼

如果傳送成功,我們會看到下面的一條訊息

13:09:39.356 [main] INFO  org.apache.pulsar.client.cli.PulsarClientTool - 1 messages successfully produced

複製程式碼

不需要顯式地建立新主題

也許你注意到了,我們傳送訊息之前並沒有事前建立my-topic。如果我們往一個topic傳送訊息,如果topic事前並沒有建立,Pulsar會自動為我們建立。

使用Pulsar的客戶端

叢集建立後我們可以通過Pulsar提供的客戶端(java, python, c ++, go 等)與 Pulsar互動了

  • http://localhost:8080
  • pulsar://localhost:6650

Java 客戶端生產者的例子:

String localClusterUrl = "pulsar://localhost:6650";

PulsarClient client = PulsarClient.builder().serviceURL(localClusterUrl).build();
Producer<byte[]> producer = client.newProducer().topic("my-topic").create();

複製程式碼

Python 生產者的例子:

import pulsar

client = pulsar.Client('pulsar://localhost:6650')
producer = client.create_producer('my-topic')

複製程式碼

C++ 生產者例子:

Client client("pulsar://localhost:6650");
Producer producer;
Result result = client.createProducer("my-topic", producer);
if (result != ResultOk) {
    LOG_ERROR("Error creating producer: " << result);
    return -1;
}複製程式碼