Redis如何实现订单过期删除

这篇文章主要介绍“Redis如何实现订单过期删除”，在日常操作中，相信很多人在Redis如何实现订单过期删除问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Redis如何实现订单过期删除”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

前言

设计订单过期，不能单纯靠Redis，需要兜底策略

代码实现：

import com.coolplay.trade.dto.req.CancelOrderReq;import lombok.extern.slf4j.Slf4j;import org.apache.commons.collections.CollectionUtils;import org.springframework.data.redis.core.ZSetOperations;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Service;import javax.annotation.Resource;import java.util.Set;import java.util.concurrent.TimeUnit;@Service@Slf4jpublic class OrderRedisDelayQueueOperator extends AbstractOrderScheduleDelayQueue {    @Resource(name = "redisTemplate")    private ZSetOperations<String, String> orderRedis;        private static final String DELAY_QUEUE_NAME = "order";        @Override    @Scheduled(cron = "0/1 * * * * ? ")    public void orderEventProcess() {        if (!redisLock.tryLock(this.getClass().getSimpleName(), TimeUnit.MILLISECONDS, 10, 100)) {            return;        }        Set<String> dq = orderRedis.range(DELAY_QUEUE_NAME, 0L, Long.MAX_VALUE);        if (CollectionUtils.isEmpty(dq)) {            return;        }        for (String orderNo : dq) {            Double xs = orderRedis.score(DELAY_QUEUE_NAME, orderNo);            Double now = System.currentTimeMillis() * 1.0;            if (xs <= now) {                log.info("{} timed out", orderNo);                super.threadPoolTaskExecutor.execute(() -> {                    CancelOrderReq req = new CancelOrderReq();                    req.setOrderNo(orderNo);                    req.setCancelType(OrderActionEnum.TIME_OUT_CANCEL);                    orderService.cancelOrder(req);                });            } else {                //log.info("{} no time out", orderNo);                //如果最小的都没有过期，剩余的则不用处理了                break;            }        }    }    public void addToRedis(String orderNo, long delayTime) {        orderRedis.add(DELAY_QUEUE_NAME, orderNo, delayTime * 1.0);    }    public void removeFromRedis(String orderNo) {        orderRedis.remove(DELAY_QUEUE_NAME, orderNo);    }}

兜底策略

    @XxlJob("cancelOrder20Minutes")    public void cancelOrderTenMinutes() {        log.info("*****[开始：下单十分钟以后系统自动取消订单]*****");        Date start = DateUtil.dateRoll(new Date(), Calendar.MINUTE,-20);        Date end = new Date();       List<ClOrder> clorderList =clOrderMapper.selectListAllOrdrWaiting(start,end);       if(ObjectUtil.isNotEmpty(clorderList)){           for(int i=0;i<clorderList.size();i++){               ClOrder clOrder = clorderList.get(i);               if(ObjectUtil.isNotEmpty(clOrder)){                   Date orderTime = clOrder.getOrderTime();                   long between = cn.hutool.core.date.DateUtil.between(orderTime, new Date(), DateUnit.MINUTE);                   if(between>10){                       ClOrder clOrderTemp = new ClOrder();                       clOrderTemp.setOrderState("3");                       clOrderTemp.setId(clOrder.getId());                       clOrderTemp.setMemberId(clOrder.getMemberId());                       String msg="您的订单已经取消，订单金额已发放至您的账户请查收~";                       try {                           boolean b = orderService.cancelOrder(clOrderTemp,msg);                           if(!b){                               log.info("[订单失效：定时任务兜底策略更新失败]**订单ID: {}",clOrderTemp.getId());                           }                           log.info("[Redis订单取消订单失效，定时任务兜底策略生效]");                       }catch (Exception e){                           log.info("[订单失效：定时任务兜底策略更新失败]**订单ID: {}",clOrderTemp.getId());                           e.printStackTrace();                       }                   }               }           }       }        log.info("*****[结束：下单十分钟以后系统自动取消订单]*****");    }

到此，关于“Redis如何实现订单过期删除”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！