CentOS7 搭建Pulsar 消息队列环境,CentOS(Linux)部署Pulsar,亲测成功,以及Python操作Pulsar实例驱动
在 最佳开源数据库与数据分析平台奖 中,之前曾连续两年入选的 Kafka 意外滑铁卢落选,取而代之的是新兴项目 Pulsar,Bossie Awards中对 Pulsar 点评如下:“Pulsar 旨在取代 Apache Kafka 多年的主宰地位。Pulsar在很多情况下提供了比 Kafka 更快的吞吐量和更低的延迟,并为开发人员提供了一组兼容的 API,让他们可以很轻松地从 Kafka 切换到 Pulsar。Pulsar 的最大优点在于它提供了比 Apache Kafka 更简单明了、更健壮的一系列操作功能,特别在解决可观察性、地域复制和多租户方面的问题。在运行大型 Kafka 集群方面感觉有困难的企业可以考虑转向使用 Pulsar。”
Pulsar中文文档:https://pulsar.apache.org/docs/zh-CN/standalone/
1,系统环境
a,操作系统 CentOS Linux release 7.6.1810 (Core) 64位,必须确保你的内存是4G以上,双核CPU!否则将无法新建默认命名空间。
b,确保jdk环境已经安装,具体教程请看 CentOS7 shell脚本安装jdk
c,确保Python3和对应的pip已经安装,具体教程请看 CentOS7 源码编译安装Python3.5
2,执行以下命令,启动Pulsar
wget https://archive.apache.org/dist/pulsar/pulsar-2.3.0/apache-pulsar-2.3.0-bin.tar.gz # 下载pulsar安装包
tar xvfz apache-pulsar-2.3.0-bin.tar.gz # 解压安装包
cd apache-pulsar-2.3.0 # 打开pulsar目录
bin/pulsar standalone # 启动单机pulsar
bin/pulsar-client produce my-topic --messages "hello-pulsar" # 发送一条消息
如图,消息已经成功发送
3,执行命令 pip3 install pulsar-client==2.3.1
4,创建Pulsar消费者监听python3程序 consumer.py
import pulsar
client = pulsar.Client('pulsar://localhost:6650')
consumer = client.subscribe('my-topic2', 'my-subscription')
while True:msg = consumer.receive()try:print("Received message '{}' id='{}'".format(msg.data(), msg.message_id()))consumer.acknowledge(msg)except:consumer.negative_acknowledge(msg)
client.close()
运行 python3 consumer.py
5, 创建Pulsar生产者python3程序 producer.py
import pulsar
client = pulsar.Client('pulsar://localhost:6650')
producer = client.create_producer('my-topic2')
for i in range(10):producer.send(('Hello-%d' % i).encode('utf-8'))
client.close()
运行 python3 producer.py
看到 消费者监听界面,出现如下消息
CentOS7 搭建Pulsar 消息队列环境,CentOS(Linux)部署Pulsar,亲测成功,以及Python操作Pulsar实例驱动相关推荐
- CentOS7 搭建Kafka消息队列环境,以及Python3操作Kafka Demo
Kafka适合什么样的场景? 它可以用于两大类别的应用: 构造实时流数据管道,它可以在系统或应用之间可靠地获取数据. (相当于message queue) 构建实时流式应用程序,对这些流数据进行转换或 ...
- PMON环境配置(龙芯,亲测成功1)
1.前言 2.运行平台 3.依赖组件 4.安装与配置安装专用GCC编译器 4.1下载GCC编译器 4.2解压GCC编译器 4.3 ...
- 数据库:Centos7安装解压版mysql5.7图文教程,亲测成功
目录 1.卸载Centos7默认自带的mariadb数据库,避免冲突 2.下载解压版mysql并安装 3.配置mysql 4.mysql客户端访问 Centos7安装mysql5.7解压版完整教程避免 ...
- 阿里云apache配置php mysql_阿里云CentOS7搭建Apache+PHP+MySQL环境
最近要搭建一个阿里云的LMAP环境,选了CentOS7来做搭建. 1.Apache Centos7默认已经安装httpd服务,只是没有启动. 如果你需要全新安装,可以yum install -y ht ...
- 大厂实践|Apache Pulsar 消息队列在拉卡拉的应用
关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息.存储.轻量化函数式计算为一体,采用计算与存储分离架构设计,支 ...
- centos7.4.3 部署python-pcl亲测可用(采坑记)
最近工作里用到PCL库,处理点云数据.点云抽稀能极大的减少点云数据. 通过python-pcl调用C++的PCL库.windows下运行ok,linux下部署踩了很多坑,试了多种办法,包括源码安装,都 ...
- 2021-07-22 CentOS7.6 Samba使用AD域控认证(winbind),亲测有效。
CentOS7.6 Samba使用AD域控认证(winbind),亲测有效. centos7: https://www.freesion.com/article/44621398696/ cetnos ...
- Linux安装svn服务器和权限配置_亲测成功
Linux安装svn服务器和权限配置_亲测成功 SVN简介 SVN是Subversion的简称,是一个开放源代码的版本控制系统,通过采用分支管理系统的高效管理,简而言之就是用于多个人共同开发同一个项目 ...
- grafana graphite statsd搭建安装部署 实时监控_亲测成功
grafana graphite statsd搭建安装部署 实时监控_亲测成功 docker部署grafana graphite stastd实时监控告警配置_亲测成功 下载软件 # 下载carbon ...
最新文章
- 让“云”无处不在-Citrix Xenserver之一 环境搭建
- 下拉菜单被挡住了,DIV置于最底层的方法
- UC伯克利发现「没有免费午餐定理」加强版:每个神经网络,都是一个高维向量...
- sysfs cannot create duplicate filename问题
- PHPUnit 3.4.10 在windows上配置
- 在Spring中使用DButils
- react.js 从零开始(五)React 中事件的用法
- sql 过滤空值_图解 SQL,这简直太形象了吧!
- 使用flask开发web应用
- 分布式微服务架构及演变过程
- html拖拽验证,jQuery按住滑块拖动验证插件
- 上传doc,pdf,ppt,png,jpg,html文件并解析内容
- 详解:什么是VXLAN?
- 2019 Python接口自动化测试框架实战开发(一)
- itest考试切屏能检测出来吗_用itest考试分屏会被后台检测吗?
- html中背景条纹效果,使用CSS线性渐变 制作条纹背景
- C语言socket重连和心跳,c# socket 心跳 重连
- java引入外部字体_Java中如何自定义字体文件(引用外部字体)?-字体文件
- apa引用要在文中吗_SCI论文:常见的两种参考文献引用方式
- LabVIEW使用G#框架实现面向对象编程
热门文章
- Python数据分析入门(四)
- 构建安全网络 比格云全系云产品30天内5折购
- 怎样在fastboot 里面加入新的命令
- 就国内某个程序员问答网站的简单的分析
- PowerShell3.0入门视频(由Jeffrey Snover和Jason Helmick主讲)
- crontab环境变量
- PCI_Express规范第七章解读-Software Initialization and configuration
- 更新MySQL复制 自动监控脚本
- 第三方类库的学习心态
- inflate简介,LayoutInflater和inflate()方法的用法