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

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

二、解決方案

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

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

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

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

2、Java本身的解決方案--DelayQueue,延時(shí)隊(duì)列

核心思想如圖：

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

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

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

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

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

延時(shí)隊(duì)列實(shí)體Bean

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

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

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

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

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

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

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

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

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

首先了解一下，在JFinal框架下會(huì)有一個(gè)初始化類JFinalConfig,繼承該類可以做項(xiàng)目的一些初始化操作

該類有兩個(gè)方法：

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

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

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

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

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

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

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

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

實(shí)現(xiàn)步驟：

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

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

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

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

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

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

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