罗小爬的技术宝书

其实就平时可能遇见的场景而言，使用RabbitMQ 的死信机制就已经足够了。毕竟大部分延时任务都是固定时间的，比如下单后半小时未支付则关闭订单这种场景。只要场景是有着固定时间的延时任务的话,RabbitMQ无疑可以很好的承担起这个需求。RabbitMQ 死信机制能作为延时任务这个场景的解决方案但是，由于 RabbitMQ 消息死亡并非异步化，而是阻塞的。所以无法作为复杂延时场景 -需要每条消息的死亡相互独立这种场景下的解决方案。

Kafka、ActiveMQ、RabbitMQ、RocketMQ 的优缺点对比及选型建议

（1）下载下载Erlang：https://github.com/erlang/otp/releases/download/OTP-24.2/otp_win64_24.2.exe下载RabbitMq：https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.9.11/rabbitmq-server-3.9.11.exe（2）安装先安装erlang-otp，然后再安装rabbitMq（3）启动RabbitMq管理控制台（图形管理

Reactive API for RabbitMQ参考：Reactor RabbitMQ Reference GuideReactor RabbitMQ is a reactive API for RabbitMQ based on Reactor and RabbitMQ Java Client. Reactor RabbitMQ API enables messages to be published to RabbitMQ and consumed from RabbitMQ using func

示例代码import com.rabbitmq.client.Channel;import org.springframework.amqp.core.Message;...@RabbitListener(queues = "${rabbit.my.queue}")public void process(Message message, Channel channel) { //确认消息已经消费 channel.basicAck(message.getMessageProperties