共计 3310 个字符，预计需要花费 9 分钟才能阅读完成。
在很多场景下，咱们都有提早队列的需要，然而默认状况下 RabbitMQ 并未提供提早队列相干的性能，不过，在后面的文章中，松哥和大家分享了 RabbitMQ 中的死信队列，联合死信队列以及音讯过期工夫的设定，咱们也能够实现提早队列的性能，明天咱们就一起来看下。
RabbitMQ 其实有提供专门的提早队列插件，这个咱们有空了再聊。
如果大家还没看过后面的文章，能够先去瞅瞅，这有助于了解本文：
- RabbitMQ 中的音讯会过期吗？
1. 什么时候须要提早队列？
先来说说什么时候咱们须要提早队列。
举几个简略的例子。
- 在电商我的项目中，当咱们下单之后，个别须要 20 分钟之内或者 30 分钟之内付款，否则订单就会进入异样解决逻辑中，被勾销，那么进入到异样解决逻辑中，就能够当成是一个提早队列。
- 我买了一个智能砂锅，能够用来煮粥，下班前把素材都放到锅里，而后设置几点几分开始煮粥，这样上班后就能够喝到香喷喷的粥了，那么这个煮粥的指令也能够看成是一个提早工作，放到一个提早队列中，工夫到了再执行。
- 公司的会议预约零碎，在会议预约胜利后，会在会议开始前半小时告诉所有预约该会议的用户。
- 平安工单超过 24 小时未解决，则主动拉企业微信群揭示相干责任人。
- 用户下单外卖当前，间隔超时工夫还有 10 分钟时揭示外卖小哥行将超时。
- …
很多场景下咱们都须要提早队列。
可能有小伙伴说至于嘛，间接搞个定时工作不更不便？如果我的项目中只有一个这样的提早队列的场景，那么搞个定时工作仿佛也能够，然而如果我的项目中有很多这样的场景，那么定时工作很显著就不是最佳计划了，咱们能够通过提早队列来实现一个通用的解决方案。
2. 提早队列实现思路
提早队列实现的思路也很简略，就是上篇文章咱们所说的 DLX（死信交换机）+TTL（音讯超时工夫）。
咱们能够把死信队列就当成提早队列。
具体来说是这样：
如果一条音讯须要提早 30 分钟执行，咱们就设置这条音讯的有效期为 30 分钟，同时为这条音讯配置死信交换机和死信 routing_key，并且不为这个音讯队列设置消费者，那么 30 分钟后，这条音讯因为没有被消费者生产而进入死信队列，此时咱们有一个消费者就在“蹲点”这个死信队列，音讯一进入死信队列，就立马被生产了。
这就是提早队列的实现思路，是不是很简略？
3. 案例
接下来松哥通过一个简略的案例，来和大家演示一下提早队列的具体实现。
首先筹备好一个启动的 RabbitMQ。
而后咱们创立一个 Spring Boot 我的项目，引入 RabbitMQ 依赖：
而后在 application.properties 中配置一下 RabbitMQ 的根本连贯信息：
spring.rabbitmq.host=localhost
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.port=5672接下来咱们来配置两个音讯队列：一个一般队列，一个死信队列：
@Configuration
public class QueueConfig {
public static final String JAVABOY_QUEUE_NAME = "javaboy_queue_name";
public static final String JAVABOY_EXCHANGE_NAME = "javaboy_exchange_name";
public static final String JAVABOY_ROUTING_KEY = "javaboy_routing_key";
public static final String DLX_QUEUE_NAME = "dlx_queue_name";
public static final String DLX_EXCHANGE_NAME = "dlx_exchange_name";
public static final String DLX_ROUTING_KEY = "dlx_routing_key";
/**
* 死信队列
* @return
*/
@Bean
Queue dlxQueue() {return new Queue(DLX_QUEUE_NAME, true, false, false);
}
/**
* 死信交换机
* @return
*/
@Bean
DirectExchange dlxExchange() {return new DirectExchange(DLX_EXCHANGE_NAME, true, false);
}
/**
* 绑定死信队列和死信交换机
* @return
*/
@Bean
Binding dlxBinding() {return BindingBuilder.bind(dlxQueue()).to(dlxExchange())
.with(DLX_ROUTING_KEY);
}
/**
* 一般音讯队列
* @return
*/
@Bean
Queue javaboyQueue() {Map<String, Object> args = new HashMap<>();
// 设置音讯过期工夫
args.put("x-message-ttl", 1000*10);
// 设置死信交换机
args.put("x-dead-letter-exchange", DLX_EXCHANGE_NAME);
// 设置死信 routing_key
args.put("x-dead-letter-routing-key", DLX_ROUTING_KEY);
return new Queue(JAVABOY_QUEUE_NAME, true, false, false, args);
}
/**
* 一般交换机
* @return
*/
@Bean
DirectExchange javaboyExchange() {return new DirectExchange(JAVABOY_EXCHANGE_NAME, true, false);
}
/**
* 绑定一般队列和与之对应的交换机
* @return
*/
@Bean
Binding javaboyBinding() {return BindingBuilder.bind(javaboyQueue())
.to(javaboyExchange())
.with(JAVABOY_ROUTING_KEY);
}
}这段配置代码尽管略长，不过原理其实简略。
- 配置能够分为两组，第一组配置死信队列，第二组配置一般队列。每一组都由音讯队列、音讯交换机以及 Binding 三者组成。
- 配置音讯队列时，为音讯队列指定死信队列，不相熟的小伙伴能够翻一下上篇文章，传送门：RabbitMQ 中的音讯会过期吗？。
- 配置队列中的音讯过期工夫时，默认的工夫单位时毫秒。
接下来咱们为死信队列配置一个消费者，如下：
@Component
public class DlxConsumer {private static final Logger logger = LoggerFactory.getLogger(DlxConsumer.class);
@RabbitListener(queues = QueueConfig.DLX_QUEUE_NAME)
public void handle(String msg) {logger.info(msg);
}
}收到音讯后就将之打印进去。
这就完事了。
启动我的项目。
最初咱们在单元测试中发送一条音讯：
@SpringBootTest
class DelayQueueApplicationTests {
@Autowired
RabbitTemplate rabbitTemplate;
@Test
void contextLoads() {System.out.println(new Date());
rabbitTemplate.convertAndSend(QueueConfig.JAVABOY_EXCHANGE_NAME, QueueConfig.JAVABOY_ROUTING_KEY, "hello javaboy!");
}
}这个就没啥好说的了，就是一般的音讯发送，10 秒之后这条音讯会在死信队列的消费者中被打印进去。
4. 小结
好啦，这就是咱们用 RabbitMQ 做提早队列的思路～
小伙伴们在公众号后盾回复文章题目，能够下载本文案例～
