84669 人學習
152542 人學習
20005 人學習
5487 人學習
7821 人學習
359900 人學習
3350 人學習
180660 人學習
48569 人學習
18603 人學習
40936 人學習
1549 人學習
1183 人學習
32909 人學習
需求/場景:
例如設定一篇文章2018-5-22 13:51:16發布。
三天後通知我。
訊息過期後自動刪除。
……
等等這種需求,就是自動到了一個時間點就做某件事,這個跟隊列好像沒什麼關係感覺,是不是要什麼中間件之類的時間,或是常駐進程之類的。
我的理解是,把待做的任務放到一行一行的一個表裡面,然後一個進程不斷的去刷,滿足時間節點的任務就拿出來執行,是這樣的思路嗎。
想知道這種場景成熟的解決方案是用什麼做的?
謝謝^_^
用延時任務, https://github.com/ouqiang/go...
自己實現, 用時間輪或小根堆
用redis鍵空間通知
beanstalkd
樓主要的應該是DelayQueue,即延遲訊息佇列服務。具體場景可以參考:1.淘寶的自動取消訂單業務2.餓了麼下單簡訊通知業務等等。 基於wait/notify的方式把Timer實現。
就是用程式不斷去刷的= =
可以使用crontab定時任務來解決,可以來設計每天、小時、分呼叫Php介面。
加個時間字段,然後在模型層做相關判斷
程序刷,但是要考慮資料庫壓力。 可以把任務都壓到佇列去,腳本死循環從佇列拿出來,比較時間點,到了就把任務丟給執行模組。時間點沒到的就繼續另一邊壓入隊列。
兩個隊列。例如 待執行佇列:tastList; 立即執行佇列:runList。 把取任務和執行任務分不同進程:1、取任務:腳本循環從tastList中pop任務,判斷時間點,到點了把這個任務push到runList隊列中去。不到點的繼續壓入到tastList中去;2、執行任務:循環衝runList中去pop,一有任務就馬上執行。
量大的時候,自己根據需要去到開幾個進程就了,也不用考慮說會重複執行。
用系統的定時任務功能觸發一個腳本就行了。具體腳本幹什麼,怎麼幹可以自己隨便啦,參考上面的回答也可以。 一般來說一個高頻腳本就夠了(比如1分鐘一次或5分鐘一次),腳本內再去判斷時間然後調用不同頻率的任務,這樣比每種頻率的腳本分別建立定時任務好管理的多。
websocket
或用workerman swoole定時任務功能
workerman
swoole
就是你把資料存起來,然後弄個腳本一直去偵測。 。例如1分鐘檢測一次
用延時任務, https://github.com/ouqiang/go...
延時任務實作方式
自己實現, 用時間輪或小根堆
用redis鍵空間通知
beanstalkd
樓主要的應該是DelayQueue,即延遲訊息佇列服務。具體場景可以參考:
1.淘寶的自動取消訂單業務
2.餓了麼下單簡訊通知業務等等。
基於wait/notify的方式把Timer實現。
就是用程式不斷去刷的= =
可以使用crontab定時任務來解決,可以來設計每天、小時、分呼叫Php介面。
加個時間字段,然後在模型層做相關判斷
程序刷,但是要考慮資料庫壓力。
可以把任務都壓到佇列去,腳本死循環從佇列拿出來,比較時間點,到了就把任務丟給執行模組。時間點沒到的就繼續另一邊壓入隊列。
兩個隊列。例如 待執行佇列:tastList; 立即執行佇列:runList。
把取任務和執行任務分不同進程:
1、取任務:腳本循環從tastList中pop任務,判斷時間點,到點了把這個任務push到runList隊列中去。不到點的繼續壓入到tastList中去;
2、執行任務:循環衝runList中去pop,一有任務就馬上執行。
量大的時候,自己根據需要去到開幾個進程就了,也不用考慮說會重複執行。
用系統的定時任務功能觸發一個腳本就行了。具體腳本幹什麼,怎麼幹可以自己隨便啦,參考上面的回答也可以。
一般來說一個高頻腳本就夠了(比如1分鐘一次或5分鐘一次),腳本內再去判斷時間然後調用不同頻率的任務,這樣比每種頻率的腳本分別建立定時任務好管理的多。
或用
workerman
swoole
定時任務功能就是你把資料存起來,然後弄個腳本一直去偵測。 。例如1分鐘檢測一次