限時訂單實現方案（DelayQueue、ActiveMq）

原文連接：http://www.studyshare.cn/blog-front/blog/details/1132/1

1、在各類電商網站下訂單後會保留一個時間段，時間段內未支付則自動將訂單狀態設置爲已過時。

 

 

2、解決方案

    一、輪詢數據庫：實現一個定時器，每隔一段時間去檢查一遍數據庫裏的全部訂單，查看其狀態是不是未支付而且已經到期。並修改這些數據的狀態爲已過時。

    優勢：方法簡單，容易實現

    缺點：訂單狀態處理不及時，輪詢數據庫的次數中可能不少都並無修改訂單（作的無用功），數據庫頻繁屢次被鏈接浪費數據庫資源開銷。

所以以上方式實際開發中基本不予採用。開發中真正實現限時訂單採用如下兩種方案：

    二、Java自己的解決方案--DelayQueue,延時隊列

    核心思想如圖：

 

    （1）、用戶下單，保存訂單到數據庫的同時，將該訂單以及訂單的過時時間推入DelayQueue

    （2）、啓動一個檢查訂單到期的線程，該線程使用delayQueue的take()方法獲取到期訂單，該方法爲阻塞方法，若是當前沒有到期訂單，該方法會一直阻塞等待，直到獲取到訂單後繼續往下執行。

    （3）、當take()獲取到一個到期訂單後，該線程按獲取到的訂單的id去數據庫查詢訂單並去檢查訂單狀態，若是爲未支付，則將狀態修改成已過時

        2.一、SpringBoot框架下代碼實現

      延時隊列實體Bean

 

 

      延時訂單業務處理接口

 

  延時訂單業務處理實現類

 

 

   若是咱們只實現了以上的代碼，會存在一個很嚴重的問題，由於延時訂單是存在DelayQueue中的，而DelayQueue是存在內存中的，那麼當系   統重啓後，DelayQueue中的數據就被清空了，所以當系統從新啓動的時候，須要在訂單的實現類中去作一個檢索數據庫訂單的操做，將已過時未支付的設置爲已過時，將未過時未支付的從新推入DelayQueue隊列中。代碼以下：

 

            @PostConstruct  註解不重複解釋，上面代碼中有註釋

2.二、JFinal框架下代碼實現

        因爲項目中接口工程使用的是JFinal框架，SpringBoot框架下實現限時訂單很簡單，而JFinal框架下實現有一點小麻煩，特別在此進行分享

        （1）ItemVo類和SpringBoot下的如出一轍。再也不重複貼代碼

        （2）延時訂單業務接口

 

（3）延時訂單業務處理實現類

 

不是使用spring的註解，這兩個方法在JFinal框架下怎麼調用，見下圖

    首先了解一下，在JFinal框架下會有一個初始化類JFinalConfig,繼承該類能夠作項目的一些初始化操做

 

該類有兩個方法：

afterJFinalStart() ：當JFinal框架初始化完成後執行，僅執行一次

beforeJFinalStop()  ：當JFinal框架關閉以前執行，僅執行一次

那麼咱們的延時訂單線程初始化與系統重啓後檢測數據庫訂單的操做就能夠放到afterJFinalStart() 裏面進行執行          

 

系統關閉線程中斷執行代碼：

 

以上就完整實現了限時訂單的功能。

三、ActiveMq消息中間件實現方案

        使用DelayQueue方案適合在單臺服務器上，若是在分佈式環境下，DelayQueue方案則還須要進行改進，存在的問題就是多個服務器會搶奪同一個訂單，解決方案就是分區處理，每一個服務器只負責本身的訂單，無論其餘服務器上的訂單。

        使用DelayQueue的方案在功能上比較好的實現了限時訂單的功能，可是可擴展性和伸縮性並很差，那麼接下來使用ActiveMq實現，既能實現功能，也能更好的擴展和伸縮（消息中間件的特性就是實現系統的解耦）

        實現步驟：

           一、用戶下單保存到數據庫的同時使用消息生產者發送一條消息到ActiveMq消息隊列，注意：並非調用send就立刻發送，而是根據過時時間進行延遲發送。時間到期了纔會發送這條消息到消息隊列中。

            二、當消息隊列收到該消息的時候，將消息轉發給訂閱了該隊列的消費者，消費者收到消息就去作訂單狀態檢查

  （1）、接口實現類

 

    （2）、消息生產者--發送訂單到期的消息到消息隊列（按過時時間延遲發送）

 

 

             （3）、消息消費者--修改訂單過時狀態

 

以上三個類就是使用ActiveMq消息中間件實現限時訂單的全部代碼。調用代碼很簡單就是保存訂單的同時將消息發送到消息隊列，不在贅述。

更多深度技術好文：http://www.studyshare.cn/blog-front//index