前言 在開發中經常會遇到延時任務的需求，例如在12306購買車票，若生成訂單30分鍾未支付則自動取消；還有在線商城完成訂單后48小時不評價 ，自動5星好評。像這類在某事件觸發后一段時間內執行的需求任務我們稱之為 延時任務。 那么如何實現延遲任務呢？ 第一反應是利用 ...

rocketmq提供一種延時消息的解決方案，就是在特定的時間到了，消息才會被投遞出去供consumer消費。總體來是簡單的場景是滿足了，但是需要注意的是延時的時間是需要按照默認配置的延時級別去配置的，而不是隨意設置消息的延時時間。 如果想不受延時級別的約束 可以參考之前的一遍文章http ...

rocketmq 的延時消息不能支持任意延時,她定義了18 個延時等級,並且我們可以指定這18 個延時等級的延時時間. 發送消息的時候只需在消息中指定 當前消息的 延時等級即可,並且這個延時消息不是立刻翻到目標消息隊列的,rocketmq 定義了 18 個 不可見的 隊列,延時消息 ...

RocketMQ的消息重試包含了producer發送消息的重試和consumer消息消費的重試。 producer發送消息重試 producer在發送消息的時候如果發送失敗了，RocketMQ會自動重試。 重試幾次？ 由上面可以看出發送消息的重試次數區分不同的情況： 同步發送 ...

初始化消費者和生產者 生產者 設置rocketmq的accesskey 和secretkey 以及rocketmq的 binder server。 首先 編輯一個配置類，將關於配置rocketmq的東西寫在配置類中 ` @Component @Getter @Setter ...

分布式事務是一個復雜的問題，rmq實現了事務的最終一致性，rmq保證本地事務成功消息一定會發送成功並被成功消費，如果本地事務失敗了，消息不會被發送。 rmq事務消息的實現過程為： producer發送half消息 broker確認half消息，並通知producer，表示消息已經成功 ...

RocketMQ本身支持順序消息，在使用上發送順序消息和非順序消息有所區別 發送順序消息 send方法帶有參數MessageQueueSelector，MessageQueueSelector是讓用戶自己決定消息發送到哪一個隊列，如果是局部消息的話，用來決定消息與隊列的對應關系。 順序 ...

RocketMQ源碼解析-消息消費 1.消費者相關類 2.消費者的啟動 3.消息的拉取 4.消息的消費 5.消費隊列的負載 6.消費進度管理 看了很多遍的代碼，還是決定動手把記錄下來，梳理一下整體結構和實現細節 RocketMQ中消息的消費分為2種方式，一種是pull模式，一種 ...