Spring AMQP结合RabbitMQ死信交换机实现延迟发送邮件

今日目标

本文旨在讲解如何使用RabbitMQ的死信交换机来实现用户注册后24小时内发送邮件的功能。通过学习RabbitMQ的死信队列和TTL（消息存活时间）设置，结合Spring AMQP框架，可以实现延迟消息发送的场景。

1. 死信交换机

1.1 什么是死信交换机

当队列中消息因以下原因变为死信时，会被投递到绑定的死信交换机：

• 消息被消费者拒绝且未重新入队
• 消息超时无人消费
• 队列满导致消息无法投递

死信队列和交换机需要配置交换机名称及RoutingKey，以确保消息正确投递到死信交换机和队列。

1.2 TTL (Time-To-Live)

消息的超时时间可以通过队列设置或消息本身设置，超时后消息会变为死信。确保配置前清理已有队列和交换机。

2. 死信交换机结合TTL实现延迟发送邮件

步骤一: 配置队列和交换机

配置两个交换机和队列：

• 正常交换机和队列用于接收注册信息
• 死信交换机和队列用于接收超时消息

通过Spring AMQP在代码中设置交换机、队列绑定及TTL属性，指定死信交换机和RoutingKey。

步骤二: 创建监听接收死信队列消息

在消费者服务中添加监听器，接收来自死信队列的消息。

步骤三: 模拟用户注册发送消息

在生产者服务中添加接口，用户注册后向队列发送消息。

步骤四: 设置消息TTL

发送消息时可以通过队列的TTL属性或直接设置消息的TTL值实现延迟功能。

步骤五: 测试

启动服务后，发送模拟注册请求，观察消息在正常队列超时后转入死信队列，并被监听器消费。

总结

通过死信交换机和TTL属性，可以轻松实现消息的延迟发送功能。消息超时的两种方式包括：

• 给队列设置TTL属性
• 直接给消息设置TTL属性

延迟发送消息的应用场景包括短信通知、订单超时取消、会议提醒等。