美文网首页
分布式消息服务DMS如何实现死信消息的消费

分布式消息服务DMS如何实现死信消息的消费

作者: 中间件小哥 | 来源:发表于2018-07-06 16:33 被阅读0次

(本文部分内容节选自华为云帮助中心的分布式消息服务(DMS)服务的产品介绍)

死信消息是什么

死信消息是指无法被正常消费的消息。分布式消息服务DMS支持对消息进行异常处理。当消息进行多次重复消费仍然失败后,DMS会将该条消息转存到死信队列中,有效期为72小时,用户可以根据需要对死信消息进行重新消费。消费死信消息时,只能消费该消费组产生的死信消息。全局有序的普通队列的死信消息依然按照先入先出(FIFO)的顺序存储在死信队列中。

如何消费死信消息

消费指定消费组产生的死信消息。可同时消费多条消息,每次消费的消息负载不超过512KB。仅NORMAL队列和FIFO队列可以开启死信消息,因为只有NORMAL队列和FIFO队列可消费死信消息。

URI

GET /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters?max_msgs={max_msgs}&time_wait={time_wait}&ack_wait={ack_wait}

参数说明请参见下表:

如何确认已消费死信消息

在消费者消费死信消息期间,死信消息仍然停留在队列中,但死信消息从被消费开始的30秒内不能被该消费组再次消费,若在这30秒内没有被消费者确认消费,则DMS认为死信消息未消费成功,将可以被继续消费。

如果死信消息被确认消费成功,该死信消息将不能被该消费组再次消费,死信消息的保留时间为72小时(除非消费组被删除),72小时后会被删除。

消息批量消费确认时,必须严格按照消息消费的顺序提交确认,DMS按顺序判定消息是否消费成功,如果某条消息未确认或消费失败,则不再继续检测,默认后续消息全部消费失败。建议当对某一条消息处理失败时,不再需要继续处理本批消息中的后续消息,直接对已正确处理的消息进行确认。

注意,仅NORMAL队列和FIFO队列可以开启死信消息,因为只有NORMAL队列和FIFO队列可消费死信消息。

URI

POST /v1.0/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters/ack

以上就是对分布式消息服务DMS如何实现死信消息的消费的介绍,想要了解更多,欢迎点击分布式消息服务DMS查看。

相关文章

  • 分布式消息服务DMS如何实现死信消息的消费

    (本文部分内容节选自华为云帮助中心的分布式消息服务(DMS)服务的产品介绍) 死信消息是什么 死信消息是指无法被正...

  • RabbitMQ实现消息的最终一致性

    通过rabbit死信队列实现消息的最终一致性 配置消费队列 配置死信队列 被拒绝的消息会进入死信队列 正常数据消费...

  • 消息队列应用场景解析

    分布式消息服务DMS是完全托管的高性能消息队列服务,提供普通队列、有序队列、Kafka、ActiveMQ、Rabb...

  • RabbitMQ实现延迟消费

    RabbitMQ实现延迟消费 rabbitMQ没有能直接设置消息延迟消费的功能; 但是可以用消息超时,加入死信队列...

  • SpringBoot整合RabbitMQ——RabbitMQ进阶

    rabbitMQ如何保证如果消息发送失败,保证其消息不丢失、怎么设置消息过期时间以及死信队列是如何在消息消费失败时...

  • RabbitMQ死信队列在SpringBoot中的使用

    死信队列可以实现消息在未被正常消费的场景下,对这些消息进行其他处理,保证消息不会被丢弃。 # 概念: 消息会变成死...

  • RabbitMQ项目使用之死信队列

    消息消费失败处理方式: 一 进入死信队列(进入死信的三种方式) 1.消息被拒绝(basic.reject or b...

  • SpringBoot+RabbitMQ 死神队列

    前言 死信:无法被消费的消息,称为死信。 如果死信一直留在队列中,会导致一直被消费,却从不消费成功。 所以我们专门...

  • RabbitMQ 死信队列详解

    一、死信的概念 死信,顾名思义就是无法被消费的消息。一般来说,Producer 将消息投递到 Broker 或者直...

  • Spring RabbitMQ 死信机制

    采用死信机制的好处是可以提高系统的稳定性,当消息消费失败后,消息进入死信队列,可以对消息进行补偿,可以达到最终一致...

网友评论

      本文标题:分布式消息服务DMS如何实现死信消息的消费

      本文链接:https://www.haomeiwen.com/subject/lglbuftx.html