Pulsar在本地以独立模式运行

在本地以独立模式运行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
  
```

在此快速入门的其余部分中,所有命令都是从发行版文件夹的根目录运行的,因此请切换到该目录:

通过执行以下命令列出内容:

创建了以下目录:

![](/images/blog/1742927618852_image_1.png)

### 第2步:启动Pulsar独立集群

运行此命令以启动Pulsar独立集群:

当Pulsar集群启动时,会创建以下目录:

![](/images/blog/1742927618852_image_2.png)

提示:

-
要将服务作为后台进程运行,你可以使用
`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

江达小记