需求/場景:
比如設(shè)置一篇文章2018-5-22 13:51:16發(fā)布。
三天后通知我。
消息過期后自動刪除。
……
等等這種需求,就是自動到了一個時間點就做某事,這個跟隊列好像沒什么關(guān)系感覺,是不是要什么中間件之類的時間,或是常駐進(jìn)程之類的。
我的理解是,把待做的任務(wù)放到一行一行的一個表里面,然后一個進(jìn)程不斷的去刷,滿足時間節(jié)點的任務(wù)就拿出來執(zhí)行,是這樣的思路嗎。
想知道這種場景成熟的解決方案是用什么做的?
謝謝^_^
用延時任務(wù), https://github.com/ouqiang/go...
自己實現(xiàn), 用時間輪或小根堆
用redis鍵空間通知
beanstalkd
樓主要的應(yīng)該是DelayQueue,即延遲消息隊列服務(wù)。具體場景可以參考:
1.淘寶的自動取消訂單業(yè)務(wù)
2.餓了么下單短信通知業(yè)務(wù)等等。
基于wait/notify的方式把Timer實現(xiàn)。
程序刷,但是要考慮數(shù)據(jù)庫壓力。
可以把任務(wù)都壓到隊列去,腳本死循環(huán)從隊列拿出來,比較時間點,到了就把任務(wù)丟給執(zhí)行模塊。時間點沒到的就繼續(xù)另一邊壓入隊列中。
兩個隊列。比如 待執(zhí)行隊列:tastList; 立即執(zhí)行隊列:runList。
把取任務(wù)和執(zhí)行任務(wù)分不同進(jìn)程:
1、取任務(wù):腳本循環(huán)從tastList中pop任務(wù),判斷時間點,到點了把這個任務(wù)push到runList隊列中去。不到點的繼續(xù)壓入到tastList中去;
2、執(zhí)行任務(wù):循環(huán)沖runList中去pop,一有任務(wù)就馬上執(zhí)行。
量大的時候,自己根據(jù)需要去到開幾個進(jìn)程就了,也不用考慮說會重復(fù)執(zhí)行。
用系統(tǒng)的定時任務(wù)功能觸發(fā)一個腳本就行了。具體腳本干什么,怎么干可以自己隨便啦,參考上面的回答也可以。
一般來說一個高頻腳本就夠了(比如1分鐘一次或者5分鐘一次),腳本內(nèi)再去判斷時間然后調(diào)用不同頻率的任務(wù),這樣比每種頻率的腳本分別建立定時任務(wù)好管理的多。