
在本地以独立模式运行Pulsar集群
对于本地开发和测试,你可以在机器上以独立模式运行Pulsar。独立模式在单个Java虚拟机(JVM)进程中运行所有组件。
第0步:先决条件
目前,Pulsar适用于64位的macOS和Linux系统。如果你想在Windows上运行Pulsar,请参阅在Docker中运行Pulsar。
同时,你需要安装适当的64位JRE/JDK版本。请参阅Pulsar运行时Java版本推荐。
第1步:下载Pulsar发行版
下载官方Apache Pulsar发行版:
1 2 3 4 5 6 7 8 9
| ``` wget https://archive.apache.org/dist/pulsar/pulsar-4.0.0/apache-pulsar-4.0.0-bin.tar.gz ``` ``` 下载完成后,解压缩tar文件: ```
|
tar xvfz apache-pulsar-4.0.0-bin.tar.gz
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
| ``` 在此快速入门的其余部分中,所有命令都是从发行版文件夹的根目录运行的,因此请切换到该目录: 通过执行以下命令列出内容: 创建了以下目录:  ### 第2步:启动Pulsar独立集群 运行此命令以启动Pulsar独立集群: 当Pulsar集群启动时,会创建以下目录:  提示: - 要将服务作为后台进程运行,你可以使用 `bin/pulsar-daemon start standalone` 命令。更多信息,请参阅pulsar-daemon。 - 当你启动Pulsar集群时,会创建 `public/default` 命名空间。此命名空间用于开发目的。所有Pulsar主题都在命名空间内管理。更多信息,请参阅命名空间和主题。 ### 第3步:创建主题 Pulsar将消息存储在主题中。即使Pulsar可以在引用主题时自动创建它们,最好在使用它们之前显式创建主题。 要创建新主题,请运行此命令: ```
|
bin/pulsar-admin topics create persistent://public/default/my-topic
1 2 3 4 5 6 7 8 9 10 11 12
| ``` ### 第4步:向主题写入消息 你可以使用 `pulsar` 命令行工具向主题写入消息。这对于实验很有用,但实际上你会在应用程序代码中使用Producer API,或者使用Pulsar IO连接器从其他系统拉取数据到Pulsar。 运行此命令以产生消息: ```
|
bin/pulsar-client produce my-topic --messages ‘Hello Pulsar!’
1 2 3 4 5 6 7 8
| ``` ### 第5步:从主题读取消息 现在一些消息已经被写入主题,运行此命令以启动消费者并读取这些消息: ```
|
bin/pulsar-client consume my-topic -s ‘my-subscription’ -p Earliest -n 0
1 2 3 4 5 6 7 8 9 10 11 12
| ``` Earliest意味着从最早的未消费消息开始消费。 `-n` 配置要消费的消息数量,0表示永远消费。 和之前一样,这对于实验消息很有用,但实际上你会在应用程序代码中使用Consumer API,或者使用Pulsar IO连接器从Pulsar读取数据并推送到其他系统。 你将看到之前步骤中产生的消息: ```
|
----- got message -----
key:[null], properties:[], content:Hello Pulsar!
1 2 3 4 5 6 7 8 9 10 11 12
| ``` ### 第6步:写入更多消息 保留上一步中的消费命令正在运行。如果你已经关闭了它,只需重新运行。 现在打开一个新的终端窗口并产生更多消息。默认的消息分隔符是 `,` : ```
|
bin/pulsar-client produce my-topic --messages “$(seq -s, -f ‘Message NO.%g’ 1 10)”
注意它们几乎立即在消费者终端中显示。
第7步:停止Pulsar集群
完成操作后,你可以关闭Pulsar集群。在启动集群的终端窗口中按
Ctrl-C
。
