延时任务-基于redis zset的完整实现 - ToB企服应用市场:ToB评测及商务社交产业平台

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

复制代码

spring:
redis:
database: 0 # Redis 数据库索引（默认为 0）
host: 192.168.161.3 # Redis 服务器地址
port: 6379 # Redis 服务器连接端口
password: 123456 # Redis 服务器连接密码（默认为空）
timeout: 5000 # 连接超时，单位ms
lettuce:
pool:
max-active: 8 # 连接池最大连接数（使用负值表示没有限制）默认 8
max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）默认 -1
max-idle: 8 # 连接池中的最大空闲连接默认 8
min-idle: 0 # 连接池中的最小空闲连接默认 0

复制代码

@Component
public class OrderDelayService implements InitializingBean {
//redis zset key
public static final String ORDER_DELAY_TASK_KEY = "delaytask:order";
@Resource
private StringRedisTemplate stringRedisTemplate;
//生成订单-order为订单信息，可以是订单流水号，用于延时任务达到时效后关闭订单
public void produce(String orderSerialNo){
stringRedisTemplate.opsForZSet().add(
ORDER_DELAY_TASK_KEY, // redis key
orderSerialNo, // zset member
//30分钟延时
System.currentTimeMillis() + (30 * 60 * 1000) //zset score
);
}
//延时任务，也是异步任务，延时任务达到时效之后关闭订单，并将延时任务从redis zset删除
@Async("test")
public void consuming(){
Set<ZSetOperations.TypedTuple<String>> orderSerialNos = stringRedisTemplate.opsForZSet().rangeByScoreWithScores(
ORDER_DELAY_TASK_KEY,
0, //延时任务score最小值
System.currentTimeMillis() //延时任务score最大值（当前时间）
);
if (!CollectionUtils.isEmpty(orderSerialNos)) {
for (ZSetOperations.TypedTuple<String> orderSerialNo : orderSerialNos) {
//这里根据orderSerialNo去检查用户是否完成了订单支付
//如果用户没有支付订单，去执行订单关闭的操作
System.out.println("订单" + orderSerialNo.getValue() + "超时被自动关闭");
//订单关闭之后，将订单延时任务从队列中删除
stringRedisTemplate.opsForZSet().remove(ORDER_DELAY_TASK_KEY, orderSerialNo.getValue());
}
}
}
//该类对象Bean实例化之后，就开启while扫描任务
@Override
public void afterPropertiesSet() throws Exception {
new Thread(() -> { //开启新的线程，否则SpringBoot应用初始化无法启动
while(true){
try {
Thread.sleep(5 * 1000); //每5秒扫描一次redis库获取延时数据，不用太频繁没必要
} catch (InterruptedException e) {
e.printStackTrace(); //本文只是示例，生产环境请做好相关的异常处理
}
consuming();
}
}).start();
}
}

复制代码

orderDelayService.produce("这里填写订单编号");

复制代码