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 成功并生产消费消息相关推荐
- Ubuntu20.04安装与配置记录
Ubuntu20.04安装与配置记录 原文地址:Ubuntu20.04安装与配置记录 一.Ubuntu系统盘制作 1.1 Windows环境下制作系统盘 下载Ubuntu系统,选择桌面版. 下载工具系 ...
- 【一生一芯】Chap.1 “一生一芯”实验环境配置| VMware安装Ubuntu20.04 | PA工程配置 | 解决llvm版本问题
[一生一芯]Chap.1 "一生一芯"实验环境配置| VMware安装Ubuntu20.04 | PA工程配置 | 解决llvm版本问题 0. 什么是PA? 1. 安装VMware ...
- Ubuntu20.04安装并配置SSH
Ubuntu20.04上安装配置openssh-server 本文将介绍在Ubuntu20.04 Desktop上安装并配置使用openssh-server 1. 安装ssh sudo apt-get ...
- DELF: DEep Local Features在Ubuntu20.04下安装配置
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 DELF: DEep Local Features在Ubuntu20.04下安装配置 一.安装Ubuntu20.04后配置深度学习环境 ...
- Ubuntu20.04 NAT 网络配置
Ubuntu20.04 NAT 网络配置 背景 用 Vmware 安装好 Ubuntu 20.04 后发现网络用不了,也不能和宿主机互相 ping 通.通过下面的步骤可以实现设置静态 IP,使 Ubu ...
- 【最简单方法】将ubuntu20.04中自带的gcc-9.4.0降级到gcc-4.8.5
前言 之前折腾过TensorFlow相关源码库安装的版本管理.今天有这么一个需求,需要将ubuntu20.04中自带的gcc-9.4.0降级到gcc-4.8.5. 实现思路 网上大多数教程都是,通过源 ...
- 在Ubuntu20.04系统上LIO-SAM跑KITTI数据集和自己数据集代码修改
LIO-SAM跑KITTI数据集和自己数据集代码修改 一.编译并运行LIO-SAM 二.代码修改 1.cloud_info.msg 2.imageProjection.cpp 三.KITTI数据集准备 ...
- ubuntu20.04系统安装及配置
一.系统安装: 启动盘制作: 1.下载ubuntu20.04(ubuntu-20.04.1-desktop-amd64.iso):Ubuntu 20.04.2.0 LTS 2.用UltraISO制作U ...
- Ubuntu20.04环境上在LXC内安装FRR
由于学习需要,在LXC内配FRR. 首先进入FRR官网找到Ubuntu20.04版本操作指南 Ubuntu 20.04 LTS - FRR latest documentation 1.安装环境依赖 ...
最新文章
- Fragment 之间传递数据
- (5.0) Tomcat 8 源码, 初始化 bootstrap
- 对比两个表中,字段名不一样的SQL
- HTML5开发手机应用--viewport的作用--20150216
- 定价错误: 必要条件 MWST 丢失
- Redis 购物车 - 删除商品与更新购买数量
- 音视频技术开发周刊 | 169
- Asp导出到Excel之二
- php手工注入拿webshell
- 线段树(单点更新,区间查询) HDU 1754 I Hate It
- 发布一个练笔的 Android 阅读器,轻微仿91 Android 阅读器【后续将提供源码】
- maven远程私服发布jar包
- python改变默认编码
- 论文撰写-LaTex 教程+模板
- 学习OpenCV研究报告指出系列(二)源代码被编译并配有实例project
- H5制作平台开发游戏成本解析
- Android 集成google地图
- Golang代码注释规范及goland代码注释模板配置
- 怎么用nginx搭建文件服务器,使用nginx搭建简单文件服务器
- 2022年ICASSP说话人日志(Speaker Diarization)方向论文泛读总结