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
- 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:8080pulsar://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;
}複製程式碼