<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去檢查用戶是否完成了訂單支付
          //如果用戶沒有支付訂單，去執(zhí)行訂單關閉的操作
          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();  //本文只是示例，生產環(huán)境請做好相關的異常處理
        }
        consuming();
      }
    }).start();
  }
}

orderDelayService.produce("這里填寫訂單編號");