一、Apache Pulsar的Local模式构建

1.1、启动服务

Standalone Local单机本地模式, 是pulsar最简单的安装方式, 此种方式仅适用于测试学习使用, 并无法作为生产环境中使用。

下载Apache Pulsar2.10

服务器系统要求:

Currently, Pulsar is available for 64-bit macOS, Linux, and Windows. To use Pulsar, you need to install 64-bit JRE/JDK 8 or

later versions. (目前，Pulsar可用于64位macOS、Linux和Windows。使用Pulsar需要安装64位JRE/JDK 8或更高版本。)

  • 将安装包上传到服务上
  • 解压



  • 进入bin目录



  • 启动pulsar



出现以下内容后，则单机版启动成功。



1.2、pulsar-client 测试消息发布订阅

首先我们先通过pulsar-client启动消费者





我们打开一个新的客户端页面，在启动服务生产者





生产者发送消息成功，在看下消费者端能否接收到消息。



可以看到消费者端已经消费生产者发送的"hello pulsar"。

二、Pulsar Manager 可视化监控

这里pulsar Manager我们是采用Docker 方式部署，所以我们直接使用Docker命里运行即可。



运行完成后，我们需要在宿主机上执行以下命令，为pulsar Manager创建用户；

这里的用户名是"admin",密码:"apachepulsar",可以根据自己的实际情况配置。

配置完用户名和密码后，我们在浏览器中访问：http://ip:9527/,这里可以根据自己的ip修改。



登录成功后，我们配置下集群的信息：





注意配置服务url时，需配置可以访问到集群的IP，最好不要使用localhost或127.0.0.1，我这里配置的是我的公网IP。

配置完成后，点击localhost,可以进入集群信息内部查看集群内容。



My-top就是我们刚刚测试的队列。

三、Golang实现pulsar生产消费

3.1、引入golang的pulsar包



3.2、pulsar消费者

我们看下消费者完整代码：

这里比较简单，只是写个demo。后续可以对消费者代码进行完善。

3.3、生产者代码

注意：如需使用延时队列，需在消费者端设置消费模式为"pulsar.Shared"，否则无效。

我们看下结果：



看下消费者消费记录