全新一代消息中间件Pulsar

2024-02-13 13:18

本文主要是介绍全新一代消息中间件Pulsar,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Pulsar简介

Pulsar是一个用于服务端到服务端的消息中间件,具有多租户、高性能等优势。Pulsar最初由Yahoo开发,目前由Apache软件基金会管理。Pulsar采用发布-订阅的设计模式,Producer发布消息到Topic,Consumer订阅Topic、处理Topic中的消息。

Pulsar具有如下特性:

  • Pulsar的单个实例原生支持集群。
  • 极低的发布延迟和端到端延迟。
  • 可无缝扩展到超过一百万个Topic。
  • 简单易用的客户端API,支持Java、Go、Python和C++。
  • 支持多种Topic订阅模式(独占订阅、共享订阅、故障转移订阅)。
  • 通过Apache BookKeeper提供的持久化消息存储机制保证消息传递。

 

Pulsar安装

使用Docker安装Pulsar是最简单的,这次我们使用Docker来安装。

1.首先下载Pulsar的Docker镜像;

docker pull apachepulsar/pulsar

 

2.启动Pulsar

docker run --name pulsar -p 6650:6650 -p 8080:8080 --mount source=pulsardata,target=/pulsar/data --mount source=pulsarconf,target=/pulsar/conf -d apachepulsar/pulsar bin/pulsar standalone

 

pulsar-manager

Pulsar Manager是官方提供的可视化工具,可以对多个Pulsar进行可视化管理,虽然功能不多,但也基本够用了,支持Docker部署。

1.下载pulsar-manager的Docker镜像;

docker pull apachepulsar/pulsar-manager

 

2.下载完成后运行pulsar-manager容器;

9527端口可以访问Web页面;

docker run -it --name pulsar-manager -p 9527:9527 -p 7750:7750 -e SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties -d apachepulsar/pulsar-manager

 

 3.创建账号

运行成功后,我们刚开始无法访问,需要创建管理员账号,这里创建账号为admin:apachepulsar

curl http://localhost:7750/pulsar-manager/csrf-token# windows 语法
curl --header "X-XSRF-TOKEN: f5a1e31d-5afb-47e6-a551-6501270e19e2" --header "Cookie: XSRF-TOKEN=f5a1e31d-5afb-47e6-a551-6501270e19e2;" --header "Content-Type: application/json" -X PUT http://localhost:7750/pulsar-manager/users/superuser -d "{"""name""": """admin""", """password""": """apachepulsar""", """description""": """test""", """email""": """username@test.org"""}"

 

4.访问 

http://localhost:9527/

 

pulsar-dashboard

1.下载pulsar-dashboard的Docker镜像;

docker pull apachepulsar/pulsar-dashboard

 

2.下载完成后运行pulsar-manager容器;

docker run --name pulsar-dashboard -dit -p 8089:80 -e SERVICE_URL=http://mypulsar:8080 --link mypulsar apachepulsar/pulsar-dashboard

 3.访问

http://localhost:8089/

这篇关于全新一代消息中间件Pulsar的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/705618

相关文章

南卡科技“满分之选”全新开放式耳机发布,打造超越Pro的极致体验!

在音频技术的不断革新中,南卡品牌以其深厚的声学底蕴和对创新的不懈追求,再次为市场带来惊喜。今天,我们自豪地宣布,南卡OE Pro2开放式蓝牙耳机正式亮相,它不仅代表了南卡在开放式耳机领域的技术巅峰,更是对音质和佩戴舒适度的双重革新。 31°悬浮倾斜设计,无感佩戴的新高度 南卡OE Pro2将对耳机舒适性的诠释拉升到一个新境界,采用了开放式佩戴设计,彻底告别了传统耳机的堵塞感。基于上万耳

DevExpress WinForms v24.1新版亮点:功能区、数据编辑器全新升级

DevExpress WinForms拥有180+组件和UI库,能为Windows Forms平台创建具有影响力的业务解决方案。DevExpress WinForms能完美构建流畅、美观且易于使用的应用程序,无论是Office风格的界面,还是分析处理大批量的业务数据,它都能轻松胜任! DevExpress WinForms控件2024年第一个重大版本——v24.1全新发布,此版本对功能区、状态栏

Pulsar与Kafka消费模型对比

kafka kafka 属于 Stream 的消费模型,为了支持多 partition 的消费关系,引入了 consumer group 的概念,同时支持在消费端动态的 reblance 操作,当多个 Consumer 订阅了同一个 Topic 时,会根据分区策略进行消费者订阅分区的重分配。只要 consumer-group 与 topic 之间的关系发生变更,就会动态触发 reblance 操

下一代分布式消息队列Apache Pulsar

Pulsar简介 Apache Pulsar是一个企业级的分布式消息系统,最初由Yahoo开发并在2016年开源,目前正在Apache基金会下孵化。Plusar已经在Yahoo的生产环境使用了三年多,主要服务于Mail、Finance、Sports、 Flickr、 the Gemini Ads platform、 Sherpa以及Yahoo的KV存储。Pulsar之所以能够称为下一代消息队列,

Kafka 已落伍,转角遇见 Pulsar!

自 LinkedIn 2011 年创建了 Apache Kafka 后,这款消息系统一度成为大规模消息系统的唯一选择。为什么呢?因为这些消息系统每天需要传递数百万条消息,消息规模确实很庞大(2018 年 Twitter 推文平均每天 500 万条,用户数平均每天为 1 亿)。那时,我们没有 MOM 系统来处理基于大量订阅的流数据能力。所以,很多大牌公司,像 LinkedIn、Yahoo、Twit

Apache Pulsar崛起 | Meetup北京站全解析

来源:大数据技术与架构 大数据技术与架构 点击右侧关注,大数据开发领域最强公众号! 暴走大数据 点击右侧关注,暴走大数据! By  大数据技术与架构 场景描述: 2019 年 7 月, Apache Pulsar 正式发布了 2.4.0 版本,在 2.

提示工程颠覆:DSPy 引领全新范式革命

几个月前,我清楚地记得,Prompt Engineering 还是热门话题。就业市场上充斥着提示工程师的岗位,仿佛这是未来的必备技能。 然而,现在情况已经大不相同了。提示工程并不是一门艺术或科学,更像是“聪明的汉斯”现象——人类为系统提供了必要的背景,以便系统能更好地作出回应。甚至还有人撰写了书籍或博客,如《前50个提示:充分利用 GPT》等等。 但事实证明,没有一种提示或策略能够解决所有类型

「账号诊断」上线,「违规检测」全新改版!企业运营效率再提升!

云略自推出至今,始终致力于搜集用户的使用反馈,并据此不断新增及优化各项功能,持续产品迭代。 从矩阵号管理延伸的私聊/评论回复功能,到文案生成进阶的智能混剪,云略通过产品功能的不断升级优化,助力品牌的内容创作与用户经营。 近期,我们新增「账号诊断」功能,并对「违规检测」全面改版,让企业运营者可以更加轻松地掌握账号健康状况,及时发现并解决潜在问题,从而提升整体运营效率。 具体功能

5000字阐述云原生消息中间件Apache Pulsar的核心特性和设计概览

点击上方蓝色字体,选择“设为星标” 回复”面试“获取更多惊喜 Apache Pulsar 是 Apache 软件基金会顶级项目,自称是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存储分离架构设计,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。 Pulsar 是一个用于服务器到服务器的消息系统,具有多租户

消息中间件都有哪些

RabbitMQ:这可是一个开源的消息代理软件,也叫消息中间件。它支持多种消息传递协议,可以轻松地在分布式系统中进行可靠的消息传递。   Kafka:Apache Kafka是一个分布式流处理平台,它主要用于处理实时数据流。Kafka的设计初衷是为了处理高吞吐量的日志数据,但它也被广泛用于其他类型的消息传递和流处理任务。   ActiveMQ:Apache ActiveMQ