首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

腾讯开源万亿分布消息中间件 TubeMQ

beMQ 是腾讯在 2013 年自研的分布消息中间件系统,专注服务大数据场景下海量数据的高性能存储和传输,经过近 7 年上万亿的海量数据沉淀,目前日均接入量超过 25 万亿条。...变更及查询实现了完整的自动化闭环管理,减轻了系统维护的复杂度; 服务器侧消费负载均衡 Tube MQ 采用的是服务侧负载均衡的方案,而不是客户端侧操作,提升系统的管控能力同时简化客户端实现,更便于均衡算法升级; 系统行锁操作...对于 Broker 消息读写中存在中间状态的并发操作采用行锁,避免重复问题; Offset 管理调整 Offset 由各个 Broker 独自管理,ZK 只作数据持久化存储用(最初考虑完全去掉 ZK...依赖,考虑到后续的功能扩展就暂时保留); 消息读取机制的改进 Tube MQ 采用的是消息随机读取模式, 同时为了降低消息时延又增加了内存缓存读写, 对于带 SSD 设备的机器, 增加消息滞后转 SSD...消费时延分级保证、消费限流控制,以及数据拉取频率控制等; 系统安全管控 根据业务不同的数据服务需要,以及系统运维安全的考虑,Tube MQ 系统增加了 TLS 传输层加密管道,生产和消费服务的认证、授权,以及针对分布式访问控制的访问令牌管理

1.5K60

腾讯万亿分布消息中间件TubeMQ正式开源

TubeMQ是腾讯在2013年自研的分布消息中间件系统,专注服务大数据场景下海量数据的高性能存储和传输,经过近7年上万亿的海量数据沉淀,目前日均接入量超过25万亿条。...系统行锁操作 对于Broker消息读写中存在中间状态的并发操作采用行锁,避免重复问题; 5. ...消息读取机制的改进 Tube MQ采用的是消息随机读取模式,同时为了降低消息时延又增加了内存缓存读写,对于带SSD设备的机器,增加消息滞后转SSD消费的处理,解决消费严重滞后时吞吐量下降以及SSD磁盘容量小...系统安全管控 根据业务不同的数据服务需要,以及系统运维安全的考虑,Tube MQ系统增加了TLS传输层加密管道,生产和消费服务的认证、授权,以及针对分布式访问控制的访问令牌管理,满足业务和系统运维在系统安全方面的需求...客户端改进 基于业务使用上的便利性以,我们简化了客户端逻辑,使其做到最小的功能集合,我们采用基于响应消息的接收质量统计算法来自动剔出坏的Broker节点,基于首次使用时作连接尝试来避免大数据量发送时发送受阻

1.2K72
您找到你想要的搜索结果了吗?
是的
没有找到

腾讯云数据库携手天阳,共建国产新生态

近日,天阳信用卡新一代核心产品CreditX完成了与腾讯云分布式数据库TDSQL的适配性测试,并基于双深度融合,推出“金融零售核心CreditX+分布式数据库TDSQL”的新一代分布式信用卡核心产品联合解决方案...CreditX整体技术架构与腾讯云整体解决方案全面融合:其中PaaS平台采用腾讯蓝鲸平台进行CI/CD持续集成及部署,以及统一运维;数据库采用TDSQL;消息服务组件使用腾讯云消息队列CMQ。...此次联合方案中的TDSQL是腾讯云企业分布式关系型数据库品牌,旗下涵盖金融分布式、云原生、分析型等多引擎融合的完整数据库产品体系,提供业界领先的金融高可用、计算存储分离、数据仓库等能力,同时具备智能运维平台...其中TDSQL金融分布式引擎,具备线性可扩展、海量吞吐、高性能、数据强一致、99.999%高可用、企业安全等特性,服务了微众银行、平安银行、数字广东等广大金融政企机构,包括近半国内TOP 20银行客户等...国产数据库,中标哪家强? ↓↓一年19.9特惠云数据库点这儿~

6.5K30

TVP专家谈鹅厂中间件:创新前行 遇见未来

为了倾听用户心声,腾讯云中间件携微服务观测平台 TSW、消息队列CKafka两款产品,登上第三期「鹅厂中间件吐槽大会」的舞台,与8位顶专家现场过招,强强碰撞,直击产品问题,共同为产品指明全新方向,为产品与技术的完美融合续写全新未来...在本次会议中,消息队列领域资深大咖、老虎证券技术负责人胡夕直截了当地指出,CKafka 这款产品非常,但是在交互体验上还可以更加完善。...4-1.png 腾讯云中间件产品矩阵 腾讯云中间件产品基于腾讯在微服务、消息队列领域多年的技术积累,提供了功能强大、兼容并包、生态开放的云原生分布式微服务解决方案和消息队列服务。...全方位打造出7款优秀产品:微服务平台 TSF、消息队列 CKafka、金融消息队列 TDMQ、微服务观测平台 TSW、弹性微服务TEM、微服务引擎 TSE、分布式事务 DTF,全面布局云原生领域产品矩阵...在盛行 Serverless 的时代,我们近期也推出云上首款 Serverless 化的金融消息队列 TDMQ(Tencent Distributed Message Queue,简称 TDMQ),其极好的云原生和

1K31

MQ 系列之初识消息中间件

1.1 简介 1.1.1 概述   消息中间件(MQ)适用于需要可靠的数据传送的分布式环境。采用消息中间件机制的系统中,不同的对象之间通过传递消息来激活对方的事件,完成相应的操作。...淘宝的 MySQL 集群内部有使用它进行通讯, OpenStack 开源云平台的通信组件,最先在金融行业得到运用。 Kafka:Kafka 是一个分布消息发布订阅系统。...1.3 几种中间件对比 1.3.1 对比表 特性 ActiveMQ RabbitMQ RocketMQ Kafka 单机吞吐量 万,吞吐量比 RocketMQ 和 Kafka 要低了一个数量级 万,...0 丢失 经过参数优化配置,消息可以做到 0 丢失 功能支持 MQ 领域的功能极其完备 基于 erlang 开发,所以并发能力很强,性能极其,延时很低 MQ 功能较为完善,还是分布式的,扩展性 功能较为简单...RocketMQ 接口简单易用,而且毕竟在阿里大规模应用过,有阿里品牌保障,日处理消息上百亿之多,可以做到大规模吞吐,性能也非常分布式扩展也很方便,社区维护还可以,可靠性和可用性都是 ok 的,还可以支撑大规模的

49620

【TEGer 在全球架构师峰会】 : 腾讯企业消息中间件 CMQ 技术解密

目前专注于于分布式服务开发与治理平台TSF的建设。 大规模分布式系统的快速发展使得消息中间件已经成为系统间通信的核心手段。...本文将对腾讯TEG基础架构部中间件团队研发的企业消息中间件CMQ原理进行分享介绍。...中间件团队消息队列发展历程: [3631gssrfr.png] CMQ/CKafka/MQ for IoT本质上都属于分布消息中间件分布消息系统的最大特点是可扩展性。...3.Module是根据系统行为提前定义的正确性验证模型,Checker结合Module分析history输出测试报告。...总结 本文主要腾讯基础架构部消息中间件发展历程进行简要介绍,重点对金融消息中间件CMQ核心原理进行分享,除此之外,中间件团队针对大数据领域常用的kafka进行优化改进推出了CKafka,在相同条件下小于

2.1K91

消息中间件的对比

消息中间件性能究竟哪家强? 引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。...现在开源的消息中间件有很多,前段时间我们自家的产品 RocketMQ (MetaQ的内核) 也顺利开源,得到大家的关注。 那么,消息中间件性能究竟哪家强?...RocketMQ是阿里开源的消息中间件,它是纯Java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。...RabbitMQ 是使用Erlang编写的一个开源的消息队列,本身支持很多的协议:AMQP,XMPP, SMTP, STOMP,也正是如此,使的它变的非常重量级,更适合于企业的开发。...Apache Kafka相对于ActiveMQ是一个非常轻量级的消息系统,除了性能非常之外,还是一个工作良好的分布式系统。

1.7K00

消息中间件选型

十万 时效性 ms以内 us(微秒) ms ms 可用性 非常高(分布式架构) 高(主从架构) 非常高(分布式架构) 高(主从架构) 功能特性 只支持主要的 MQ功能,像一些消息查询...并发能力很强,性能及其,延迟极低,管理界面丰富 MQ功能比较完备,扩展性强 成熟的产品,在很多公司得到应用,有很多成熟的文档,支持各种协议 一、中间件选型 ---- Kafka Kafka 是 LinkedIn...号称大数据的杀手锏,谈到大数据领域内的消息传输,则绕不开Kafka,这款为大数据而生的消息中间件,以其百万TPS(单机写入TPS约在百万条/秒**)**的吞吐量名声大噪,迅速成为大数据领域的宠儿,在数据采集...RocketMQ RocketMQ是阿里开源的消息中间件,它是纯 Java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。...消息可靠性非常高,经过参数优化配置,消息可以做到0丢失。MQ功能较为完善,还是分布式的,扩展性。支持10亿别的消息堆积,不会因为堆积导致性能下降。

1.8K20

【金猿信创展】恒生电子——全栈式信创解决方案,助力金融信创行稳致远

核心技术及产品突破 1、分布式微服务中间件Light-JRES Light-JRES是面向金融领域的企业应用快速开发平台和多系统融合平台,既减轻对基础设施的依赖,又从业务上具备可复用、可扩展、高安全的特性...JRES中间件是实现对通用技术组件的服务化,譬如:分布式缓存、消息队列、分布式事务等等,通过应用共享以及多租户隔离实现技术组件最大程度复用,降低系统的资源消耗让技术组件和业务公共模块下沉,从而做到支持业务的快速创新和迭代...2、分布式低延时中间件Light-LDP Light-LDP是具有集低延时、分布式解耦、灵活开放等特点的开发平台,支持金融机构微秒业务应用,主要面向券商自营、券商资管以及券商机构业务的策略交易、算法交易...3、金融分布式数据库LightDB LightDB是一款支持在线事务处理与在线分析处理的融合型分布式数据库,具备SQL兼容性高、容量弹性伸缩、金融高可用、现代硬件融合、纯内存计算等核心特性,适用于对可用性...LightDB具有“更快、更稳、更懂金融”的企业特性:采用单机分布式一体化架构,同时支持集中式和分布式部署,在长时间高负载压测下抖动很低;性能方面,在同机房高可用信创软硬件下、单节点进行证券典型订单TPS

99030

Kafka、RabbitMQ、RocketMQ消息中间件的对比 —— 消息发送性能-转自阿里中间件

引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品 RocketMQ (MetaQ的内核) 也顺利开源,得到大家的关注。...那么,消息中间件性能究竟哪家强? 带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了性能比较。...Kafka是LinkedIn开源的分布式发布-订阅消息系统,目前归属于Apache定级项目。Kafka主要特点是基于Pull的模式来处理消息消费,追求高吞吐量,一开始的目的就是用于日志收集和传输。...RocketMQ是阿里开源的消息中间件,它是纯Java开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。...在同步发送场景中,三个消息中间件的表现区分明显: Kafka的吞吐量高达17.3w/s,不愧是高吞吐量消息中间件的行业老大。这主要取决于它的队列模式保证了写磁盘的过程是线性IO。

1.7K40

一文带你读懂中间件

得益于政府、金融、电信等行业信息化建设的提速,以及用户对基于云的分布式应用服务、消息队列等中间件工具的需求增长,未来,中间件市场将保持稳定增长的态势。...基础中间件 中间件产生之初主要解决分布式环境下软件性能和可靠性的问题,包括交易中间件消息中间件等。此后,为满足应用软件在不同硬件平台、网络环境下运行的需求,应用服务器中间件随之出现。...交易中间件适用于联机交易系统,如银行业务系统、订票系统等,在金融、财税、电信等行业中得到广泛落地。 消息中间件解决了分布式计算环境下多个子系统间的消息通信问题。...2019年,公司获得华为优选认证服务解决方案伙伴认证,多款产品通过华为自有数据库、操作系统的兼容性认证。 金蝶天燕 公司是基础软件行业的软件开发商,成立于2000年,2017年于新三板挂牌上市。...团队自主研发的一系列产品在2007年底开始的淘宝架构2.0到3.0变迁过程中,使淘宝网从集中式的Java应用走向了分布式Java应用,涵盖消息中间件、服务框架、数据层、应用服务器和大规模分布式稳定性平台等

3.7K40

Serverless 云函数支持 TDMQ 触发器 - 更高效的消息队列触发方式

Serverless 与消息队列生态结合 消息队列 MQ 是 Serverless 事件驱动场景下必要的解耦中间件也是云函数最重要的触发源之一。...TDMQ 是一款基于 Apache 顶级开源项目 Pulsar 自研的金融分布消息中间件。...功能优势 TDMQ 能够高效支持百万消息生产和消费,海量消息堆积且消息堆积容量不设上限,支撑腾讯计费所有场景;性能方面,单集群 QPS 超过 10 万,同时在时耗方面有保护机制来保证低延迟,可轻松应对的海量数据触发函数...TDMQ 提供丰富的消息类型,涵盖普通消息、顺序消息(全局顺序 / 分区顺序)、分布式事务消息、定时消息,满足各种严苛触发器函数的场景下的高级特性需求。...扫码即可免费体验 免费体验路径:云产品体验->基础->消息队列CKafka 消息队列TDMQ 一款基于 Apache 顶级开源项目 Pulsar 自研的金融分布消息中间件

3.8K20

谈谈你对MQ(消息中间件)的理解

1、什么是MQ MQ全称是Message Queue,直译过来叫做消息队列,主要是作为分布式应用之间实现异步通信的方式。 主要由三个部分组成,分别是生产者、消息服务端和消费者。...服务提供方(生产者)只需要将协商消息发送到消息队列,之后的处理就由消费者,也不需要等待消费者的返回结果。...3、如何选择MQ 目前,主流的消息中间件有ActiveMQ、RabbitMQ、Kafka、RocketMQ、Pulsar。在技术选型的时候,可以根据具体的业务需求更合适的中间件。...数据量大、吞吐量要求比较高的场景一般采用Kafka; 对消息可靠性要求很高,甚至要求支持事务的场景,比如金融互联网,可以选择RocketMQ; 对于中小型公司来说, 可以选择RabbitMQ,它利用erlang...语言本身的并发优势,性能 在微秒

87410

应对流量高峰的利器——消息中间件

引言 大家,我是小❤。 周末和朋友一起自驾去海边玩,去过杨梅坑的应该都知道,从杨梅坑到鹿嘴山庄需要坐快艇过去。...在分布式系统里面,实现消费队列的一种主要方式就是采用消息中间件。 什么是消息中间件 消息中间件(Message Broker)是一种在分布式系统中用于传递消息、通知和事件的基础架构组件。...适用场景: RocketMQ 适用于需要高性能、低延迟、可扩展性的大规模应用,如电商平台、金融系统、物联网应用等。 5....Kafka 特点: Kafka 是一款高吞吐量、低延迟的分布消息中间件,适用于大规模数据处理和实时流处理。 主要用于发布-订阅模型,将消息以日志形式存储。...建议在选择消息中间件之前仔细评估你的应用需求,并根据具体情况进行选择。 当然,无论选择哪种消息中间件,都需要深入了解其特点和使用方式,以确保它能够满足应用需求,以构建高效、可靠的分布式系统。 8.

26450

RocketMq消息中间件分布式事务消息实现原理

一.消息中间件 1.1消息中间件本质 一次RPC变成两次RPC、内容存储和择机投递;基于消息的通信模式,从关注处理到关注通知。 ?...1.2 消息中间件的使用场景 解耦 解耦是消息中间件解决的最本质问题,核心业务只关心通知,不关心处理结果 最终一致性 可以用消息中间件实现微服务之间状态的最终一致性(只是理论上的,...支持 API完整性 高 高 高 高 多语言支持 支持 Java优先 语言无关 只支持Java 支持 Java优先 单机吞吐量 万 十万 消息延迟 微妙 毫秒 毫秒 高可用性 高...(主从) 高(主从) 非常高(分布式) 非常高(分布式) 消息丢失率 低 低 理论上不会丢失 理论上不会丢失 消息重复性 业务控制 业务控制 业务控制 参考文档完整性 高 高 高 高 提供快速入门 有...六 rocketmq分布式事务消息原理设计 具体可以查阅接下来的文章。

1K40

鹅厂中间件产品遭遇暴风吐槽

为了更好地服务使用微服务架构进行软件设计的企业,腾讯云中间件产品基于腾讯在微服务、消息队列领域多年的技术积累,提供了功能强大、兼容并包、生态开放的云原生分布式微服务解决方案和消息队列服务。...全方位打造出7款优秀产品:微服务平台 TSF、消息队列CKafka、金融消息队列TDMQ、微服务观测平台 TSW、弹性微服务 TEM、微服务引擎TSE、分布式事务DTF,全面布局云原生领域产品矩阵。...另外,腾讯云还始终积极对外贡献技术力量,参与了《中间件技术和产业白皮书》的编写,以及《工业互联网平台微服务》国家标准和《消息中间件技术标准》的讨论与制定。...经过多年匠心打磨,腾讯中间件产品已在金融、政府、能源、制造业等行业得到了大规模的应用,但是用户在使用的过程中,到底是什么感受呢?...福利大放送 对于本期“腾讯云中间件-微服务与消息队列产品”吐槽大会,你有什么想说的话?在留言区写下你对专题会议的期待,点击「在看」,并配上文案“腾讯云中间件,面对疾风吧!”

90220

腾讯云中间件产品面对疾风吧——TVP吐槽大会第4期

KV.jpg 为了更好地服务使用微服务架构进行软件设计的企业,腾讯云中间件产品基于腾讯在微服务、消息队列领域多年的技术积累,提供了功能强大、兼容并包、生态开放的云原生分布式微服务解决方案和消息队列服务...全方位打造出6款优秀产品:微服务平台 TSF、消息队列CKafka、金融消息队列TDMQ、微服务观测平台 TSW、微服务引擎TSE、分布式事务DTF,全面布局云原生领域产品矩阵。...另外,腾讯云还始终积极对外贡献技术力量,参与了《中间件技术和产业白皮书》的编写,以及《工业互联网平台微服务》国家标准和《消息中间件技术标准》的讨论与制定。...在云原生2.0时代,腾讯云致力于为企业提供更加完善的分布式架构解决方案,帮助企业加速数字化建设,快速实现架构升级。...经过多年匠心打磨,腾讯中间件产品已在金融、政府、能源、制造业等行业得到了大规模的应用,但是用户在使用的过程中,到底是什么感受呢?

1.1K91

分布式架构设计篇(五)-刚性事务之2PC详解

上述场景就是分布式一致性问题,追根到底,分布式一致性的根本原因在于数据的分布式操作,引起的本地事务无法保障数据的原子性引起。...分布式一致性问题的解决思路有两种,一种是分布式事务,一种是尽量通过业务流程避免分布式事务。分布式事务是直接解决问题,而业务规避其实通过解决出问题的地方(解决提问题的人)。...,中文名是二阶段提交,是XA规范的实现思路,XA规范是 X/Open DTP 定义的交易中间件与数据库之间的接口规范(即接口函数),交易中间件用它来通知数据库事务的开始、结束以及提交、回滚等。...一般,常见的事务管理器( TM )是交易中间件,常见的资源管理器( RM )是数据库,常见的通信资源管理器( CRM )是消息中间件。...林淮川 毕业于西安交通大学;奈学教育《百万架构师训练营》讲师及企业源码内源负责人,前大树金融高级架构师;前大树金融技术委员会开创者;前大树金融供应链金融技术总监;前天阳宏业交易事业部技术主管;多年互联网金融行业

1.7K1818

秒懂消息队列MQ,看这篇就够了!

消息队列是大型分布式系统不可缺少的中间件,也是高并发系统的基石中间件,所以掌握好消息队列MQ就变得极其重要。接下来我就将从零开始介绍什么是消息队列?消息队列的应用场景?如何进行选型?...消息中间件是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的构建。...消息中间件分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削峰等问题,实现高性能,高可用,可伸缩和最终一致性的系统架构。...以下是关于各个消息队列中间件的选型对比: 特性 Kafka RocketMQ RabbitMQ ActiveMQ 单机吞吐量 10万 10万 10万 开发语言 Scala Java Erlang...Java 高可用 分布分布式 主从 分布消息延迟 ms ms us ms 消息丢失 理论上不会丢失 理论上不会丢失 低 低 消费模式 拉取 推拉 推拉 持久化 文件 内存,文件 内存

5.5K14

腾讯云中间件产品面对疾风吧——TVP吐槽大会第4期

KV.jpg 为了更好地服务使用微服务架构进行软件设计的企业,腾讯云中间件产品基于腾讯在微服务、消息队列领域多年的技术积累,提供了功能强大、兼容并包、生态开放的云原生分布式微服务解决方案和消息队列服务...全方位打造出6款优秀产品:微服务平台 TSF、消息队列CKafka、金融消息队列TDMQ、微服务观测平台 TSW、微服务引擎TSE、分布式事务DTF,全面布局云原生领域产品矩阵。...另外,腾讯云还始终积极对外贡献技术力量,参与了《中间件技术和产业白皮书》的编写,以及《工业互联网平台微服务》国家标准和《消息中间件技术标准》的讨论与制定。...在云原生2.0时代,腾讯云致力于为企业提供更加完善的分布式架构解决方案,帮助企业加速数字化建设,快速实现架构升级。...经过多年匠心打磨,腾讯中间件产品已在金融、政府、能源、制造业等行业得到了大规模的应用,但是用户在使用的过程中,到底是什么感受呢?

89440
领券