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

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

二、解決方案

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

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

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

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

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

核心思想如圖：

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

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

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

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

2.1、SpringBoot框架下代碼實現(xiàn)

延時隊列實體Bean

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

延時訂單業(yè)務(wù)處理實現(xiàn)類

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

@PostConstruct 注解不重復(fù)解釋，上面代碼中有注釋

2.2、JFinal框架下代碼實現(xiàn)

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

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

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

（3）延時訂單業(yè)務(wù)處理實現(xiàn)類

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

該類有兩個方法：

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

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

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

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

以上就完整實現(xiàn)了限時訂單的功能。

3、ActiveMq消息中間件實現(xiàn)方案

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

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

實現(xiàn)步驟：

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

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

（1）、接口實現(xiàn)類

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

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

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

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