在RocketMQ 重復消費問題 | 訂單系統核心流程引入冪等性機制一文中,我們討論了消息重復消費的問題,比較好的方案是采用在消費側使用業務判斷法來保證接口的冪等性,這樣就能避免消息重復消費的問題。 ...
在RocketMQ 重復消費問題 | 訂單系統核心流程引入冪等性機制一文中,我們討論了消息重復消費的問題,比較好的方案是采用在消費側使用業務判斷法來保證接口的冪等性,這樣就能避免消息重復消費的問題。 ...
Redis-Cluster 即使是使用哨兵,此時的Redis集群的每個數據庫依然存有集群中的所有數據,從而導致集群的總數據存儲量受限於可用存儲內存最小的節點,形成了木桶效應。而因為Redis是基於內 ...
關於 Topic 和 Partition Topic 在 kafka 中,topic 是一個存儲消息的邏輯概念,可以認為是一個消息集合。每條消息發送到 kafka 集群的消息都有一個類別。物理上來 ...
消息的存儲原理: 消息的文件存儲機制: 前面我們知道了一個 topic 的多個 partition 在物理磁盤上的保存路徑,那么我們再來分析日志的存儲方式。通過 [root@ ...
客服接到用戶的反饋:訂單支付成功之后,用戶收到了多張優惠券。按照正常業務來說,完成訂單之后只會給用戶發送一張優惠券,而現在發送了多張。 如上圖所示,訂單系統與優惠券系統通過 RocketMQ ...
clone 並導入源碼 本地啟動 NameServer 本地啟動 Broker 本地運行生產者與消費者代碼 完成上述步驟之后,RocketMQ的源碼環境就搭建完畢了,之后就可以 ...
集群 先來簡單了解下redis中提供的集群策略, 雖然redis有持久化功能能夠保障redis服務器宕機也能恢復並且只有少量的數據損失,但是由於所有數據在一台服務器上,如果這台服務器出現硬盤故障,那 ...
目前幾乎很多大型網站及應用都是分布式部署的,分布式場景中的數據一致性問題一直是一個比較重要的話題。分布式的CAP理論告訴我們“任何一個分布式系統都無法同時滿足一致性(Consistency)、可用性( ...
消費端消費消息的原理 我們通過上一節課的講解,知道有兩種方法可以接收消息,一種是使用同步阻塞的MessageConsumer#receive方法。另一種是使用消息監聽器MessageListener ...