RocketMQ （三）RocketMQ 怎么保證的消息不丟失？
一、消息發送過程 我們將消息流程分為如下三大部分，每一部分都有可能會丟失數據。 生產階段：Producer通過網絡將消息發送給Broker，這個發送可能會發生丟失，比如網絡延遲不可達等。 存儲階段：Broker肯定是先把消息放到內存的，然后根據刷盤策略持久化到硬盤中，剛收到 ...
原文：rocketMQ 消息的 tag
tag 的使用場景：不同的消費組，訂閱同一 topic 不同的 tag，拉取不同的消息並消費。在 topic 內部對消息進行隔離。 producer 發送消息，指定 tag consumer 訂閱 topic，指定 tag broker 存儲 consumer 訂閱的 tag 信息 broker 計算 tag 的 hashCode，直接取字符串的 hashcode 值 broker 存儲消息 ta ...
2019-12-01 14:09 0 1800 推薦指數：
相關推薦
rocketMQ(七) rocketMQ 消息端配置
一.消息隊列RocketMQ4.X消費者核心配置講解 consumeFromWhere配置(某些情況失效：參考 https://blog.csdn.net/a417930422/article/details/83585397 ...
RocketMQ源碼 — 九、 RocketMQ延時消息
通過設置消息被投遞的時間來實現的，但是Apache RocketMQ在版本4.2.0中尚不支持指定時間 ...
RocketMQ源碼 — 八、 RocketMQ消息重試
RocketMQ的消息重試包含了producer發送消息的重試和consumer消息消費的重試。 producer發送消息重試 producer在發送消息的時候如果發送失敗了，RocketMQ會自動重試。 重試幾次？ 由上面可以看出發送消息的重試次數區分不同的情況： 同步發送 ...
RocketMQ（二）事務消息&順序消息
一、事務消息的由來 1、案例 引用官方的購物案例： 小明購買一個100元的東西，賬戶扣款100元的同時需要保證在下游的積分系統給小明這個賬號增加100積分。賬號系統和積分系統是兩個獨立是系統，一個要減少100元，一個要增加100積分。如下圖： 2、問題 賬號服務扣款成功 ...
rocketMq消息的發送和消息消費
rocketMq消息的發送和消息消費 ###一.消息推送 ```java public void pushMessage() { String message = "推送消息內容！"; try { DefaultMQProducer producer = new ...
RocketMQ中Topic、Tag、GroupName的設計初衷
本文主要介紹RocketMQ中Topic、Tag、GroupName的概念、設計初衷以及使用方法。 一.Topic 首先看看官方的定義： Topic是生產者在發送消息和消費者在拉取消息的類別。Topic與生產者和消費者之間的關系非常松散。 具體來說，一個Topic ...
rocketmq對 topic 、consumerGroup、tag（selectorExpress）組合配置
多個服務器的情況下： 相同 topic 、consumerGroup tag 默認 均衡消費消息 相同 topic 、consumerGroup 當存在不同Tag的時候，會導致消費混亂，比如TagA的消息被TagB的消費者消費了。 相同topic 不同consumerGroup 默認 ...