redis-delay
背景
我们先看看以下业务场景：
当订单一直处于未支付状态时，如何在半小时后自动取消？
如何定期检查处于退款状态的订单是否已经退款成功？
实现方案
- 定时任务扫表
为了解决以上问题，最简单直接的办法就是定时去扫表。每个业务都要维护一个自己的扫表逻辑。
- 优点：简单
- 缺点：每分钟全局扫表，浪费资源，损耗数据库性能
- 消息中间件
使用消息中间件可以实现延迟消息，像RocketMQ就自带这个功能
- 优点：成熟稳定，使用方便
- 缺点：针对那些项目里没有使用消息中间件的，需要额外部署，成本大。
3.基于Redis
根据Redis的zset、list的特性,我们可以利用Redis来实现一个延迟队列。
- 优点：性能高，容易实现
- 缺点：消息持久化依赖于redis
方案参考有赞延迟队列：https://tech.youzan.com/queuing_delay/
软件架构
消息流程：
- 用户对某个商品下单，系统创建订单成功，同时往延迟队列里put一个job。
- 延迟队列收到该job后，先往job pool中存入job信息，然后根据delay计算出绝对执行时间，放入delay bucket.
- 如果不是延迟job，直接放入ready set中。
- DelayMoveToReadyTimer定时器循环取出delay中延迟时间达到的数据，放入ready set里
- ReadyQueueTimer定时器循环取出消息消费
接入流程
在项目里的redis-delay-test测试项目中有完整的接入示例
大概流程如下：
- 引入pom
<dependency>
<groupId>com.mmc</groupId>
<artifactId>redis-delay-core</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
- 注入两个bean
@Configuration
public class DelayConfig {
@Autowired
private RedisTemplate redisTemplate;
@Bean
public DelayFacade delayFacade(){
return new DelayFacadeImpl(redisTemplate);
}
@Bean
public RedisDelayService redisDelayService(){
return new RedisDelayServiceImpl(delayFacade());
}
}
- 建议创建一个topic枚举类
public enum TopicEnum {
ORDER,
LOG;
}
- 继承AbstractTopicRegister，实现不同的topic的消息消费的业务方法
@Component
public class OrderTopicRegister extends AbstractTopicRegister {
@Override
public String getTopic() {
return ORDER.name();
}
@Override
public boolean handle(Job job) {
System.out.println("处理订单："+ JSON.toJSONString(job));
return true;
}
}
- 使用api
目前提供三个api：
- asyncPutMessage 异步放入消息
- syncPutMessage 同步放入消息
- queryAllMessage 查询所有消息
@RequestMapping("/testDelay")
public String testDelay(Long id, @RequestParam(required = false) Long delayTime, String topic){
JobParam jobParam=new JobParam();
jobParam.setBody("");
jobParam.setJobId(id);
jobParam.setTopic(topic);
jobParam.setDelayTime(delayTime==null?0:delayTime);
jobParam.setRetries(5);
redisDelayService.syncPutMessage(jobParam);
return "success";
}
项目地址
https://gitee.com/mmcLine/redis-delay/
只完成了第一版，需要优化的地方还很多。欢迎大家一起来完善。