首页 > 其他分享 >一文带你认知定时消息发布RocketMQ

一文带你认知定时消息发布RocketMQ

时间:2022-08-19 11:44:17浏览次数:92  
标签:场景 认知 华为 DMS 消息 消息中间件 定时 RocketMQ

摘要:DMS任意时间定时消息能力发布。

DMS是华为云的分布式消息中间件服务。适用于解决分布式架构中的系统解耦、跨系统跨地域数据流通、分布式事务协调等难题,协助构建优雅的现代化应用架构,提供可兼容 Kafka/RabbitMQ/RocketMQ 开源系统的云服务。

DMS是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。

近期,DMS服务正式上线任意时间定时消息特性,带来了灵活、精确、高性能的消息定时能力支持。

DMS rocketMQ定时消息功能流程图

为什么需要定时消息

随着互联网技术的蓬勃发展,各公司的业务场景变得越来越纷繁复杂。对于精确度、高并发、高可靠的要求也达到了一个前所未有的高度。

在这些复杂的业务场景中,定时调度场景,尽管有着十分庞大和迫切的需求,却缺乏一个“完美”的一站式解决方案。

对于定时消息需求稍低的企业会使用一些消息中间件“残血版”的开源来实现定时调度。有的企业对于定时消息的吞吐量和精确度有着非常高的要求,往往会在消息中间件的基础上自建 Serverless 定时消息中台。如:使用 Amazon SNS 服务实现的 Serverless 定时器

华为云 DMS 定时消息能力的优势

华为云 DMS 上线的定时消息能力在开源消息中间件和各大云厂商提供的定时能力中处于领先地位,能够提供毫秒级精确度、最大长达一年的定时消息能力。对于高度依赖定时消息中台的场景、华为云 DMS 定时消息能够支撑万级吞吐量。后续会上线 Serverless 能力,做到动态伸缩,同时满足低成本和高性能的诉求。

下面介绍一下华为云 DMS 定时消息的功能亮点:

  • 任意时间:能够支持 1 年内任意时间的定时消息。
  • 高精度:定时精度达到毫秒级(在无堆积情况下)。
  • 高性能:接近于普通消息的吞吐量。
  • 高可靠:不会丢失定时消息。
  • 支持取消:在定时消息未投递前支持取消。
  • 可观测性:可查询定时消息。

定时消息最佳实践

在用户发起订单的场景下,需要在一定时间(如 5 分钟)后自动关闭未支付的订单。我们需要一个定时机制按时触发订单关闭的逻辑。此时正式定时消息发挥作用的时刻:在下单时发送一条定时在 5 分钟后投递的定时消息,用它触发关闭订单的逻辑。如果用户支付了订单,可以将之前的定时消息取消。

此外,对于需要大量任务定时调度的场景,可以基于DMS定时消息能力构建一个定时调度中台。依靠DMS定时消息的高吞吐量,可以实现数十万任务并发调度。

除此之外,定时调度还能应用于更多其他场景,如定时提醒、等待重试、事件预订等等。

订单场景流程图

未来展望

华为云已经上线分布式消息服务 RocketMQ 版任意时间定时消息特性。

点击使用

华为云 DMS 版本正在快速演进中,后续将引入 Serverless 架构,在高可靠高可用基础上消息服务基础上,提供动态扩缩容能力,从容应对流量洪峰,在流量低谷时缩容。按需计费,动态管理企业业务成本,达到降本增效的效果。

 

点击关注,第一时间了解华为云新鲜技术~

标签:场景,认知,华为,DMS,消息,消息中间件,定时,RocketMQ
From: https://www.cnblogs.com/huaweiyun/p/16601488.html

相关文章

  • 定时任务Quartz、elastic-job、xxl-job对比
    一、概述Quartz:Java上的定时任务标准。但Quartz关注点在于定时任务而非数据,并无一套根据数据处理而定制化的流程。虽然Quartz可以基于数据库实现作业的高可用,但缺少分布......
  • ETL认知
    作者:herain链接:https://www.zhihu.com/question/264690762/answer/2431424917来源:知乎著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。ETL绝不是......
  • windows定时任务执行python爬虫
    有一些定时爬取的操作,适合用定时任务去执行。个人单独用的项目不适合放在工作所用的服务器上,也没必要单独买个服务器,我们windows电脑本身就有这项功能。接下来是一个wi......
  • 不用定时器用接收超时做超时处理
    [原始代码]while(1){/*接收感兴趣的事件WRITE_EVENT,以永久等待方式去接收*/if(rt_event_recv(recvdata_event,WRITE_EVENT,RT_EVENT_FLAG_OR|RT_EV......
  • linux-crontab每分钟定时执行
    [root@tingnan-DB3tandelindata]#servicecrondrestart#重启定时任务,有restart和reload两个命令[root@tingnan-DB3tandelindata]#servicecrondstatus#查看执......
  • RocketMQ 消息过滤
    一、概述RocketMQ的消费者可以根据Tag进行消息过滤,也支持自定义属性过滤。消息过滤目前是在Broker端实现的,优点是减少了对于Consumer无用消息的网络传输,缺点是增加了B......
  • Jenkins 定时任务
    每次手动触发job构建,是很麻烦的一件事情,job中可以配置定时构建,今天就来分享下定时构建;构建分为两种:定时构建和轮询SCM。一.定时构建Jenkins采用了著名的UNIX任务调度工......
  • spring boot 定时任务使用
    1.在Springboot启动类上添加注解:@EnableScheduling2.在需要执行定时任务的类上加@Component注解,在需要执行的方法上加@Scheduled(cron="0/2*****")注解@Compon......
  • RocketMQ 消息存储机制
    一、概述RocketMQ中的消息存储在本地文件系统中,主要是由ConsumeQueue和CommitLog配合完成的,消息真正的物理存储文件是CommitLog,ConsumeQueue是消息的逻辑队列,类似数据......
  • big endian (comes from RocketMQ)
    #ifndefBASE_BIG_ENDIAN_H_#defineBASE_BIG_ENDIAN_H_ template<typenameT>inlinevoidReadBigEndian(constcharbuf[],T*out){*out=buf[0];......