我正在編寫一個簡單的通知服務(wù) i Go。該服務(wù)提供了一個 REST api，可以在其中放置通知，例如{ delayUntil: '2016-02-05T18:00:00' user: 'username', msg: 'Hello World', isSent: false}現(xiàn)在我想在 delayUntil 時間向用戶發(fā)送通知，要求服務(wù)即使重新啟動也應(yīng)該工作，這意味著我必須保留通知?，F(xiàn)在我正在使用 BoltDB（鍵/值存儲）。解決此問題的一種方法是持續(xù)讀取數(shù)據(jù)庫并在經(jīng)過 delayUntil 時發(fā)送通知。另一種方法是在服務(wù)啟動時讀取數(shù)據(jù)庫，并將每個通知放在一個 goroutine 中，該協(xié)程在 delayUntil 時間觸發(fā)。消息發(fā)送后，它在 DB 中被標(biāo)記為已發(fā)送。進入 API 的新條目被插入到數(shù)據(jù)庫中并進行調(diào)度。有沒有首選/更好/更簡單的方法來實現(xiàn)這一目標(biāo)？編輯：只需要一個實例。
1 回答
月關(guān)寶盒
TA貢獻1772條經(jīng)驗 獲得超5個贊
如果您不想使用外部工具并且一個實例就足夠了，您可以：
在服務(wù)啟動時讀取數(shù)據(jù)庫并將所有掛起的通知放在列表中
對列表進行排序
delayUntil并獲取t下一個（最早的）通知的時間。睡眠直到
t，醒來，delayUntil >= t在他們自己的 goroutine 中發(fā)送所有通知，從列表和數(shù)據(jù)庫中刪除它們。重復(fù)步驟 2。
這就是 cron 的工作原理。當(dāng)然，您必須處理插入和其他特殊情況。看看https://github.com/robfig/cron/blob/master/cron.go開始吧。
- 1 回答
- 0 關(guān)注
- 183 瀏覽
添加回答
舉報
0/150
提交
取消