原文鏈接:http://www.studyshare.cn/blog/details/1132/1
一、在各種電商網站下訂單后會保留一個時間段,時間段內未支付則自動將訂單狀態設置為已過期。
二、解決方案
1、輪詢數據庫:實現一個定時器,每隔一段時間去檢查一遍數據庫里的所有訂單,查看其狀態是否是未支付並且已經到期。並修改這些數據的狀態為已過期。
優點:方法簡單,容易實現
缺點:訂單狀態處理不及時,輪詢數據庫的次數中可能很多都並沒有修改訂單(做的無用功),數據庫頻繁多次被連接浪費數據庫資源開銷。
因此以上方式實際開發中基本不予采用。開發中真正實現限時訂單采用以下兩種方案:
2、Java本身的解決方案--DelayQueue,延時隊列
核心思想如圖:

(1)、用戶下單,保存訂單到數據庫的同時,將該訂單以及訂單的過期時間推入DelayQueue
(2)、啟動一個檢查訂單到期的線程,該線程使用delayQueue的take()方法獲取到期訂單,該方法為阻塞方法,如果當前沒有到期訂單,該方法會一直阻塞等待,直到獲取到訂單后繼續往下執行。
(3)、當take()獲取到一個到期訂單后,該線程按獲取到的訂單的id去數據庫查詢訂單並去檢查訂單狀態,如果為未支付,則將狀態修改為已過期
2.1、SpringBoot框架下代碼實現
延時隊列實體Bean


延時訂單業務處理接口

延時訂單業務處理實現類


如果我們只實現了以上的代碼,會存在一個很嚴重的問題,因為延時訂單是存在DelayQueue中的,而DelayQueue是存在內存中的,那么當系 統重啟后,DelayQueue中的數據就被清空了,因此當系統重新啟動的時候,需要在訂單的實現類中去做一個檢索數據庫訂單的操作,將已過期未支付的設置為已過期,將未過期未支付的重新推入DelayQueue隊列中。代碼如下:

@PostConstruct 注解不重復解釋,上面代碼中有注釋
2.2、JFinal框架下代碼實現
由於項目中接口工程使用的是JFinal框架,SpringBoot框架下實現限時訂單很簡單,而JFinal框架下實現有一點小麻煩,特別在此進行分享
(1)ItemVo類和SpringBoot下的一模一樣。不再重復貼代碼
(2)延時訂單業務接口

(3)延時訂單業務處理實現類


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

該類有兩個方法:
afterJFinalStart() :當JFinal框架初始化完成后執行,僅執行一次
beforeJFinalStop() :當JFinal框架關閉之前執行,僅執行一次
那么我們的延時訂單線程初始化與系統重啟后檢測數據庫訂單的操作就可以放到afterJFinalStart() 里面進行執行

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

以上就完整實現了限時訂單的功能。
3、ActiveMq消息中間件實現方案
使用DelayQueue方案適合在單台服務器上,如果在分布式環境下,DelayQueue方案則還需要進行改進,存在的問題就是多個服務器會搶奪同一個訂單,解決方案就是分區處理,每個服務器只負責自己的訂單,不管其他服務器上的訂單。
使用DelayQueue的方案在功能上比較好的實現了限時訂單的功能,但是可擴展性和伸縮性並不好,那么接下來使用ActiveMq實現,既能實現功能,也能更好的擴展和伸縮(消息中間件的特性就是實現系統的解耦)
實現步驟:
1、用戶下單保存到數據庫的同時使用消息生產者發送一條消息到ActiveMq消息隊列,注意:並不是調用send就馬上發送,而是根據過期時間進行延遲發送。時間到期了才會發送這條消息到消息隊列中。
2、當消息隊列收到該消息的時候,將消息轉發給訂閱了該隊列的消費者,消費者收到消息就去做訂單狀態檢查
(1)、接口實現類

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


(3)、消息消費者--修改訂單過期狀態

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