建站
咨詢
售后
建站咨詢
新聞中心
一、緣起
站在用戶的角度思考問題，與客戶深入溝通，找到彭陽網(wǎng)站設(shè)計與彭陽網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗，讓設(shè)計與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個性化、用戶體驗好的作品，建站類型包括：做網(wǎng)站、網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、域名與空間、虛擬空間、企業(yè)郵箱。業(yè)務(wù)覆蓋彭陽地區(qū)。
很多時候，業(yè)務(wù)有“在一段時間之后，完成一個工作任務(wù)”的需求。
例如：滴滴打車訂單完成后，如果用戶一直不評價，48小時后會將自動評價為5星。
一般來說怎么實現(xiàn)這類“48小時后自動評價為5星”需求呢?
1. 常見方案：
啟動一個cron定時任務(wù)，每小時跑一次，將完成時間超過48小時的訂單取出，置為5星，并把評價狀態(tài)置為已評價。
假設(shè)訂單表的結(jié)構(gòu)為：t_order(oid, finish_time, stars, status, …)，更具體的，定時任務(wù)每隔一個小時會這么做一次：
- 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ù)量很大，需要分頁查詢，分頁update，這將會是一個for循環(huán)。
2. 方案的不足：
(1)輪詢效率比較低
(2)每次掃庫，已經(jīng)被執(zhí)行過記錄，仍然會被掃描(只是不會出現(xiàn)在結(jié)果集中)，有重復(fù)計算的嫌疑
(3)時效性不夠好，如果每小時輪詢一次，最差的情況下，時間誤差會達(dá)到1小時
(4)如果通過增加cron輪詢頻率來減少(3)中的時間誤差，(1)中輪詢低效和(2)中重復(fù)計算的問題會進一步凸顯
如何利用“延時消息”，對于每個任務(wù)只觸發(fā)一次，保證效率的同時保證實時性，是今天要討論的問題。
二、高效延時消息設(shè)計與實現(xiàn)
高效延時消息，包含兩個重要的數(shù)據(jù)結(jié)構(gòu)：
- 環(huán)形隊列，例如可以創(chuàng)建一個包含3600個slot的環(huán)形隊列(本質(zhì)是個數(shù)組)
- 任務(wù)集合，環(huán)上每一個slot是一個Set
同時，啟動一個timer，這個timer每隔1s，在上述環(huán)形隊列中移動一格，有一個Current Index指針來標(biāo)識正在檢測的slot。
Task結(jié)構(gòu)中有兩個很重要的屬性：
- Cycle-Num：當(dāng)Current Index第幾圈掃描到這個Slot時，執(zhí)行任務(wù)
- Task-Function：需要執(zhí)行的任務(wù)指針
假設(shè)當(dāng)前Current Index指向***格，當(dāng)有延時消息到達(dá)之后，例如希望3610秒之后，觸發(fā)一個延時消息任務(wù)，只需：
- 計算這個Task應(yīng)該放在哪一個slot，現(xiàn)在指向1，3610秒之后，應(yīng)該是第11格，所以這個Task應(yīng)該放在第11個slot的Set 中
- 計算這個Task的Cycle-Num，由于環(huán)形隊列是3600格(每秒移動一格，正好1小時)，這個任務(wù)是3610秒后執(zhí)行，所以應(yīng)該繞3610/3600=1圈之后再執(zhí)行，于是Cycle-Num=1
Current Index不停的移動，每秒移動到一個新slot，這個slot中對應(yīng)的Set ，每個Task看Cycle-Num是不是0：
- 如果不是0，說明還需要多移動幾圈，將Cycle-Num減1
- 如果是0，說明馬上要執(zhí)行這個Task了，取出Task-Funciton執(zhí)行(可以用單獨的線程來執(zhí)行Task)，并把這個Task從Set 中刪除
使用了“延時消息”方案之后，“訂單48小時后關(guān)閉評價”的需求，只需將在訂單關(guān)閉時，觸發(fā)一個48小時之后的延時消息即可：
- 無需再輪詢?nèi)坑唵?，效率?/li>
- 一個訂單，任務(wù)只執(zhí)行一次
- 時效性好，精確到秒(控制timer移動頻率可以控制精度)
三、總結(jié)
環(huán)形隊列是一個實現(xiàn)“延時消息”的好方法，開源的MQ好像都不支持延遲消息，不妨自己實現(xiàn)一個簡易的“延時消息隊列”，能解決很多業(yè)務(wù)問題，并減少很多低效掃庫的cron任務(wù)。
【本文為專欄作者“58沈劍”原創(chuàng)稿件，轉(zhuǎn)載請聯(lián)系原作者】
戳這里，看該作者更多好文
本文名稱：1分鐘實現(xiàn)“延遲消息”功能
URL網(wǎng)址：http://www.dlmjj.cn/article/cdddcci.html
