Java 中 RabbitMQ 怎么使用 ReturnListener 回调感知因没有匹配到合适队列而被退回的消息

云丽姑娘_5968

云丽姑娘_5968

2026-07-25

701人浏览

原创

当mandatory=true且消息无法路由时,rabbitmq将消息退回生产者,spring amqp通过returncallback捕获该事件,需配合confirmcallback实现完整投递链路监控。

java 中 rabbitmq 怎么使用 returnlistener 回调感知因没有匹配到合适队列而被退回的消息

在 RabbitMQ 中,当生产者发送消息到 Exchange,但没有匹配到任何绑定的 Queue(比如路由键不匹配、队列不存在或未绑定),且消息设置了 mandatory = true 时,RabbitMQ 会将消息退回给生产者。此时可通过 ReturnListener(现推荐使用 ConfirmCallback + ReturnCallback 组合)来捕获这类“被退回”的消息。

启用 mandatory 并注册 ReturnCallback

ReturnCallback 是 Spring AMQP 中处理 mandatory 退信的核心机制。它只在消息因路由失败被 Broker 主动退回时触发,不是所有失败都走这里(比如连接断开、Broker 不可用等走 ConfirmCallback 的 nack)。

  • 必须在发送时设置 messageProperties.setDeliveryMode(MessageDeliveryMode.PERSISTENT) 非必需,但建议;关键是要设 messageProperties.setMandatory(true)
  • 通过 RabbitTemplate.setReturnCallback() 注册回调,该回调会在消息被退回时被调用
  • 注意:ReturnCallback 是 Spring 提供的抽象,底层依赖 AMQP 协议的 basic.return 方法,需 Broker 支持(默认开启)

ReturnCallback 的典型用法

实现 ReturnCallback 接口,重写 returnedMessage 方法,可获取退回原因、响应码、响应文本、交换器名、路由键等信息:

rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
    String msgBody = new String(message.getBody(), StandardCharsets.UTF_8);
    System.err.println("消息被退回:body=" + msgBody
            + ", replyCode=" + replyCode
            + ", replyText=" + replyText
            + ", exchange=" + exchange
            + ", routingKey=" + routingKey);
    // 可记录日志、存库、重发、告警等
});

常见 replyCode 示例:312(NO_ROUTE)、313(NO_CONSUMERS),replyText 通常是 "No route to queue" 或 "No consumers for queue"。

Learn Docker
Learn Docker

通过 LabEx 容器基础课程和镜像/编排实验学习 Docker。Docker 课程和实验通过 LabEx MCP 获取,返回 labex.io 链接以继续。

下载

配合 ConfirmCallback 确保整体可靠性

ReturnCallback 只管“退信”,不保证消息是否成功到达 Broker。要完整监控投递链路,还需启用发布确认:

  • 配置 spring.rabbitmq.publisher-confirm-type: correlated(推荐)
  • 设置 rabbitTemplate.setConfirmCallback() 处理 ack/nack
  • 只有在 confirm 回调返回 ack 后,才可能触发 return 回调(即消息已抵达 Broker 并被判定无法路由)
  • 若 confirm 是 nack(如网络中断、Broker 拒绝),则不会进入 return 流程

验证场景与注意事项

测试 mandatory 退信需构造明确的不可达条件:

  • 向一个 direct exchange 发送消息,但 routingKey 与所有绑定队列都不匹配
  • 向一个 topic exchange 发送消息,routingKey 完全不满足任何 binding pattern
  • Exchange 存在但未绑定任何 Queue(空 Exchange)
  • 确保消费者端没有 auto-delete 队列干扰测试(建议手动声明队列并持久化)

注意:mandatory=false 时,不匹配的消息会被静默丢弃,不会触发 ReturnCallback;mandatory=true 才可能退回。

Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

rabbitmq linux docker java

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

2023.06.15

10757

6

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

2023.07.05

7862

9

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

2023.07.31

6832

8

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.01

1164

3

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.02

948

3

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

1396

5

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

2829

5

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

2023.08.03

20131

3

配置java环境变量
配置java环境变量

配置Java环境变量是为了让操作系统能够识别和使用Java的相关命令和功能。本专题为大家提供配置java环境变量相关文章,帮助大家解决问题。

2023.08.03

1255

8

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
RabbitMQ 入门教程
RabbitMQ 入门教程

共0课时 | 137人学习

RabbitMQ 教程手册
RabbitMQ 教程手册

共0课时 | 0人学习

RabbitMQ 官方文档
RabbitMQ 官方文档

共0课时 | 0人学习