本文尝试通过技术演进的方式，以redis、kafka和 pulsar为例，逐步深入，讲讲它们架构和原理，帮助你更好地理解和学习消息队列。文章作者：刘德恩，腾讯IEG研发工程师。...一、最基础的队列 最基础的消息队列其实就是一个双端队列，我们可以用双向链表来实现，如下图所示： push_front：添加元素到队首； pop_tail：从队尾取出元素。...有了这样的数据结构之后，我们就可以在内存中构建一个消息队列，一些任务不停地往队列里添加消息，同时另一些任务不断地从队尾有序地取出这些消息。...这正好对应了我们队列抽象的push_front和pop_tail，因此我们可以直接把redis的list当成一个消息队列来使用。...不过好在kafka的partition是单向的队列，因此队列中消息的生产时间都是有序的。因此每次过期删除消息时，从头开始删就行了。 看起来似乎很简单，但仔细想一下还是有不少问题。
目前最为我们所熟知的消息队列有：ActiveMQ、Kafka、RabbitMQ、Pulsar和RocketMQ，他们都有哪些优势和劣势， 我们应该如何选择呢？相信这是摆在很多开发者面前的问题。...1.5、Pulsar Pulsar是一种开源的分布式消息中间件系统，由Apache Software Foundation维护和支持。...Pulsar在性能方面表现出色，它可以支持每秒数百万条消息的吞吐量，同时也提供了丰富的管理和监控工具，如Pulsar Manager和Prometheus等，帮助用户更好地管理和监控消息队列系统。...目前，AMQP协议已经得到了广泛的应用，许多消息队列系统如RabbitMQ、ActiveMQ、Qpid等都支持AMQP协议，而Kafka与Pulsar则不支持标准AMQP。...三、消息队列对比 ActiveMQ RabbitMQ RocketMQ Kafka Pulsar 单机吞吐量 较低(万级) 一般（万级） 高（十万级） 高（十万级） 高（十万级） 开发语言 Java
新春采购节 新春钜惠，爆款秒杀；企业用户专属，高配高性价比，助力企业轻松上云，腾讯云微服务新春大促重磅来袭！...不限新老用户 腾讯微服务平台 TSF、消息队列 CKafka 最低 4 折优惠 最高可省 30000+ 元！ 更有爆款秒杀、代金券大礼包限量放送 点击【在看】先到先得！...往期 推荐 《一天，把 Pulsar 客户端的性能提升3倍+！》 《超有料！万字详解腾讯微服务平台 TSF 的敏捷开发流程》 《火速围观！鹅厂中间件产品遭遇暴风吐槽！》...扫描下方二维码关注本公众号， 了解更多微服务、消息队列的相关信息！ 解锁超多鹅厂周边！ 戳原文，了解更多 新春采购节 活动信息 点亮在看，你最好看
消息队列学习 概念学习 参考资料： IBM Messages and queues Microsoft-MSMQ Overview KM-消息队列原理简介与对比选型 基础概念 消息（messages）：...而且在队列中接受者不用担心超时问题；在Topic中接受者必须continuously active并且按时接收，不然消息就会超时。...Pub/Sub：Pub-Sub Messaging 消息队列的优点： 分离消息的生产者和消费者，使其在代码层面解耦合 允许消费者对消息进行异步处理，加快处理速度。 访问控制中的峰值控制。...Pulsar 参考资料： 下一代消息队列pulsar到底是什么 pulsar/concepts-messaging 架构上来说，Pulsar是Pub-sub架构 Broker：无状态服务层，负责接受和传递消息...有状态持久化层，由一组名为Bookie的存储节点组成 Producer：数据生产者，负责发布数据到Topic Consumer：数据消费者，负责从Topic订阅数据 使用ZooKeeper作为元数据存储 其他消息队列是分区存储
欢迎您关注《大数据成神之路》 Pulsar简介 Apache Pulsar是一个企业级的分布式消息系统，最初由Yahoo开发并在2016年开源，目前正在Apache基金会下孵化。...Pulsar之所以能够称为下一代消息队列，主要是因为以下特性: 线性扩展。能够丝滑的扩容到成百上千个节点(Kafka扩容需要占用很多系统资源在节点间拷贝数据，而Plusar完全不用) 高吞吐。...我们知道Kafka在0.8版本之前是将消费进度存储到ZK中的，但是ZK本质上基于单个日志的中心服务，简单来讲，ZK的性能不会随着你增加更多的节点而线性增加，会只会相反减少，因为更多的节点意味着需要将日志同步到更多的节点...Failover: 多个消费者可以连接同一个topic并按照字典序排序，第一个消费者会开始消费消息，称之为master，当master断开连接，所有未ack和队列中剩下的消息会分发给另一个消费者。...总结 Plusar作为下一代分布式消息队列，拥有非常多吸引人的特性，也弥补了一些其他竞品的短板，例如地域复制、多租户、扩展性、读写隔离等等。 image.png
消息队列RocketMQ版提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍消息队列RocketMQ版事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。...概念介绍 事务消息：消息队列RocketMQ版提供类似XA或Open XA的分布式事务功能，通过消息队列RocketMQ版事务消息能达到分布式事务的最终一致。...半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了消息队列RocketMQ版服务端，但是消息队列RocketMQ版服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半事务消息...分布式事务消息的优势 消息队列RocketMQ版分布式事务消息不仅可以实现应用之间的解耦，又能保证数据的最终一致性。...事务消息发送步骤如下： 生产者将半事务消息发送至消息队列RocketMQ版服务端。
导语 2021年12月1日，腾讯云分布式消息队列 TDMQ Pulsar 版正式商业化。...用户使用消息队列 TDMQ Pulsar 版时，无需担心与开源 Apache Pulsar 社区的兼容性问题。...Pulsar 版，轻松上云，享受腾讯云提供的 7*24小时的专业消息队列服务支持，享受高可用消息队列服务，无需关注运维细节。...消息队列 TDMQ Pulsar 版可实现高效的异步通信和应用解耦，确保主站业务的连续性。...截至2021年11月底，消息队列 TDMQ Pulsar 版已有上百家活跃的企业用户。
在开源的业界已经有这么多消息队列中间件了，pulsar作为一个新势力到底有什么优点呢？...pulsar自从出身就不断的再和其他的消息队列(kafka,rocketmq等等)做比较，但是Pulsar的设计思想和大多数的消息队列中间件都不同，具备了高吞吐，低延迟，计算存储分离，多租户，异地复制等功能...，所以pulsar也被誉为下一代消息队列中间件，接下来我会一一对其进行详细的解析。...pulsar架构原理 ? ? 整体的架构和其他的消息队列中间件差别不是太大，相信大家也看到了很多熟悉的名词，接下来会给大家一一解释这些名词的含义。...灾备：加强版独占，如果独占的那个挂了，会自动的切换到另外一个好的消费者，但是还是只能由一个独占。
长轮询的思想： 服务端接收到新消息请求后，如果队列里没有新消息，并不急于返回，通过一个循环不断查看状态，每次waitForRunning一段时间（默认是5秒），然后再Check。...queueId,然后通过topic和queueID获取到该消息队列的最大偏移量，之后调用notifyMessageArriving方法。...，如果该消息队列的最大偏移量大于待拉取偏移量，说明有新的消息传入。...在消息存储中，存在一个线程ReputMessageService，它会实时更新消息消费队列和索引文件，每执行一次任务推送后会休息1毫秒就继续尝试推送消息到消费队列和索引文件。...线程的notifyMessageArriving方法唤醒挂起线程，判断当前消费队列最大偏移量是否大于待拉取偏移量，如果大于则拉取消息。
本文从传统消息队列上云所面临的三大挑战说起，并以 Apache Pulsar 为技术案例，深入浅出地讲解了如何打造适配云原生的消息队列。希望本文能对大家提供参考。...为了更好地为广大用户服务，提供金融级可靠消息服务，腾讯云开启了消息队列上云之路，目前 Apache Pulsar 在腾讯云上已经大规模使用。...对于强一致的异地多活，现有的消息队列很少有提供开箱即用的完整方案。 PART THREE 遇见Apache Pulsar 如果使用传统的消息队列上云，要解决上述问题需要费一番功夫。...PART FIVE 未来寄语 相对于其他传统消息队列，Apache Pulsar 借助存储与计算分离的云原生架构，以及支撑平滑迁移、承载海量分区、跨区域数据复制等原生功能特性，成为解决原有消息队列上云挑战的最佳解决方案之一...希望上述我们在消息队列方向的探索与实践能够带给有着类似需求的同行一些参考。 在腾讯云上，我们基于 Apache Pulsar 推出了 TDMQ 消息队列，除了上述改动，还有其他新特性。
，中间件小Q妹为大家特别准备了 2000份 新春红包封面，祝大家新春快乐，虎年大吉！...Apache Pulsar 社区年度盛会——Pulsar Summit Asia 重磅来袭！》 《腾讯云消息队列TDMQ RabbitMQ 版开启公测，文末有惊喜！》...CKafka重磅上线DataHub，让数据流转更简便》 《ZooKeeper系列文章：ZooKeeper 源码和实践揭秘（三）》 《Serverless可观测性的价值》 《喜报|CKafka荣获可信云消息队列服务稳定性先进级认证...》 《RoP重磅发布0.2.0版本：架构全新升级，消息准确性达100%》 《ZooKeeper系列文章：ZooKeeper 源码和实践揭秘（二）》 《深入理解Rabbit MQ与AMQP协议》 扫描下方二维码关注本公众号...， 了解更多微服务、消息队列的相关信息！
本文是对腾讯TEG技术委员会专家工程师刘德志老师在腾讯云开发者社区沙龙 online 的分享整理，介绍基于 Apache Pulsar 的新一代存储计算分离设计的消息队列 TDMQ，希望与大家一同交流。...视频内容 一、金融级别云原生消息队列功能需求 1....腾讯计费平台有四个版本，分别是基础版、企业版、海外版、行业版，为众多广告客户提供服务，支持单笔上亿的交易。 2....腾讯计费平台基于开源 Pulsar 存储计算分离架构，支持按量使用、无限扩展、兼容主流消息队列、专为云而生的消息队列产品——TDMQ 可以满足上述这些要求。 二、TDMQ架构说明 1....存储分离架构 TDMQ 是基于 Pulsar 内核，和其它的分布式消息队列不同，Pulsar 采用了计算和存储分离的 2 层架构： Broker 提供消息的生产、发送和管理服务，本身并不存储任何状态信息和消息内容
本文是对腾讯TEG技术委员会专家工程师刘德志老师在云+社区沙龙 online 的分享整理，介绍基于 Apache Pulsar 的新一代存储计算分离设计的消息队列 TDMQ，希望与大家一同交流。...视频内容 01 金融级别云原生消息队列功能需求 1....腾讯计费平台有四个版本，分别是基础版、企业版、海外版、行业版，为众多广告客户提供服务，支持单笔上亿的交易。 ? 2....腾讯计费平台基于开源 Pulsar 存储计算分离架构，支持按量使用、无限扩展、兼容主流消息队列、专为云而生的消息队列产品——TDMQ 可以满足上述这些要求。 02 TDMQ架构说明 1....存储分离架构 TDMQ 是基于 Pulsar 内核，和其它的分布式消息队列不同，Pulsar 采用了计算和存储分离的 2 层架构： Broker 提供消息的生产、发送和管理服务，本身并不存储任何状态信息和消息内容
到90年代 IBM、Oracle、Microsoft 纷纷推出自家的MQ，但都是收费且闭源的产品，主要面向高端的企业用户，这些MQ一般都采用高端硬件，软硬件一体机交付，需要采购专门的维护服务，MQ本身的架构是单机的架构...面向IoT的场景，消息队列开始从云内服务端应用通信，延伸到边缘机房和物联网终端设备，支持 MQTT 等物联网标准协议也成了各大消息队列的标配，我们看到 Pulsar、Kafka、RocketMQ 都在努力跟随时代步伐...Once 语义但是，一些非常重要的消息，如交易数据，下游消费者要求消息不重不漏，即 Exactly Once，精准一次，在0.11版本之前，Kafka 是无能为力的，只能通过设置ACK=-1，然后业务消费者自己去重...0.11版本之后，Kafka 引入了幂等性概念，Procedure 无论向 Broker 发送多少次消息，Broker 只会持久化一条：At Least Once + 幂等性 = Exactly Once...未完待续 此篇是消息队列基础知识的上半部分，下半部分会对现代主流的消息队列进行介绍，包括 RocketMQ、Kafka、Pulsar，以及这几款 MQ 之间的对比。
12月动态 消息队列 CKafka 版 【商业化】国内站专业版支持按小时后付费。...★ 消息队列 RocketMQ 版 【商业化】虚拟集群正式商业化：TDMQ RocketMQ 共享版（虚拟集群）于 2022年12月28日结束公测，正式商业化开始计费，计费方式为按量付费（后付费）。...★ 消息队列 Pulsar 版 【白名单功能】Pulsar 专业版商业化广州发布，多租户物理隔离，提供丰富的规格供选择，适合于对稳定性和资源隔离性要求高、业务流量大的生产环境。...消息队列 Pulsar 版 【新功能】虚拟集群到专业集群的平滑迁移支持。 【新功能】自动创建重试/死信队列的命名规则优化。 【新功能】支持订阅下延迟消息数量告警。 更多功能，敬请期待。...戳原文，查看更多消息队列 RocketMQ 版的 信息！ 点个在看你最好看
TDMQ RabbitMQ 版是TDMQ系列产品中的一款子产品，是一款分布式高可用的消息队列服务，支持AMQP 0-9-1 协议，完全兼容开源 RabbitMQ 的各个组件与概念。...TDMQ RabbitMQ 版的背景 众所周知，RabbitMQ是一个历史比较悠久的消息队列中间件，它是使用Erlang语言开发的实现AMQP（Advanced Message Queue Protocol...高级消息队列协议）的消息中间件。...高扩展性 TDMQ RabbitMQ 版相比于开源 RabbitMQ 支持更高的队列数量，可扩展能力强，底层系统可根据业务规模自动弹性伸缩、扩容/缩容集群规模，对用户透明。...产品体验入口 腾讯云消息队列TDMQ RabbitMQ 版已经开放公测，欢迎大家使用体验： 扫描二维码，立即体验 在1月6日~1月20日期间特别推出有奖产品体验活动，您可以将产品使用后的建议填写到下方问卷中
感谢机械工业出版社、博文视点和电子工业出版社的赠书，同时大会主办方也采购大量 Pulsar 书籍作为赠品，赠书给优秀嘉宾。...作为云原生的分布式消息队列和流数据平台，Pulsar不仅支持云原生、多租户、跨区域数据复制等高级功能，还支持消息队列事务、分层存储、可插拔的消息队列协议、Pulsar Function、Pulsar I...深入 Kafka与Pulsar 理解消息流平台的实践与剖析 “感谢博文视点和电子工业出版社提供赠书《深入 Kafka与Pulsar 理解消息流平台的实践与剖析》 ” 深入理解Kafka与Pulsar：消息流平台的实践与剖析...关于 Apache Pulsar Apache Pulsar 是 Apache 软件基金会顶级开源项目，是云原生时代领先的分布式消息和流平台。...Pulsar 集消息和流传输于一体： 可支持企业级消息的强一致性传输，确保消息不丢、不重和顺序性保障，同时支持延迟队列、死信队列、重试队列、事务消息和多种订阅模式等消息特性； 可支持海量流数据传输和存储
比如，在可预期的业务高峰期时，对消息队列集群进行快速扩容；在非预期的可用区故障时，其余可用区可以正常提供服务，保障交易业务的流畅性。...于是 TDMQ Pulsar 进入了 FiT 的消息队列技术选型范畴。...关于 TDMQ Pulsar 腾讯云消息队列 Pulsar 版是基于 Apache Pulsar 自研的消息中间件，具备极好的云原生和 Serverless 特性，计算存储分离的架构使其在扩缩容方面具备良好的底层优势...在完全兼容社区版的基础上，消息队列 Pulsar 版还提供了重试&死信队列、消息标签过滤、消息轨迹等高级特性。...目前消息队列 Pulsar 版已经有较大规模的应用，如王者荣耀、猫眼、微民保险、QQ音乐、领星、长安汽车等，以及包括腾讯计费绝大部分场景，包括支付主路径、实时对账、实时监控、大数据实时分析等方面。
★ 12月预告 消息队列 CKafka 版 国内站专业版支持按量计费（按小时计费）。...消息队列 Pulsar 版 Pulsar 专业版商业化，多租户物理隔离，提供丰富的规格供选择，适合于对稳定性和资源隔离性要求高、业务流量大的生产环境。...消息队列 RocketMQ 版 共享版集群商业化，开启按量收费。 支持HTTP协议。 共享集群限流，保障集群稳定性，以及相应的限流指标等。 死信消息支持在控制台重发。...死信队列新增消息数量的指标和告警。 支持开源自建的集群无缝迁移到共享版的虚拟集群上。 消息队列 RabbitMQ 版 专享集群控制台集成更多开源控制台能力，灵活适配社区使用体验。...戳原文，查看更多 消息队列 RabbitMQ 版 的信息！ 点个在看你最好看
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
