spring-cloud-stream — Retry With the RabbitMQ Binder

灰太狼 2022-06-11 06:59 143阅读 0赞

#### A simplified diagram of how the RabbitMQ binder operates can be seen below. ####

![这里写图片描述][rabbit-binder.png]

#### The RabbitMQ Binder implementation maps each destination to a TopicExchange. For each consumer group, a Queue will be bound to that TopicExchange. Each consumer instance have a corresponding RabbitMQ Consumer instance for its group’s Queue. For partitioned producers/consumers the queues are suffixed with the partition index and use the partition index as routing key. ####

#### Using the autoBindDlq option, you can optionally configure the binder to create and configure dead-letter queues (DLQs) (and a dead-letter exchange DLX). The dead letter queue has the name of the destination, appended with .dlq. If retry is enabled (maxAttempts > 1) failed messages will be delivered to the DLQ. If retry is disabled (maxAttempts = 1), you should set requeueRejected to false (default) so that a failed message will be routed to the DLQ, instead of being requeued. In addition, republishToDlq causes the binder to publish a failed message to the DLQ (instead of rejecting it); this enables additional information to be added to the message in headers, such as the stack trace in the x-exception-stacktrace header. This option does not need retry enabled; you can republish a failed message after just one attempt. ####

> Setting requeueRejected to true will cause the message to be requeued and redelivered continually, which is likely not what you want unless the failure issue is transient. In general, it’s better to enable retry within the binder by setting maxAttempts to greater than one, or set republishToDlq to true.

--------------------

> **spring.cloud.stream.bindings..consumer.maxAttempts**

--------------------

> If processing fails, the number of attempts to process the message (including the first). Set to 1 to disable retry.
> 
> Default: 3.

[http://docs.spring.io/spring-cloud-stream/docs/Chelsea.RC1/reference/htmlsingle/index.html\#\_rabbitmq\_binder\_overview][http_docs.spring.io_spring-cloud-stream_docs_Chelsea.RC1_reference_htmlsingle_index.html_rabbitmq_binder_overview]

[rabbit-binder.png]: /images/20220611/a86d8edae55c4f6a835a53a0d3d13186.png
[http_docs.spring.io_spring-cloud-stream_docs_Chelsea.RC1_reference_htmlsingle_index.html_rabbitmq_binder_overview]: http://docs.spring.io/spring-cloud-stream/docs/Chelsea.RC1/reference/htmlsingle/index.html#_rabbitmq_binder_overview