如何消费Spring云流默认死信队列的消息？
spring:
cloud:
stream:
rabbit:
default:
consumer:
auto-bind-dlq: true
republish-to-dlq: true
dead-letter-queue-name: my-dlq
共有1个答案
没有什么内置的，但文档显示了一些技术...
因为您无法预测用户希望如何处理死文消息，所以该框架没有提供任何处理它们的标准机制。如果死字的原因是暂时的，您可能希望将消息路由回原始队列。但是，如果该问题是一个永久性问题，则可能导致无限循环。下面的Spring Boot应用程序展示了一个示例，说明如何将这些消息路由回原始队列，但在三次尝试后将它们移动到第三个“停车场”队列。第二个示例使用RabbitMQ延迟消息交换为重新排队的消息引入延迟。在本例中，每次尝试时延迟都会增加。这些示例使用@RabbitListener从DLQ接收消息。您还可以在批处理过程中使用RabbitTemplate.receive（）。
...
-
这种需求类似于通过公开的REST服务API（Spring Boot）处理来自死信队列的消息。以便一旦调用REST服务,就会从DL队列中消耗一条消息,并将再次发布到主队列中进行处理。@RabbitListener(queues=“queue_name”）立即使用消息，这在场景中是不需要的。该消息只需由REST服务API使用。有什么建议或解决办法吗？
-
我正在使用带有Avro和汇流模式注册表的Spring云流。我正在为所有服务使用一个单独的DLQ主题，因此具有不同模式的消息可能会落在这个主题中。我已禁用动态架构注册，以确保不传递错误消息()。 然而，问题是由于dlq上缺少模式，我可能会在进入这个主题时丢失一条消息。因此，我希望能够以JSON格式向dlq生成消息，并在管道的其余部分使用Avro。如果有人能帮助我如何做到这一点，或者能为我指出这件事的
-
我目前正在使用带有的Kafka绑定器的Spring Cloud Stream为我的Spring Boot微服务执行消息记录。 我有： 生产者将消息发布到订阅频道 在消息从生产者发布到流并被消费者收听的整个过程中，可以观察到preSend方法被触发了两次： 一次在生产者端-消息发布到流时 然而，出于日志记录的目的，我只需要在消费者端截获并记录消息。 是否有任何方法可以仅在一侧（例如消费者侧）截获SC
-
主要内容：1 并发消费重试,1.1 失败重试,1.2 超时重试,2 顺序消费重试,2.1 失败重试,2.2 超时重试,3 broker处理回退请求,3.1 asyncConsumerSendMsgBack处理回退请求,3.2 handleRetryAndDLQ处理重试和死信消息基于RocketMQ release-4.9.3，深入的介绍了DefaultMQPushConsumer消费者重试消息和死信消息源码。 消费重试：并发消费和顺序消费对于消费失败的消息均会有消息重试机制。 1 并发消费重试
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。
-
我有一个向rabbitmq发送消息的服务，消费者对消息进行一些操作并重新排队。 我可以成功地将初始消息发送给rabbitmq，但问题是，如果消息需要修改，我无法将任何已使用的消息重新发送给rabbitmq。 我试图用new创建一个新类，但“MyService”始终为空