Serve 基于Swoole Server 编写的消息队列消费系统

互联网 Java 工程师进阶知识完全扫盲 本系列知识出自中华石杉，我对这部分知识做了一个系统的整理，方便学习查阅。By the way，微信公众号石杉的架构笔记（id:shishan100）有其它很多架构知识，墙裂推荐~ 一点小建议：学习本系列知识之前，如果你完全没接触过 MQ、ES、Redis、Dubbo、Hystrix 等，那么我建议你可以先在网上搜一下每一块知识的快速入门，跟着入门 Demo 玩一下，然后再开始每一块知识的学习，这样效果更好噢~ 高并发架构 消息队列 为什么使用消息队列？

最近在生产环境刚好遇到了延时任务的场景，调研了一下目前主流的方案，分析了一下优劣并且敲定了最终的方案。这篇文章记录了调研的过程，以及初步方案的实现。 候选方案对比 下面是想到的几种实现延时任务的方案，总结了一下相应的优势和劣势。 方案 优势 劣势 选用场景 JDK 内置的延迟队列 DelayQueue 实现简单 数据内存态，不可靠 一致性相对低的场景 调度框架和 MySQL 进行短间隔轮询 实现简单，可靠性高 存在明显的性能瓶颈 数据量较少实时性相对低的场景 RabbitM

一. 延时消息 延时消息是指消息被发送以后，并不想让消费者立即拿到消息，而是等待指定时间后，消费者才拿到这个消息进行消费。 使用延时消息的典型场景，例如： 在电商系统中，用户下完订单30分钟内没支付，则订单可能会被取消。 在电商系统中，用户七天内没有评价商品，则默认好评。 这些场景对应的解决方案，包括： 轮询遍历数据库记录 JDK 的 DelayQueue ScheduledExecutorService 基于 Quartz 的定时任务 基于 Redis 的 zset