【手册】——mq延迟队列

一、背景介绍
二、思路&方案
三、过程
- 1.项目为啥用延迟队列？
- 2.项目为啥用三方延迟队列？
- 3.项目中为啥用rabbitmq延迟队列？
- 4.rabbitmq延迟队列的安装
- 5.rabbitmq的延迟队列配置方式
- - 5.1.exchange配置
  - 5.2.queues配置
  - 5.3.exchange和queues的绑定
- 6.rabbitmq的延迟队列java集成方式
- - 6.1.pom文件中加入依赖
  - 6.2.配置文件中加入配置项
  - 6.3.增加类，设置对应exchange和queues的消息监听
四、总结
五、升华

一、背景介绍

对于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 );
      //要处理的业务
    }
}