Spring RabbitMQ 实现消息队列延迟

概述

为了实现RabbitMQ的消息队列延迟功能，通常使用官方的rabbitmq_delayed_message_exchange插件，该插件要求RabbitMQ版本至少为3.5.8。如果版本较低，则需要使用RabbitMQ的死信队列功能来实现。

安装RabbitMQ延迟插件

首先，使用rabbitmq-plugins list命令检查已安装插件。如果插件未安装，需要从官网下载并解压到RabbitMQ的plugins目录下。然后通过命令行安装插件，如果系统已配置RabbitMQ环境变量，则直接执行安装命令，否则需进入sbin目录执行。

实现RabbitMQ消息队列延迟功能

pom.xml文件中添加Spring Boot和RabbitMQ相关依赖。在application.yml配置文件中设置RabbitMQ的主机、端口、用户名、密码以及虚拟主机。创建RabbitMQ配置类，定义延迟交换器、队列和路由键。

发送消息

在CustomMessageSender服务中实现消息发送，并通过MessagePostProcessor设置消息延迟5秒。

接收消息

CustomMessageReceiver组件用于接收消息，并在控制台打印接收时间和执行操作。

测试验证

通过DelayMessageController控制器的/sendMessage端点发送消息，并在浏览器访问相应URL进行测试，查看控制台输出以验证延迟消息功能。