整合所有内容

DeepSeek V3 中英对照 Putting it All Together

以下配置创建了一个名为 myDestination 的交换器，并将队列 myDestination.consumerGroup 绑定到一个主题交换器上，使用通配符路由键 #：

---
spring.cloud.stream.bindings.input.destination=myDestination
spring.cloud.stream.bindings.input.group=consumerGroup
#disable binder retries
spring.cloud.stream.bindings.input.consumer.max-attempts=1
#dlx/dlq setup
spring.cloud.stream.rabbit.bindings.input.consumer.auto-bind-dlq=true
spring.cloud.stream.rabbit.bindings.input.consumer.dlq-ttl=5000
spring.cloud.stream.rabbit.bindings.input.consumer.dlq-dead-letter-exchange=
---

none

此配置创建了一个绑定到直接交换器（DLX）的死信队列（DLQ），路由键为 myDestination.consumerGroup。当消息被拒绝时，它们会被路由到 DLQ。5 秒后，消息过期并使用队列名称作为路由键重新路由到原始队列，如下例所示：

@SpringBootApplication
public class XDeathApplication {

    public static void main(String[] args) {
        SpringApplication.run(XDeathApplication.class, args);
    }

    @Bean
    public Consumer<Message<String>> listen() {
        return message -> {
            Map<?,?> death = message.getHeaders().get("x-death");
            if (death != null && death.get("count").equals(3L)) {
                // giving up - don't send to DLX
                throw new ImmediateAcknowledgeAmqpException("Failed after 4 attempts");
            }
            throw new AmqpRejectAndDontRequeueException("failed");
        };
    }

}

java

请注意，x-death 头中的 count 属性是一个 Long 类型。