Ubuntu20.04裸机上配置单机 Pulsar2.7.0 成功并生产消费消息

本文主要是介绍Ubuntu20.04裸机上配置单机 Pulsar2.7.0 成功并生产消费消息，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

一、系统说明：

本机是Window10系统，开启虚拟机Hyper-V后，创建Ubuntu20.04的系统，并在系统上安装JDK1.8之后，成功启动单机模式Pulsar，并在单机集群上消费生产消息；

win10上通过hyper-v安装虚拟机

二、前期准备（ubuntu开启FTP服务 +win10上安装FileZilla客户端）
​
windows和linux文件互传：FileZilla

【1】开启Ubuntu端的FTP服务;

1、安装FTP服务（vsftpd是“very secure TTP daemon”的缩写，是一个完全免费的、开源的linux上的ftp服务器软件）；

sudo apt-get install vsftpd

2、软件安装完后，使用VI命令打开 /etc/vsftpd.conf 修改文件；

sudo vi /etc/vsftpd.conf

3、确保以下两行前面无注释符 # ；

local_enable=YES 
write_enable=YES 

4、修改完vsftpd.conf后，保存退出，并重启FTP服务;

sudo /etc/init.d/vsftpd restart 

【2】win10上安装FTP客户端工具FileZilla（Ubuntu作为服务端，需要开启FTP文件传输功能）;

下载 - FileZilla中文网
​
win10上下载FileZilla后双击即可；

1、查看ubuntu的主机ip的指令 ；

ip addr show 

2、FileZilla客户端: 文件 --> 站点管理器 --> 新站点 --> 需要填写ubuntu的 主机ip + 用户名 + 密码 ；

3、同时需要修改FileZilla的字符编码集为 UTF-8；

window10 和 Ubuntu 之间就可互传文件 ;

三、Ubuntu上安装Oracle JDK1.8

Ubuntu20.04安装JDK - Areas - 博客园
​
【1】下载jdk( win10上下载 jdk1.8 之后，使用FileZilla传输至Ubuntu)

【2】解压到指定目录(以jdk-1.8-linux-x64.tar.gz 为例)

1、创建目录

sudo mkdir /usr/lib/jvm

2、解压缩到该目录

sudo tar -zxvf jdk-1.8-linux-x64.tar.gz -C /usr/lib/jvm

3、修改环境变量

sudo vi ~/.bashrc

#在文件末尾追加：

#set oracle jdk environment
export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_144   ## 这里要注意目录要换成自己解压的jdk 目录
export JRE_HOME=${JAVA_HOME}/jre  
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib  
export PATH=${JAVA_HOME}/bin:$PATH  

#使环境变量立即生效:
source ~/.bashrc

4、系统注册jdk

sudo update-alternatives --install /usr/bin/java java /usr/lib/jvm/jdk1.8.0_144/bin/java 300

5、查看java版本,看是否安装成功:

java -version

四、安装二进制版本Pulsar并启动单机模式

Pulsar单机模式
​
【1】使用wget命令下载（在window10上下载后，使用FileZilla传输至ubuntu上）；

【2】解压缩，并使用cd命令进入并启动；

#创建软件安装目录
sudo mkdir /usr/local/pulsar      

#解压缩到指定文件夹
sudo tar -zxvf apache-pulsar-2.7.0-bin.tar.gz -C /usr/local/pulsar

#进入目录
cd apache-pulsar-2.7.0

【3】启动单机模式Pulsar；

#此处一定要使用 sudo 权限
sudo bin/pulsar standalone      (上图未加sudo,启动失败)

#日志中出现以下信息则说明 安装Pulsar成功
[DLM-/stream/storage-OrderedScheduler-3-0] INFO  org.apache.bookkeeper.stream.storage.impl.sc.StorageContainerImpl - Successfully started storage container (0).
[main] INFO  org.apache.pulsar.broker.authentication.AuthenticationService - Authentication is disabled
[main] INFO  org.apache.pulsar.websocket.WebSocketService - Pulsar WebSocket Service started

五、使用Pulsar-client 在运行的单机集群中consume并produce消息到Pulsar topic;

(注意：此处bin/pulsar 终端要一直开启，再加上一个consume终端 、一个produce终端 )

【1】Consume消息

在first-subscription订阅中 consume 一条消息到my-topic的命令

sudo bin/pulsar-client consume my-topic -s "first-subscription"

如果消息成功发送到topic，则会在pulsar-client 日志中出现一个确认，如下所示：

【2】Produce消息

向名称为my-topic的 topic 发送一条简单的消息hello-pulsar

 sudo bin/pulsar-client produce my-topic --messages "hello-pulsar"

如果消息成功发送到 topic，则会在 pulsar-client 日志中出现一个确认，

最后使用Ctrl+C终止单机模式Pulsar的运行;

这篇关于Ubuntu20.04裸机上配置单机 Pulsar2.7.0 成功并生产消费消息的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！