上圖是通過RocketMQ源碼分析一個實現原理方案示意圖。 分為兩個部分： 消息的寫入消息的Schedule 在寫入CommitLog之前，如果是延遲消息，按照每10分鍾寫入delayfile文件，對於快到時間執行的，直接寫入時間輪，並且寫入delayfile，時間輪每秒鍾執行，如果時間 ...

前言篇： 　　為了節約成本，決定通過自研來改造rocketmq，添加任意時間延遲的延時隊列，開源版本的rocketmq只有支持18個等級的延遲時間， 其實對於大部分的功能是夠用了的，但是以前的項目，全部都是使用了阿里雲的rocketmq，原因是不同的供應商的訂單的延時 ...

目錄 前言 環境 具體實現 前言 RocketMQ是阿里巴巴在2012年開源的分布式消息中間件，記錄下SpringBoot整合RocketMQ的方式，RocketMQ的安裝可以查看：Windows下安裝RocketMQ 環境 ...

新的閱讀體驗：http://www.zhouhong.icu/post/157 一、業務需求 　　需要實現一個提前二十分鍾通知用戶去做某件事的一個業務，拿到這個業務首先想到的最簡單得方法就是使用Redis監控Key值：在排計划時候計算當前時間與提前二十分鍾這個時間差，然后使用一個唯一的業務 ...

1 啟動消費者等待傳入的訂閱消息 2 發送延遲消息 3 確認 您應該會看到消息在其存儲時間后大約 10 秒被消耗。 4 延遲消息的使用場景 例如在電子商務中，如果提交訂單 ...

起因 看了兩篇關於golang中限流器的帖子： Gin 開發實踐：如何實現限流中間件 常用限流策略——漏桶與令牌桶介紹 我照着用，居然沒效果…… 時間有限沒有深究。這實在是一個很簡單的功能，我的需求是每分鍾限制大約xxx次請求，平均每秒限制到XXX除60次左右的請求也就夠了 ...

延遲隊列的需求各位應該在日常開發的場景中經常碰到。比如： 用戶登錄之后5分鍾給用戶做分類推送； 用戶多少天未登錄給用戶做召回推送； 定期檢查用戶當前退款賬單是否被商家處理等等場景。 一般這種場景和定時任務還是有很大的區別，定時任務是你知道任務多久該跑一次或者什么時候只跑一次，這個時間是確定 ...

使用場景 工作中大家往往會遇到類似的場景： 1.對於紅包場景，賬戶 A 對賬戶 B 發出紅包通常在 1 天后會自動歸還到原賬戶。 2.對於實時支付場景，如果賬戶 A 對商戶 S 付款 100 元，5秒后沒有收到支付方回調將自動取消訂單。 解決方案分析 方案一： 采用通過定時任務采用 ...