当前位置: 首页 > Web前端 > HTML

腾讯云消息队列TDMQ系列产品正式上线公测,点击查看!

时间:2023-03-28 11:25:14 HTML

简介RocketMQ版消息队列(TDMQforRocketMQ,简称TDMQRocketMQ版)今日正式公测!TDMQRocketMQ是TDMQ系列产品中的分布式高可用消息队列服务。它兼容ApacheRocketMQ的各种组件和概念。RocketMQ4.6及以上版本的客户端修改权限几乎为零。欢迎大家扫描文末二维码体验一下!TDMQRocketMQ版本背景RocketMQ作为典型的业务处理消息队列,主要用于处理订单、支付、积分等业务类型。它对信息交换的准确性有着极高的要求。它的核心架构:producer端,server端(NameServer和Broker服务实例),consumer端很好的满足了这一点。TDMQRocketMQ版(TencentDistributedMessageQueueforRocketMQ)是腾讯公司打造的分布式消息队列产品,具有强一致性、高可靠、高性能等特点。兼容开源RocketMQ4.6及以上客户端,支持顺序消息、事务消息、集群/广播消费模式等原生能力,具有计算存储分离、弹性扩缩容的底层架构,广泛应用于各种电商、金融、游戏、政务等行业。TDMQRocketMQ版产品优势TDMQRocketMQ版可以更好的应对各种营销活动带来的流量冲击,非常适合时序性、事务性要求高的场景。应用。兼容开源,兼容ApacheRocketMQ各种组件和理念,支持RocketMQ4.6及以上版本客户端零改造接入,底层具有计算存储分离、灵活扩缩容的优势。资源隔离为了更好的适应云端上使用的场景,TDMQRocketMQ版本拥有多级资源结构,不仅实现了基于命名空间的虚拟隔离,还实现了集群维度的物理隔离。支持在命名空间维度为客户端配置权限校验,区分不同环境下的客户端,方便灵活。分片存储与开源版本不同的是,TDMQRocketMQ采用分片方式持久化消息数据,不易出现数据倾斜等问题。当由于扩容、机器故障等原因增加或删除节点时,不会触发再平衡,整个集群的吞吐量会急剧下降。丰富的消息类型支持普通消息、顺序消息、延迟消息、分布式事务消息等多种消息类型,支持消息重试和死信机制,满足各种业务场景。一台高性能的单机可以支持高达数万级的生产和消费吞吐量,分布式架构,无状态服务,水平扩展提升整个集群的吞吐量。简单易用免运维提供API接入接口,支持所有语言和版本的开源SDK。为腾讯云平台提供全套运维服务,实时监控告警,帮助用户快速发现和解决问题,保障服务可用性。TDMQRocketMQ版本主要能力普通消息普通消息是一种基本的消息类型,由生产者投递到指定的Topic后,供订阅该Topic的消费者消费。普通消息topic中的无序概念可以使用多个partitionnumber来提高消息生产和消费的效率,在吞吐量巨大的时候表现最好。序列消息部分序列消息:与普通消息类型相比,部分序列消息多了一个部分序列的特性。即在同一个分区下,它的消费者在消费消息时,严格按照生产者投递到分区的顺序进行消费。部分序列消息在保证一定顺序的同时,保留分区机制,提高性能。但是本地排序的消息并不能保证跨不同分区的排序。全局顺序消息:全局顺序消息最大的特点就是严格保证消息按照生产者投递的顺序被消费。因此,它使用单个分区来处理消息,用户无法自定义分区数量。与前两种消息类型相比,此类消息的性能较低。死信消息死信消息是指无法正常消费的消息。TDMQ在创建新订阅时会自动创建一个死信队列来处理这条消息(消费者决定与一个主题的订阅关系)。重试队列重试队列是为了保证消息被正常消费而设计的队列。当某些消息被消费者第一次消费,但没有收到正常响应时,就会进入重试队列。当重试次数达到一定次数后,会停止重试,投递到死信队列中。由于实际场景中可能存在的一些临时性、瞬态性问题(如网络抖动、服务重启等),导致消息无法及时处理,但在短时间后恢复正常。在这种场景下,重试队列的重试机制可以很好的解决此类问题。死信队列死信队列是一种特殊的消息队列,用于集中处理不能正常消费的消息。当一条消息在重试队列中达到一定的重试次数后仍无法正常消费时,TDMQ会判断该消息在当前情况下无法被消费,并将其投递到死信队列中。在实际场景中,可能会因为业务宕机、网络断开等原因导致一段时间内消息无法消费。这种场景下,消息不会立即被丢弃,死信队列会将消息持久化很长时间。找到对应的解决方案后,用户可以创建消费者订阅死信队列,完成当时无法处理的消息。加工。延迟消息TDMQRocketMQ版本支持自定义一定范围内的延迟消息。只需要在每条消息的消息属性中添加具体的延时参数即可实现。即使使用开源版本的RocketMQ客户端,也可以轻松扩展该能力。集群消费集群消费适用于每条消息只需要处理一次的场景。广播消费广播消费适用于每条消息都需要集群下的每个消费者处理的场景。应用场景异步解耦每笔交易订单数据需要被下游数十个业务系统关注,包括物品审批、发货、积分、流计算分析等,多个系统对消息的处理逻辑不一致,单个系统不可能适应每一个相关的业务。此时TDMQRocketMQ版本可以实现高效的异步通信和应用解耦,保证主站业务的连续性。企业不定期举办的一些削峰填谷营销活动、新品发布会、节日期间抢红包等,往往会带来暂时的流量高峰,这对各种后端应用系统是一个巨大的考验.TDMQRocketMQ版本现在可以承担缓冲区的角色,集中收集上游突然增加的请求,下游可以根据自己的实际处理能力消费请求消息。顺序发送和接收顺序消息的应用程序出现在业务场景中。例如,APP或游戏中采购和发货过程中的订单创建、支付、退款等流程,都是严格按照顺序执行的。类似于先进先出(FIFO)的原则,TDMQRocketMQ版本提供了一种专门针对这种情况的顺序消息特性,即GuaranteedMessageFIFO。产品体验入口腾讯云消息队列TDMQRocketMQ版已开放公测。欢迎到官网体验。进行公测的用户可移步“腾讯云中间件”微信公众号TDMQRocketMQ公测推文扫码进入TDMQRocketMQ官方用户群。群里有腾讯云消息队列团队的专业技术人员。有问题可以直接在群里回复,会有专业人员为你解答。