重试与延迟调度系统-场景与设计

Posted 2020-09-05 Mr.do

首先，来说一下业务场景，也即什么时候，需要有这个一个系统，举两个例子：

1. 订单推送——点评侧垂直业务产生新的订单之后，需要推送给美团订单中心，以在美团APP展示出来。这种通过RPC调用的推送，是可能调用失败的，那么失败之后怎么处理呢？业务线程自己立即重试还是睡一会再重试都不是很合理。在推送失败后，新建个task丢给重试中心统一处理无疑更加优雅。

2. 延迟任务——一个常见的场景就是用户下单一段时间之后，出发XX操作。这种情况下，之前团队经常使用的方式就是新写一个job，轮询扫描表，然后执行XX操作。这种用job来执行延迟操作的方式我觉得是很不优雅的。一是浪费资源，扫描了一些无用数据，或者根本没有需要执行的任务，也会启动一次job。二是job代码和业务代码一般会在不用项目中写，使业务逻辑分离了。

以上的两个例子，一个对应重试，一个对应延迟任务。