Spring Cloud Stream+RabbitMQ：StreamBridge.send()返回值能否作可靠发布确认？

先明确两者的本质区别 #

• StreamBridge.send()返回值：默认场景下，这个true仅仅意味着消息成功写入了Binder的本地发送缓冲区，并没有真正到达RabbitMQ Broker。只有当你配置了同步确认模式（比如spring.cloud.stream.rabbit.bindings.<output>.producer.confirm-type=SIMPLE），此时返回值才会对应Broker的确认结果——true代表Broker已确认接收，false或抛出异常代表失败。但同步模式会阻塞发送线程，影响吞吐量。
• 回调机制：这是RabbitMQ Binder提供的异步确认能力，通过RabbitProducerConfirmationCallback或者RabbitReturnCallback实现。不管是消息被Broker确认接收，还是路由失败（比如指定的队列不存在），你都能拿到明确的回调通知，还能获取失败的具体原因（比如错误码、描述）。这种方式不会阻塞发送线程，能更精准地处理投递失败的场景（比如重试、记录死信）。

哪种更可靠？ #

如果你的业务要求必须确保消息100%被Broker接收，那回调机制是更可靠的选择：

• 同步返回值的方式在高并发场景下容易因为阻塞影响性能，而且无法处理路由失败的细节（比如消息被退回的具体原因）。
• 回调机制能异步捕获所有投递结果，包括Broker的确认和路由失败的情况，方便你做针对性的补偿逻辑，比如重试三次后存入数据库待人工处理。

当然，如果你的业务对投递可靠性要求不高，或者能接受“本地发送成功即认为投递成功”的弱一致性，那仅用返回值也能满足需求，但这不是严格意义上的Broker级确认。

补充配置提示 #

如果要启用可靠的回调确认，需要在配置里开启：

# 开启发布确认
spring.cloud.stream.rabbit.bindings.<你的output通道名>.producer.confirm-type=CORRELATED
# 开启返回（处理路由失败）
spring.cloud.stream.rabbit.bindings.<你的output通道名>.producer.return=true

然后自定义RabbitProducerConfirmationCallback bean来处理确认回调，RabbitReturnCallback处理路由失败的回调。

内容的提问来源于stack exchange，提问作者Rod