一、系统说明:

本机是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 

ubuntu上开启ftp服务

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

下载 - FileZilla中文网

win10上下载FileZilla后双击即可;

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

ip addr show 

ubuntu查看ip地址

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

filezilla安装配置

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

filezilla安装配置2

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

jdk解压

jdk安装配置

四、安装二进制版本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

pulsar解压
启动单机pulsar

【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

成功标志1
成功标志2

五、使用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 日志中出现一个确认,如下所示:
consume消息成功

【2】Produce消息

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

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

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

produce消息成功

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

标签: bin, sudo, Ubuntu20.04, 裸机, topic, FileZilla, Pulsar, Pulsar2.7, pulsar

相关文章推荐

添加新评论,含*的栏目为必填