首页 > 其他分享 >Pulsar分布式消息系统

Pulsar分布式消息系统

时间:2023-02-08 11:45:43浏览次数:126  
标签:http Kafka manager 消息 pulsar Apache Pulsar 分布式

说明

Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体。该系统源于 Yahoo,最初在 Yahoo 内部开发和部署,支持 Yahoo 应用服务平台 140 万个主题,日处理超过 1000 亿条消息。Pulsar 于 2016 年由 Yahoo 开源并捐赠给 Apache 软件基金会进行孵化,2018 年成为 Apache 软件基金会顶级项目。

Pulsar 作为下一代云原生分布式消息流平台,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐以及低延时的高可扩展流数据存储特性,内置诸多其他系统商业版本才有的特性,是云原生时代解决实时消息流数据传输、存储和计算的最佳解决方案。 Apache Pulsar 提供了统一的消费模型,支持 Stream(如 Kafka)和 Queue(如 RabbitMQ)两种消费模型, 支持 exclusive、failover 和 shared 三种消费模式。同时,Pulsar 提供和 Kafka 兼容的 API,以及 Kafka-On-Pulsar(KoP) 组件来兼容 Kafka 的应用程序,KoP 在 Pulsar Broker 中解析 Kafka 协议,用户不用改动客户端的任何 Kafka 代码就能直接使用 Pulsar。 目前,Apache Pulsar 已经应用部署在国内外众多大型互联网公司和传统行业公司,案例分布在人工智能、金融、电信运营商、直播与短视频、物联网、零售与电子商务、在线教育等多个行业,如美国有线电视网络巨头 Comcast、Yahoo!、腾讯、中国电信、中国移动、BIGO、VIPKID 等。 目前 Apache Pulsar 项目原生核心贡献者已组成创业公司 StreamNative,进一步为 Apache Pulsar 提供更好的企业级服务支持与生态建设。

端口映射

序号 服务 docker 端口映射 备注
1 standalone 8082:8080  
2 6650:6650  
3 dashboard 81:80  
4 pulsar-manager 9527:9527  
7750:7750  

部署

部署目录统一放在: /data/middleware/

内网部署

# 详细配置与镜像已修改 
git clone https://git.insightone.cn/middleware/pulsar.git cd pulsar
# 启动
docker-compose up -d

离线部署

下载全部镜像 https://adlereden.cn/middleware/pulsar/images/
#导入镜像
sh load_image.sh
下载项目 https://adlereden.cn/middleware/pulsar/project/
# 解压项目并启动
unzip pulsar.zip
cd pulsar
# 启动
docker-compose up -d
等待运行完成... 查看启动端口
# 创建token
CSRF_TOKEN=$(curl http://localhost:7750/pulsar-manager/csrf-token)
# 创建账号
curl -H 'X-XSRF-TOKEN: $CSRF_TOKEN' \
-H 'Cookie: XSRF-TOKEN=$CSRF_TOKEN;' \
-H "Content-Type: application/json" -X PUT http://localhost:7750/pulsar-manager/users/superuser \
-d '{"name": "admin", "password": "pulsar", "description": "dev", "email": "[email protected]"}'
创建成功 {"message":"Add super user success, please login"} manager页面添加环境 Service_URL=http://standalone:8080 访问 http://xxxxx:9527 url处填写 http://xxxxx:8080 即可 提示: 填写容器ip+端口 http://172.18.0.13:8080 或 http://standalone:8080    

标签:http,Kafka,manager,消息,pulsar,Apache,Pulsar,分布式
From: https://www.cnblogs.com/edeny/p/17101181.html

相关文章

  • 消息中心
      usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tasks;namespace_Test_{internalclassMess......
  • React:消息订阅(subscribe)-发布(publish)机制
    发布类似触发事件, 订阅类似监听事件使用这种方式的好处是,兄弟组件间通信不必再像使用props那种通过父组件来通信,多层组件之间通信也不必在一层一层的传递,直接在触发事件......
  • OpenHarmony开发15 —— 消息队列
    OpenHarmony开发15——消息队列说点别的,这几天没更新真的是被这个消息队列折磨完了,谁知道鬼鸿蒙它不进行任何提示!为什么stackoverflow会不提示啊!!!太折磨了太折磨了......
  • ChatGPT自动回复消息
    介绍微信连接ChatGPT,实现微信私聊自动回复消息(群聊回复需@)条件上网长登录的微信小号一个注册&登录ChatGPT官网地址:https://openai.com/api/注册需要一个邮箱(建......
  • RabbitMQ 消息的可靠投递
    rabbitmq整个消息投递的路径为: produce--->rabbitmqbroker--->exchange--->queue--->consumer 1.1 生产端可靠性在使用RabbitMQ的时候,作为消息发送方希望杜......
  • Docker第三章:主从操作、分布式存储
    mysql_master主从配置 1:新建主服务器容器实例3307dockerrun-p3307:3306--privileged=true-v/zyt/mysql_master/log:/var/log/mysql-v/zyt/mysql_master/data:/......
  • redis实现分布式锁释放锁和分布式锁实现可重入性
    本文为上一篇redis使用setnx实现分布式锁的增加篇重在体会思想与开源的框架自然是无法比拟的 如果当前线程已经获取到锁的情况下,不需要重复获取锁,而是直接复用。 ......
  • 《分布式技术原理与算法解析》学习笔记Day04
    分布式选举算法为什么需要分布式选举?分布式意味着我们的应用部署在一个集群中,集群包含多个节点或者服务器,对于一个集群来说,多个节点是怎么协同工作的呢?我们需要有一个主......
  • redis使用setnx实现分布式锁
     packagecom.shanhe.service;importcom.shanhe.entity.CommodityDetails;importcom.shanhe.lock.impl.RedisLockImpl;importcom.shanhe.mapper.CommodityDetail......
  • redis超卖(分布式锁) setnx排他独占 最终效果,既可以防止死锁,又可以设置过期时间
    热点key过期,加一个锁,抢占到锁才会去查询mysql数据库,然后查到数据后重新写入redis,几百台服务器,几十个热点数据,不能用jvm锁            ----......