关于springboot:个人学习系列-Spring-Boot集成DelayQueue实现订单到期自动取消

52次阅读

共计 4431 个字符,预计需要花费 12 分钟才能阅读完成。

最近在思考购物网站上的未领取订单到期主动勾销是怎么实现的,发现了一个 DelayQueue 队列能够实现,所以来整顿一下。。。

DelayQueue

java 提早队列提供了在指定工夫能力获取队列元素的性能,队列头元素是最靠近过期的元素。没有过期元素的话,应用 poll() 办法会返回 null 值,超时断定是通过 getDelay(TimeUnit.NANOSECONDS) 办法的返回值小于等于 0 来判断。

1. 新建 Spring Boot 我的项目

1.1 pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>cn.hutool</groupId>
    <artifactId>hutool-all</artifactId>
    <version>5.4.2</version>
</dependency>

1.2 application.yml

server:
  port: 8888

order:
  isStarted: 1 # 是否开启主动勾销性能(0 敞开,1 开启)

1.3 新建 Order 订单类

/**
 * 订单类
 * @author zhouzhaodong
 */
public class Order implements Delayed {

    /**
     * 订单号
     */
    private String orderNo;

    /**
     * 用户 id
     */
    private String userId;

    /**
     * 订单状态(0 待领取,1 已领取,2 已勾销)*/
    private Integer status;

    /**
     * 订单创立工夫
     */
    private Date createTime;

    /**
     * 订单勾销工夫
     */
    private Date cancelTime;

    public String getOrderNo() {return orderNo;}

    public void setOrderNo(String orderNo) {this.orderNo = orderNo;}

    public String getUserId() {return userId;}

    public void setUserId(String userId) {this.userId = userId;}

    public Integer getStatus() {return status;}

    public void setStatus(Integer status) {this.status = status;}

    public Date getCreateTime() {return createTime;}

    public void setCreateTime(Date createTime) {this.createTime = createTime;}

    public Date getCancelTime() {return cancelTime;}

    public void setCancelTime(Date cancelTime) {this.cancelTime = cancelTime;}

    public Order(String orderNo, String userId, Integer status, Date createTime, Date cancelTime) {
        this.orderNo = orderNo;
        this.userId = userId;
        this.status = status;
        this.createTime = createTime;
        this.cancelTime = cancelTime;
    }

    @Override
    public String toString() {
        return "Order{" +
                "orderNo='" + orderNo + '\'' +
                ", userId='" + userId + '\'' +
                ", status=" + status +
                ", createTime=" + createTime +
                ", cancelTime=" + cancelTime +
                '}';
    }

    /**
     * 取得延迟时间,用过期工夫 - 以后工夫,工夫单位须要对立
     * @param unit
     * @return
     */
    @Override
    public long getDelay(TimeUnit unit) {// 上面用到 unit.convert() 办法,其实在这个小场景不须要用到,只是学习一下如何应用罢了
        return unit.convert(cancelTime.getTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
    }

    /**
     * 用于提早队列外部比拟排序,以后工夫的延迟时间 - 比拟对象的延迟时间
     * @param o
     * @return
     */
    @Override
    public int compareTo(Delayed o) {
        // 这里依据勾销工夫来比拟,如果勾销工夫小的,就会优先被队列提取进去
        return this.getCancelTime().compareTo(((Order) o).getCancelTime());
    }
}

1.4 新建 CancelOrderService

/**
 * 勾销订单 service 类
 * @author zhouzhaodong
 */
public interface CancelOrderService {

    /**
     * 勾销订单
     */
    void cancelOrder();

    /**
     * 获取队列
     * @return
     */
    DelayQueue<Order> getOrder();}

1.5 新建 servie 实现类

/**
 * 勾销订单实现类
 *
 * @author zhouzhaodong
 */
@Service
public class CancelOrderServiceImpl implements CancelOrderService {

    /**
     * 是否开启主动勾销性能
     */
    @Value("${order.isStarted}")
    private int isStarted;

    /**
     * 提早队列,用来寄存订单对象
     */
    DelayQueue<Order> queue = new DelayQueue<>();

    @Resource
    private ThreadPoolTaskExecutor executorService;

    @Override
    public void cancelOrder() {
        // 新建一个线程,用来模仿定时勾销订单 job
        executorService.submit(()->{
            try {System.out.println("开启主动勾销订单 job, 以后工夫:" + DateUtil.date());
                while (isStarted == 1) {
                    try {Order order = queue.take();
                        order.setStatus(2);
                        System.out.println("订单:" + order.getOrderNo() + "付款超时,主动勾销,以后工夫:" + DateUtil.date());
                    } catch (InterruptedException e) {e.printStackTrace();
                    }
                }
            } catch (Exception e) {e.printStackTrace();
            }
        });
    }

    @Override
    public DelayQueue<Order> getOrder(){executorService.submit(()->{
            try {Date date = DateUtil.date();
                queue.add(new Order("SO001", "001", 0, date, DateUtil.offset(date, DateField.SECOND, 3)));
                queue.add(new Order("SO002", "002", 0, DateUtil.offset(date, DateField.SECOND, 3), DateUtil.offset(date, DateField.SECOND, 6)));
                queue.add(new Order("SO003", "003", 0, DateUtil.offset(date, DateField.SECOND, 6), DateUtil.offset(date, DateField.SECOND, 9)));
                queue.add(new Order("SO004", "004", 0, DateUtil.offset(date, DateField.SECOND, 9), DateUtil.offset(date, DateField.SECOND, 12)));
                queue.add(new Order("SO005", "005", 0, DateUtil.offset(date, DateField.SECOND, 12), DateUtil.offset(date, DateField.SECOND, 15)));
                queue.add(new Order("SO006", "006", 0, DateUtil.offset(date, DateField.SECOND, 15), DateUtil.offset(date, DateField.SECOND, 18)));
            } catch (Exception e) {e.printStackTrace();
            }
        });
        return queue;
    }
}

1.6 新建 controller

/**
 * 控制器
 * @author zhouzhaodong
 */
@RestController
public class CancelOrderController {

    @Resource
    CancelOrderService cancelOrderService;

    @RequestMapping("/")
    public void cancelOrder(){cancelOrderService.getOrder();
        cancelOrderService.cancelOrder();}

    @RequestMapping("/queue")
    public void getOrder(){cancelOrderService.getOrder();
    }
    
}

2. 测试

2.1 启动我的项目,拜访 localhost:8888/

2.2 拜访 localhost:8888/queue

因为队列中曾经没有订单了,所以控制台不再打印相干订单勾销的信息,所以咱们再创立一遍方才的订单,察看控制台打印信息:

至此,咱们简略的订单定时勾销性能就实现了,当然能够依据本人具体的要求进行批改!

集体博客地址:

http://www.zhouzhaodong.xyz

GitHub 源码地址:

https://github.com/zhouzhaodo…

正文完
 0