摘要：一在各種電商網站下訂單后會保留一個時間段，時間段內未支付則自動將訂單狀態(tài)設置為已過期。并修改這些數據的狀態(tài)為已過期。因此以上方式實際開發(fā)中基本不予采用。時間到期了才會發(fā)送這條消息到消息隊列中。

一、在各種電商網站下訂單后會保留一個時間段，時間段內未支付則自動將訂單狀態(tài)設置為已過期。(原文鏈接 )

二、解決方案

1、輪詢數據庫：實現一個定時器，每隔一段時間去檢查一遍數據庫里的所有訂單，查看其狀態(tài)是否是未支付并且已經到期。并修改這些數據的狀態(tài)為已過期。

優(yōu)點：方法簡單，容易實現

缺點：訂單狀態(tài)處理不及時，輪詢數據庫的次數中可能很多都并沒有修改訂單（做的無用功），數據庫頻繁多次被連接浪費數據庫資源開銷。

因此以上方式實際開發(fā)中基本不予采用。開發(fā)中真正實現限時訂單采用以下兩種方案：

2、Java本身的解決方案--DelayQueue,延時隊列

核心思想如圖：

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

（2）、啟動一個檢查訂單到期的線程，該線程使用delayQueue的take()方法獲取到期訂單，該方法為阻塞方法，如果當前沒有到期訂單，該方法會一直阻塞等待，直到獲取到訂單后繼續(xù)往下執(zhí)行。

（3）、當take()獲取到一個到期訂單后，該線程按獲取到的訂單的id去數據庫查詢訂單并去檢查訂單狀態(tài)，如果為未支付，則將狀態(tài)修改為已過期

java開發(fā)工具下載地址及安裝教程大全，在這里。
更多深度技術文章，在這里。

2.1、SpringBoot框架下代碼實現

延時隊列實體Bean

延時訂單業(yè)務處理接口

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

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

@PostConstruct 注解不重復解釋，上面代碼中有注釋

2.2、JFinal框架下代碼實現

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

（1）ItemVo類和SpringBoot下的一模一樣。不再重復貼代碼

（2）延時訂單業(yè)務接口

（3）延時訂單業(yè)務處理實現類

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

該類有兩個方法：

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

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

那么我們的延時訂單線程初始化與系統(tǒng)重啟后檢測數據庫訂單的操作就可以放到afterJFinalStart() 里面進行執(zhí)行

系統(tǒng)關閉線程中斷執(zhí)行代碼：

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

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

使用DelayQueue方案適合在單臺服務器上，如果在分布式環(huán)境下，DelayQueue方案則還需要進行改進，存在的問題就是多個服務器會搶奪同一個訂單，解決方案就是分區(qū)處理，每個服務器只負責自己的訂單，不管其他服務器上的訂單。

使用DelayQueue的方案在功能上比較好的實現了限時訂單的功能，但是可擴展性和伸縮性并不好，那么接下來使用ActiveMq實現，既能實現功能，也能更好的擴展和伸縮（消息中間件的特性就是實現系統(tǒng)的解耦）

實現步驟：

1、用戶下單保存到數據庫的同時使用消息生產者發(fā)送一條消息到ActiveMq消息隊列，注意：并不是調用send就馬上發(fā)送，而是根據過期時間進行延遲發(fā)送。時間到期了才會發(fā)送這條消息到消息隊列中。

2、當消息隊列收到該消息的時候，將消息轉發(fā)給訂閱了該隊列的消費者，消費者收到消息就去做訂單狀態(tài)檢查

（1）、接口實現類

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

（3）、消息消費者--修改訂單過期狀態(tài)

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

原創(chuàng)文章，轉載請注明出處。
java開發(fā)工具下載地址及安裝教程大全，在這里。
更多深度技術文章，在這里。