上图是通过RocketMQ源码分析一个实现原理方案示意图。 分为两个部分： 消息的写入消息的Schedule 在写入CommitLog之前，如果是延迟消息，按照每10分钟写入delayfile文件，对于快到时间执行的，直接写入时间轮，并且写入delayfile，时间轮每秒钟执行，如果时间 ...

前言篇： 　　为了节约成本，决定通过自研来改造rocketmq，添加任意时间延迟的延时队列，开源版本的rocketmq只有支持18个等级的延迟时间， 其实对于大部分的功能是够用了的，但是以前的项目，全部都是使用了阿里云的rocketmq，原因是不同的供应商的订单的延时 ...

目录 前言 环境 具体实现 前言 RocketMQ是阿里巴巴在2012年开源的分布式消息中间件，记录下SpringBoot整合RocketMQ的方式，RocketMQ的安装可以查看：Windows下安装RocketMQ 环境 ...

新的阅读体验：http://www.zhouhong.icu/post/157 一、业务需求 　　需要实现一个提前二十分钟通知用户去做某件事的一个业务，拿到这个业务首先想到的最简单得方法就是使用Redis监控Key值：在排计划时候计算当前时间与提前二十分钟这个时间差，然后使用一个唯一的业务 ...

1 启动消费者等待传入的订阅消息 2 发送延迟消息 3 确认 您应该会看到消息在其存储时间后大约 10 秒被消耗。 4 延迟消息的使用场景 例如在电子商务中，如果提交订单 ...

起因 看了两篇关于golang中限流器的帖子： Gin 开发实践：如何实现限流中间件 常用限流策略——漏桶与令牌桶介绍 我照着用，居然没效果…… 时间有限没有深究。这实在是一个很简单的功能，我的需求是每分钟限制大约xxx次请求，平均每秒限制到XXX除60次左右的请求也就够了 ...

延迟队列的需求各位应该在日常开发的场景中经常碰到。比如： 用户登录之后5分钟给用户做分类推送； 用户多少天未登录给用户做召回推送； 定期检查用户当前退款账单是否被商家处理等等场景。 一般这种场景和定时任务还是有很大的区别，定时任务是你知道任务多久该跑一次或者什么时候只跑一次，这个时间是确定 ...

使用场景 工作中大家往往会遇到类似的场景： 1.对于红包场景，账户 A 对账户 B 发出红包通常在 1 天后会自动归还到原账户。 2.对于实时支付场景，如果账户 A 对商户 S 付款 100 元，5秒后没有收到支付方回调将自动取消订单。 解决方案分析 方案一： 采用通过定时任务采用 ...