【ApachePulsar】ApachePulsar单机环境及Go语⾔开发环境
搭建
0x01 简介
0x02 Apache Pulsar单机版环境搭建
1、前提条件
Pulsar⽬前仅仅⽀持MacOS和Linux系统,不⽀持Windows系统。并且要求系统中安装了Java 8环境。
2、系统环境
我们以CentOS系统作为搭建环境,系统为CentOS7.2。
3、搭建步骤
由于我本地环境的限制,所以本⽂中所有的⽂件下载都是⾸先在Windows系统中下载,然后⼿动拷贝到Linux服务器上的。
此处,我们点击下载第⼀个,即⼆进制发布。然后拷贝到CentOS服务器上,并解压该压缩包,结果如下:
进⼊对应解压得到的⽂件夹,该⽂件夹下⽂件如下:
进⼊conf⽂件夹下,并使⽤vi或vim打开⽂件f,修改⾥⾯的webServiceUrl和brokerServiceUrl
字段中对应的IP为该服务器IP,如下所⽰(其中涂改部分为服务器IP):
保存并退出,然后进⼊到bin⽬录下,以后台运⾏模式启动pulsar服务,如下:
由于之前我已经启动了后台服务,所以上图中提⽰已经在运⾏该服务。
如此简单,pulsar单机版就这么顺利的运⾏起来了。然⽽,如何验证是否正常启动了呢?⼀种是通过查看⽇志⽂件来确保正常启动,此处略去这种⽅式。直接使⽤指令来验证是否正常启动:
(1)创建消费者consumer
指令:
$ ./pulsar-client consume -s "my-subscription" my-topic
含义:创建⼀个consumer,该consumer订阅的topic名称为my-topic,本订阅名称为my-subscription。创建成功会打印如下信息(只截图了部分信息):go语言安装教程
创建成功后,该consumer就处于等待接收消息状态。
(2)创建⽣产者producer
$ ./pulsar-client produce my-topic --messages "test message from producer"
含义:创建⼀个producer,该producer对应的topic名称为my-topic(与上⾯创建的consumer订阅的topic相同),发送的消息由--messages指定,此处内容为“test message from producer”。创建成功会打印如下信息(只截图了部分信息):
此时,我们会在1中创建的consumer端接收到producer发送的消息,如下图:
0x03 Pulsar Go语⾔开发环境搭建
前提条件:开发电脑本地或Linux服务器中已经安装好了Go开发环境。
在Windows系统中开发Pulsar时需要安装GCC编译环境,所以需要安装MinGW,由于环境限制,这⾥我⽆法下载MinGW,所以就直接在CentOS系统中搭建开发环境了。
当前版本(2.1.0-incubating)下,Pulsar官⽅仅仅提供了C++、Java、Python、Go四种语⾔的客户端开发包。且四种语⾔的⽀持特性
不尽相同,如下所⽰:
此外,还有⼀些第三⽅的客户端包,如下:
由于Pulsar Go客户端库是基于C++客户端库的,所以在安装Go库之前必须要确保已经成功安装了C++客户端库。
1、安装Pulsar C++客户端
在Pulsar C++客户端⽹页中,下载下图中所⽰的三个⽂件:
然后将下载的三个⽂件拷贝到CentOS服务器上,如下:
然后执⾏如下命令来安装这三个RPM包:
$ rpm -ivh apache-pulsar-client*.rpm
此处暂且先不验证是否安装成功。
2、安装Pulsar Go客户端
由于我环境所限制,⽆法使⽤go get的⽅式来下载Pulsar的Go语⾔包,我是直接在GitHub上⾯下载的incubator-pulsar-branch-
2.1.zip,解压该⽂件得到如下内容:
此处,我们仅仅需要⾥⾯的pulsar-client-go⽂件夹⾥⾯的内容,根据官⽹上的⽰例程序可知该go语⾔包的路径如下:
所以我们将pulsar-client-go拷贝到CentOS服务器上$GOPATH/src/github/apache/incubator-pulsar下,如果中间⽂件夹不存在就⾃⼰创建,最终如下:
到此,Pulsar Go客户端包安装完成。
此时,我们使⽤⼀个简单的Pulsar Go程序来验证上⾯安装是否正常,程序内容如下:

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。