Spring Boot 整合 RabbitMQ 实现延迟消息_spring boot mq延时消息

关于 RabbitMQ

消息队列（Message Queuing，简写为 MQ）最初是为了解决金融行业的特定业务需求而产生的。慢慢的，MQ 被应用到了更多的领域，然而商业 MQ 高昂的价格让很多初创公司望而却步，于是 AMQP（Advanced Message Queuing Protocol，高级消息队列协议）应运而生。

随着 AMQP 草案的发布，两个月后，RabbitMQ 1.0 就发布了。

RabbitMQ 的架构模型可以分为客户端和服务端两部分，客户端包括生产者和消费者，服务端包括虚拟主机、交换器和队列。

整体的流程非常简单，生产者将消息发送到服务端，消费者从服务端获取对应的消息。

生产者在发送消息前需要先确认发送给哪个虚拟主机的哪个交换器，再由交换器通过路由键将消息转发给与之绑定的队列。

最后，消费者到指定的队列中获取自己的消息进行消费。

客户端

生产者和消费者都属于客户端。

生产者：消息的发送方，将要发送的消息封装成一定的格式，发送给服务端。消息包括消息体和标签。

消费者：消息的接收方，负责消费消息体。

服务端

虚拟主机、交换机、队列都属于服务端。

虚拟主机：用来对交换器和队列进行逻辑隔离，在同一个虚拟主机下，交换器和队列的名称不能重复。有点类似 Java 中的包，同一个包下，不能有相同名称的类或者接口。

交换器：负责接收生产者发来的消息，并根据规则分配给对应的队列，不生产消息，只是消息的搬运工。

队列：负责存储消息，生产者发送的消息会放在这里，消费者从这里取。

连接和信道

连接和信道是两个不同的概念，连接的英文叫 connection，信道叫 channel。

连接里包含了多条信道，连接用的是 TCP 连接，因为 AMQP 就是用 TCP 实现的。

为什么不直接使用连接，而要在连接的基础上新建信道呢？

因为 TCP 连接是比较昂贵的，新建需要三次握手，销毁需要四次挥手，所以如果每个线程在想 RabbitMQ 服务端发送/接收消息的时候都新建一个 TCP 连接，就会非常的消耗资源，于是就有了信道。

信道是线程私有的，连接是线程共享的。

信道+连接的模式，既保证了线程之间的私密性，又减少了系统开销。

业务场景

消息队列的主要功能有三种：

• 异步处理，比如说在做电商业务的时候，提交订单的动作可能涉及到创建订单、扣除库存、增加用户积分、发送订单邮件等。它们并不是一个串行的操作，可以把发送订单邮件和增加用户积分交给消息队列去做。
• 系统解耦，消息队列可以作为不同系统之间的桥梁，且不受系统技术栈的约束。
• 缓冲削峰，消息队列可以将大量的请求放到队列中，然后再按照一定的顺序规则交给业务服务器处理。

工作模式

RabbitMQ 支持 7 种工作模式：

• 简单模式
• 工作队列模式
• 广播模式
• 路由模式
• 动态路由模式
• 远程模式
• 生产者确认模式

我们这里只演示前三种，

简单模式

简单模式真的超级简单，生产者将消息发送给队列，消费者从队列中获取消息队列即可。

生活中就类似于 快递员将包裹放到快递柜，然后给取件人发一个取件码，取件人通过取件码去快递柜里取包裹