Java中怎么实现商城订单超时取消功能

发布时间:2021-08-12 17:31:15 作者:Leah
来源:亿速云 阅读:134

这篇文章将为大家详细讲解有关Java中怎么实现商城订单超时取消功能,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

实现原理:

利用 jdk 的 DelayQueue的阻塞队列的特性实现。在项目启动时开启一个线程处理 DelayQueue 队列里弹出的超时订单对象,订单未超时该线程处于等待中。

DelayQueue的简单介绍:

DelayQueue类的主要作用:是一个无界的BlockingQueue,用于放置实现了Delayed接口的对象,其中的对象只能在其到期时才能从队列中取走。这种队列是有序的,即队头对象的延迟到期时间最长。注意:不能将null元素放置到这种队列中。

实现方式 :

1.创建一个实现Delayed接口的 order 类并重写compareTo和 getDelay方法

2.创建一个帮助类OrderCollection(订单的增删查)

3. 创建CancellOrder类

在生成订单时将订单号创建时间和过期时间封装成一个实现Delayed接口的对象存入DelayQueue队列中,当该订单支付完成后将该对象从队列中移除,(为了保证不丢失订单建议在项目启动时将数据库中的符合条件的订单初始化到DelayQueue队列中 )

实现代码如下:

/** * 类说明 * * @author grl * @date 2019年12月16日 新建 */public class Order implements Delayed {  private String orderShopNum;  /**  * 1-普通活动 2-限时活动 3-拼购活动  */  private int orderType;  private long orderCreateTime;  private long expTime;  public Order(String orderShopNum, int orderType, Date createTime) {   if (StringUtils.isNotBlank(orderShopNum)) {     this.orderShopNum = orderShopNum.trim();   }   if (createTime == null) {     this.orderCreateTime = System.currentTimeMillis();   } else {     this.orderCreateTime = createTime.getTime();   }   this.orderType = orderType;   if (orderType == 2) {     this.expTime = TimeUnit.MILLISECONDS.convert(Const.LIMIT_ACTIVITY_EXPIRATION_TIME, TimeUnit.MINUTES)        + createTime.getTime();   }if(orderType == 3){     this.expTime = TimeUnit.MILLISECONDS.convert(Const.LIMIT_GROUP_BUY_EXPIRATION_TIME, TimeUnit.MINUTES)        + createTime.getTime();   } else {     this.expTime = TimeUnit.MILLISECONDS.convert(Const.ORDER_PAYMENT_DEADLINE, TimeUnit.DAYS)        + createTime.getTime();   }  }  public String getOrderShopNum() {   return orderShopNum;  }  public long getOrderCreateTime() {   return orderCreateTime;  }  public long getExpTime() {   return expTime;  }  public int getOrderType() {   return orderType;  }  @Override  public int compareTo(Delayed o) {   return Long.valueOf(this.expTime).compareTo(Long.valueOf(((Order) o).expTime));  }  @Override  public long getDelay(TimeUnit unit) {   return unit.convert(this.expTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);  } } /** * 类说明 * * @author grl * @date 2019年12月16日 新建 */public class OrderCollection {  /**  * 订单管理集合  */  private static DelayQueue<Order> orderList = new DelayQueue<Order>();  private OrderCollection() {  }  /**  * 获取订单集合  * @author grl  * @return  */  protected static DelayQueue getOrderCollection() {   return orderList;  }   /**  * 向集合中添加订单  *   * @author grl  * @param order  * @return  */  public static boolean add(Order order) {   boolean flag = false;   if (order != null && StringUtils.isNotBlank(order.getOrderShopNum())) {     flag = orderList.offer(order);   }   return flag;  }  /**  * 从集合中删除订单  *   * @author grl  * @param orderShopNum  * @return  */  public static boolean remove(String orderShopNum) {   boolean flag = false;   Order thisOrder = null;   if (StringUtils.isNotBlank(orderShopNum)) {     orderShopNum = orderShopNum.trim();     for (Order order : orderList) {      String orderNum = order.getOrderShopNum();      if (orderNum.equals(orderShopNum)) {        thisOrder = order;      }     }     if (thisOrder != null) {      flag = orderList.remove(thisOrder);     }   }   return flag;  }  /**  * 获取订单的过期剩余时间  *   * @author grl  * @param orderShopNum  * @param unit  * @return -1 已经过期  */  public static long getDelay(String orderShopNum) {   long time = -1;   if (StringUtils.isNotBlank(orderShopNum)) {     orderShopNum = orderShopNum.trim();     for (Order order : orderList) {      String orderNum = order.getOrderShopNum();      if (orderNum.equals(orderShopNum)) {        time = order.getDelay(TimeUnit.MILLISECONDS);        if(time<5000) {         time = -1;        }      }     }   }   return time;  }} /** * 类说明 * * @author grl * @date 2019年12月16日 新建 */@Componentpublic class CancellOrder implements Runnable {  private static final Logger log = LoggerFactory.getLogger(CancellOrder.class);  @Override  public void run() {   while (true) {     try {      Order take = OrderCollection.getOrderCollection().take();      String orderShopNum = take.getOrderShopNum();      int orderType = take.getOrderType();      // 业务逻辑操作     } catch (InterruptedException e) {      e.printStackTrace();      log.error("CancellOrder DelayQueue 错误 {}", e.getMessage());     }   }  }}

关于Java中怎么实现商城订单超时取消功能就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

推荐阅读:
  1. PHP实现延时队列和处理超时订单
  2. Java实现商城订单超时取消功能

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

java

上一篇:java中怎么实现生成图片验证码功能

下一篇:怎么用Javascript制作随机星星效果图

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》