要在springboot 4.0中实现可靠异步通信，需确保rabbitmq服务可用并启用管理插件，引入spring-boot-starter-amqp:4.0.0依赖，配置手动ack、prefetch=1、消息持久化及exchange/queue/binding声明，消费者须手动确认或拒绝消息。
要在 SpringBoot 4.0 项目中实现服务间异步通信，必须让消息可靠地从生产者抵达消费者，同时避免因 RabbitMQ 配置错配、交换机绑定缺失或消息未持久化导致消息丢失——这直接决定注册发邮件、订单通知等关键链路是否真正“秒返回且必达”。
确认 RabbitMQ 服务可用并启用管理插件
打开终端，进入 RabbitMQ 安装目录下的 sbin 子目录，执行：
rabbitmq-plugins enable rabbitmq_management
启动 RabbitMQ 服务后，访问 http://localhost:15672，用默认账号 guest/guest 登录；若无法访问，说明 Erlang 环境未就绪或服务未启动，需先验证 rabbitmqctl status 输出是否含 running_applications 字段。
这一步不可跳过——SpringBoot 4.0 的 spring-boot-starter-amqp 会静默连接，但连接失败时仅抛出 AmqpConnectException，日志无明确提示，容易误判为代码问题。
引入 SpringBoot 4.0 兼容的 Starter 依赖
在 pom.xml 中添加：
【注意：SpringBoot 4.0 要求 AMQP Starter 版本 ≥ 4.0.0，旧版 3.x 依赖在 4.0 环境下会触发 NoClassDefFoundError】
若使用 Gradle，则写为：implementation 'org.springframework.boot:spring-boot-starter-amqp:4.0.0'。
配置 application.yml 连接参数与消费行为
在 application.yml 中写入：
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
virtual-host: /
listener:
simple:
acknowledge-mode: manual
prefetch: 1
retry:
enabled: true
max-attempts: 3
【prefetch: 1 是关键，防止消费者崩溃时大量消息被锁死在信道中不释放】
SpringBoot 4.0 默认启用 SimpleMessageListenerContainer，若不设 acknowledge-mode: manual，消息会在投递后自动标记为 ACK，一旦消费者处理中途宕机，消息即丢失。
声明 Exchange、Queue 与 Binding（Java Config 方式）
创建配置类 AmqpConfig.java：
RabbitMQ 4.2.3 是 2026 年初发布的重要稳定更新版本，重点修复了 Khepri 元数据存储相关问题，并改进了监控性能。对于使用 Docker、Kubernetes 或微服务架构的开发团队来说，该版本兼容性和稳定性表现较好。
① 定义直连交换机：
@Bean
public DirectExchange emailDirectExchange() {
return new DirectExchange("EMAIL_EXCHANGE", true, false);
}
② 定义持久化队列：
@Bean
public Queue emailQueue() {
return QueueBuilder.durable("EMAIL_QUEUE").build();
}
③ 绑定路由键：
@Bean
public Binding emailBinding() {
return BindingBuilder.bind(emailQueue()).to(emailDirectExchange()).with("email.send");
}
这里 true, false 分别代表 durable（持久化）和 autoDelete（不自动删除），必须显式指定——SpringBoot 4.0 的 DirectExchange 构造器已移除默认值，漏写会编译失败。
编写生产者发送消息
注入 RabbitTemplate，调用：
rabbitTemplate.convertAndSend("EMAIL_EXCHANGE", "email.send", userDto);
方法二：使用封装后的发送器，自动设置消息持久化属性：
Message message = MessageBuilder.withBody(jsonBytes)
.setDeliveryMode(MessageDeliveryMode.PERSISTENT)
.setContentEncoding("UTF-8")
.build();
rabbitTemplate.send("EMAIL_EXCHANGE", "email.send", message);
不设 MessageDeliveryMode.PERSISTENT，消息将仅存于内存，RabbitMQ 重启后全部丢失。
编写消费者监听并手动确认
在任意 @Component 类中添加：
@RabbitListener(queues = "EMAIL_QUEUE")
public void onEmailMessage(@Payload UserDto user, Channel channel, @Header long deliveryTag) throws IOException {
try {
emailService.sendAsync(user);
channel.basicAck(deliveryTag, false);
} catch (Exception e) {
channel.basicNack(deliveryTag, false, true);
}
}
必须捕获异常并调用 basicNack，否则未处理异常会导致信道关闭，后续消息无法投递；false, true 表示不批量确认、且拒绝后重回队列头部重试。
