RocketMQ快速入门

RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够...

MQ介绍

为什么要用MQ

作业

在处理超时未支付订单时，如果发现订单确实超时未支付，最终需要关闭该订单。

延迟消息

在电商的支付业务中，对于一些库存有限的商品，为了更好的用户体验，通常都会在用户下单时立刻扣减商品库存。例如电影院购票、...

消费者的可靠性

当RabbitMQ向消费者投递消息以后，需要知道消费者的处理状态如何。

MQ的可靠性

消息到达MQ以后，如果MQ不能及时保存，也会导致消息丢失，所以MQ的可靠性也非常重要。

练习

将MQ配置抽取到Nacos中管理，微服务中直接使用共享配置。

发送者的可靠性

首先，我们一起分析一下消息丢失的可能性有哪些。

业务改造

案例需求：改造余额支付功能，将支付成功后基于OpenFeign的交易服务的更新订单状态接口的同步调用，改为基于RabbitMQ的异步通知。

SpringAMQP

将来我们开发业务功能的时候，肯定不会在控制台收发消息，而是应该基于编程的方式。由于`RabbitMQ`采用了AMQP协议，因此它具备...