一汰聋、緣起
很多時(shí)候门粪，業(yè)務(wù)有“在一段時(shí)間之后，完成一個(gè)工作任務(wù)”的需求烹困。
例如：滴滴打車(chē)訂單完成后玄妈，如果用戶(hù)一直不評(píng)價(jià)，48小時(shí)后會(huì)將自動(dòng)評(píng)價(jià)為5星髓梅。
一般來(lái)說(shuō)怎么實(shí)現(xiàn)這類(lèi)“48小時(shí)后自動(dòng)評(píng)價(jià)為5星”需求呢拟蜻？
常見(jiàn)方案：?jiǎn)?dòng)一個(gè)cron定時(shí)任務(wù)，每小時(shí)跑一次枯饿，將完成時(shí)間超過(guò)48小時(shí)的訂單取出酝锅，置為5星，并把評(píng)價(jià)狀態(tài)置為已評(píng)價(jià)鸭你。
假設(shè)訂單表的結(jié)構(gòu)為：t_order(oid, finish_time, stars, status, …)屈张，更具體的擒权，定時(shí)任務(wù)每隔一個(gè)小時(shí)會(huì)這么做一次：
select oid from t_order where finish_time > 48hours and status=0;
update t_order set stars=5 and status=1 where oid in[…];
如果數(shù)據(jù)量很大袱巨，需要分頁(yè)查詢(xún)，分頁(yè)update碳抄，這將會(huì)是一個(gè)for循環(huán)愉老。
方案的不足：
（1）輪詢(xún)效率比較低
（2）每次掃庫(kù)，已經(jīng)被執(zhí)行過(guò)記錄剖效，仍然會(huì)被掃描（只是不會(huì)出現(xiàn)在結(jié)果集中）嫉入，有重復(fù)計(jì)算的嫌疑
（3）時(shí)效性不夠好，如果每小時(shí)輪詢(xún)一次璧尸，最差的情況下咒林，時(shí)間誤差會(huì)達(dá)到1小時(shí)
（4）如果通過(guò)增加cron輪詢(xún)頻率來(lái)減少（3）中的時(shí)間誤差，（1）中輪詢(xún)低效和（2）中重復(fù)計(jì)算的問(wèn)題會(huì)進(jìn)一步凸顯
如何利用“延時(shí)消息”爷光，對(duì)于每個(gè)任務(wù)只觸發(fā)一次垫竞，保證效率的同時(shí)保證實(shí)時(shí)性，是今天要討論的問(wèn)題。
二欢瞪、高效延時(shí)消息設(shè)計(jì)與實(shí)現(xiàn)
高效延時(shí)消息活烙，包含兩個(gè)重要的數(shù)據(jù)結(jié)構(gòu)：
（1）環(huán)形隊(duì)列，例如可以創(chuàng)建一個(gè)包含3600個(gè)slot的環(huán)形隊(duì)列（本質(zhì)是個(gè)數(shù)組）
（2）任務(wù)集合遣鼓，環(huán)上每一個(gè)slot是一個(gè)Set
同時(shí)啸盏，啟動(dòng)一個(gè)timer，這個(gè)timer每隔1s骑祟，在上述環(huán)形隊(duì)列中移動(dòng)一格回懦，有一個(gè)Current Index指針來(lái)標(biāo)識(shí)正在檢測(cè)的slot。
Task結(jié)構(gòu)中有兩個(gè)很重要的屬性：
（1）Cycle-Num：當(dāng)Current Index第幾圈掃描到這個(gè)Slot時(shí)次企，執(zhí)行任務(wù)
（2）Task-Function：需要執(zhí)行的任務(wù)指針
假設(shè)當(dāng)前Current Index指向第一格粉怕，當(dāng)有延時(shí)消息到達(dá)之后，例如希望3610秒之后抒巢，觸發(fā)一個(gè)延時(shí)消息任務(wù)贫贝，只需：
（1）計(jì)算這個(gè)Task應(yīng)該放在哪一個(gè)slot，現(xiàn)在指向1蛉谜，3610秒之后稚晚，應(yīng)該是第11格，所以這個(gè)Task應(yīng)該放在第11個(gè)slot的Set中
（2）計(jì)算這個(gè)Task的Cycle-Num型诚，由于環(huán)形隊(duì)列是3600格（每秒移動(dòng)一格客燕，正好1小時(shí)），這個(gè)任務(wù)是3610秒后執(zhí)行狰贯，所以應(yīng)該繞3610/3600=1圈之后再執(zhí)行也搓，于是Cycle-Num=1
Current Index不停的移動(dòng)，每秒移動(dòng)到一個(gè)新slot涵紊，這個(gè)slot中對(duì)應(yīng)的Set傍妒，每個(gè)Task看Cycle-Num是不是0：
（1）如果不是0，說(shuō)明還需要多移動(dòng)幾圈摸柄，將Cycle-Num減1
（2）如果是0颤练，說(shuō)明馬上要執(zhí)行這個(gè)Task了，取出Task-Funciton執(zhí)行（可以用單獨(dú)的線程來(lái)執(zhí)行Task）驱负，并把這個(gè)Task從Set中刪除
使用了“延時(shí)消息”方案之后嗦玖，“訂單48小時(shí)后關(guān)閉評(píng)價(jià)”的需求，只需將在訂單關(guān)閉時(shí)跃脊，觸發(fā)一個(gè)48小時(shí)之后的延時(shí)消息即可：
（1）無(wú)需再輪詢(xún)?nèi)坑唵斡畲欤矢?/p>
（2）一個(gè)訂單，任務(wù)只執(zhí)行一次
（3）時(shí)效性好酪术，精確到秒（控制timer移動(dòng)頻率可以控制精度）
三器瘪、總結(jié)
環(huán)形隊(duì)列是一個(gè)實(shí)現(xiàn)“延時(shí)消息”的好方法，開(kāi)源的MQ好像都不支持延遲消息，不妨自己實(shí)現(xiàn)一個(gè)簡(jiǎn)易的“延時(shí)消息隊(duì)列”娱局，能解決很多業(yè)務(wù)問(wèn)題彰亥，并減少很多低效掃庫(kù)的cron任務(wù)。
