背景

最近项目中需要对一条数据，在半小时候更改其状态，类似于提交商城订单半小时后未支付的订单需要更改为超时状态，当然这个解决方案有很多，最好的解决方案是用MQ的死信队列；但由于项目中没有引入MQ，故本文采用的是基于redis与定时器实现该需求。
不废话直接撸串！

代码示例

定义队列名称

public class QueueConstant {
    public static final String DELAY_QUEUE = "delay-queue";
}

将数据放入redis的zset有序集合中

@Autowired
RedisTemplate redisTemplate;

@Value("${timeout:1800000}") //30*60*1000
private Integer timeout;

@Override
public R method(Long id) {
     //业务代码
     ...
     
	 //将订单id(唯一识别号)放入redis中
     redisTemplate.opsForZSet().add(QueueConstant.DELAY_QUEUE,id,System.currentTimeMillis()+timeout);
     return R.success();
 }

定时获取更新状态

@Slf4j
@Configuration
@EnableScheduling
@SuppressWarnings("all")
public class ScheduleTask implements SchedulingConfigurer {
	
	//查询定时表达式
	@Autowired
    CronMapper cronMapper;

    @Autowired
    RedisTemplate redisTemplate;

	//处理业务更新订单状态
    @Autowired
    XXXMapper xxxMapper;

	@Override
	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

        taskRegistrar.addTriggerTask(() -> {
            log.info("执行超时定时任务: " + LocalDateTime.now().toLocalTime());
            Set<Long> idSet= redisTemplate.opsForZSet().rangeByScore(QueueConstant.DELAY_QUEUE, 0, System.currentTimeMillis());
            if(!CollectionUtils.isEmpty(idSet)){
                for (Long id : idSet) {
                    redisTemplate.opsForZSet().remove(QueueConstant.DELAY_QUEUE,id);
                }
                int num = xxxMapper.closeTimeoutOrder(idSet);
            }
            log.info("执行超时定时任务: 执行条数——>"+idSet.size());
        }, triggerContext -> {
            String cron = cronMapper.getTimeoutCron();
            if (StringUtils.isEmpty(cron)) {
                cron ="30 * * * * ?"; //每隔30秒执行
            }
            return new CronTrigger(cron).nextExecutionTime(triggerContext);
        });
    }
}