概述 可靠同步發送 可靠異步發送 單向（oneway）發送 ：只管發送，直接返回，不等待消息服務器的結果，也不注冊回調函數，簡單地說，就是只管發，不管信息是否發送到了消息服務器中。 發送消息示例 /* * Instantiate ...

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

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

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

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

上一節消息重試里面提到了重試的消息可以被延時消費，其實除此之外，用戶發送的消息也可以指定延時時間（更准確的說是延時等級），然后在指定延時時間之后投遞消息，然后被consumer消費。阿里雲的ons還支持定時消息，而且延時消息是直接指定延時時間，其實阿里雲的延時消息也是定時消息的另一種表述方式，都是 ...

七、消息發送重試機制 1 說明 Producer對發送失敗的消息進行重新發送的機制，稱為消息發送重試機制，也稱為消息重投機制。 對於消息重投，需要注意以下幾點： 生產者在發送消息時，若采用同步或異步發送方式，發送失敗會重試，但oneway消息發送方式 發送失敗是沒有重試 ...

一.為什么選擇RocketMQ消息隊列？ 首先RocketMQ是阿里巴巴自研出來的，也已開源。其性能和穩定性從雙11就能看出來，借用阿里的一句官方介紹：歷年雙 11 購物狂歡節零點千萬級 TPS、萬億級數據洪峰，創造了全球最大的業務消息並發以及流轉紀錄（日志類消息除外）； 在始終保證 ...