目录
一、背景介绍
对于mq延时队列，产品中对应的应用场景用到了，自己也在执行过程中踩了认知上的坑，历历在目的画面让我不由得动笔总结。
二、思路&方案
- 1.项目为啥用延迟队列？
- 2.项目为啥用三方延迟队列？
- 3.项目中为啥用rabbitmq延迟队列？
- 4.rabbitmq延迟队列的安装
- 5.rabbitmq的延迟队列配置方式
- 6.rabbitmq的延迟队列java集成方式
三、过程
1.项目为啥用延迟队列？
项目中有这样一个业务需求，需要再未来某个时间点执行任务，这些任务或消息可能由于某些原因（如依赖其他任务的完成、等待特定时间、进行定时操作等）不能立即处理。通过使用延迟队列，可以确保这些任务或消息在指定的延迟时间后得到处理，从而实现更为灵活和高效的任务调度。
1.1. 解耦：通过将需要延迟处理的任务放入队列，实现了业务逻辑与延迟处理逻辑的解耦，使得代码更加清晰和易于维护。
可扩展性：延迟队列可以轻松地水平扩展，以应对大量延迟任务的处理需求。通过增加队列的数量或调整消费者的数量，可以灵活地调整系统的处理能力。
1.2. 高可用性：一些延迟队列实现（如RabbitMQ的延迟插件、Redis的有序集合等）提供了持久化机制，即使系统崩溃或重启，也能确保延迟任务不会丢失。
2.项目为啥用三方延迟队列？
2.1. 功能完善与性能优化：第三方延迟队列经过大量的实践和优化，通常具有更完善的功能和更高的性能。它们可能已经解决了许多常见的延迟队列问题，如精确的延迟时间控制、高并发处理、消息的持久化等，从而减少了自行开发可能遇到的困难和风险。
2.2. 可靠性与稳定性：第三方延迟队列通常经过严格的测试和验证，具有更高的可靠性和稳定性。它们可能提供了数据备份、容错处理、负载均衡等机制，确保在复杂的网络环境和系统压力下，延迟队列仍然能够稳定、可靠地运行。
2.3. 易于集成与维护：使用第三方延迟队列可以简化项目的集成工作。这些队列通常提供了丰富的API和文档，方便开发者快速集成到项目中。同时，由于第三方队列的维护和更新由专业的团队负责，开发者可以专注于业务逻辑的实现，而无需过多关注底层技术的细节。
2.4. 成本考虑：虽然自行编写延迟队列可以根据项目需求进行定制，但这通常需要投入大量的人力和时间成本。而使用成熟的第三方延迟队列，则可以快速实现功能，减少开发周期和成本。
3.项目中为啥用rabbitmq延迟队列？
3.1.RabbitMQ：通过插件或死信队列机制实现，具有灵活性和可扩展性，但需要一定的配置和管理工作。
3.2.Redis：利用有序集合数据结构实现，简单直观且性能较高，但需要定期轮询检查延迟消息。
3.3.Kafka：通常需要结合其他组件或自定义实现来模拟延迟队列，可以实现复杂的流处理和延迟逻辑，但相对复杂且需要更多的开发工作。
3.4.Amazon SQS：直接支持延迟队列功能，无需额外配置和管理工作，适合在云环境中使用。
4.rabbitmq延迟队列的安装
安装方式借鉴如下博文即可：
【rabbitmq 实现延迟消息-插件版本安装（docker环境）】
5.rabbitmq的延迟队列配置方式
5.1.exchange配置
5.2.queues配置
5.3.exchange和queues的绑定
6.rabbitmq的延迟队列java集成方式
6.1.pom文件中加入依赖
<!-- amqp依赖,包含RabbitMQ-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
<version>2.3.5.RELEASE</version>
</dependency>
6.2.配置文件中加入配置项
spring:
rabbitmq:
host: rabbitmq域名
port: rabbitmq端口
virtual-host: 指定的virtual-host，默认可以是/
username: 账号
password: 密码
#MQ业务配置
#exchange
classEndExchange: class_end_exchange
#queues
classEndQueues: Class.End.Queue
#exchange和queues绑定时候的routingkey
classEndRoutingKey: delayed_class_end
6.3.增加类，设置对应exchange和queues的消息监听
@Service
public class classEndQueues {
@RabbitListener(queues = {"${spring.rabbitmq.classEndQueues}"})
public synchronized void endClass(Message message){
String messageString = new String(message.getBody());
System.out.println(" endClass接收到的结束消息为："+messageString );
//要处理的业务
}
}
四、总结
- 1.逻辑性思考，一环一环，一步一步的去找，少了哪一步也都会出现断层，而断层所带来的代价是付出更多的时间成本；而总结的意义恰恰是避免类似的事情以后再付出更大的成本
- 2.经验办事，想当然的办事所带来的认知陷阱，会成为一个扣了盖子的井
- 3.于此形成相关手册，进行总结的过程是给自己未来建立一个连接点的过程
五、升华
写博文的深意，又有了更多维度的思考，它能够让作者静心思考，从宏观、微观、行为、心理的角度去思考、去总结、去升华。
