1. 消息順序 場景：比如下單操作，下單成功之后，會發布創建訂單和扣減庫存消息，但扣減庫存消息執行會先於創建訂單消息，也就說前者執行成功之后，才能執行后者。 不保證完全按照順序消費，在 MQ 層面支持消息的順序處理開銷太大，為了極少量的需求，增加整體上的復雜度得不償失。 所以，還是在應用層 ...

消息事務 消息事務，是保證消息傳遞原子性的一個重要特征，和JDBC的事務特征類似。 一個事務性發送，其中一組消息要么能夠全部保證到達服務器，要么都不到達服務器。 生產者、消費者與消息服務器直接都支持事務性； ActionMQ的事務主要偏向在生產者的應用。 ActionMQ 消息事務流程圖 ...

分布式消息系統作為實現分布式系統可擴展、可伸縮性的關鍵組件，需要具有高吞吐量、高可用等特點。而談到消息系統的設計，就回避不了兩個問題： 消息的順序問題 消息的重復問題 RocketMQ作為阿里開源的一款高性能、高吞吐量的消息中間件，它是怎樣來解決這兩個 ...

一、為什么出現消息重復 從 Product 看 Rocketmq 提供三種發送消息模式 同步發送：Producer 向 broker 發送消息，阻塞當前線程等待 broker 響應 發送結果。DefaultMQProducerImpl 中如果沒有設置 超時、發送失敗，就會重發。 異步發送 ...

一、事務消息的由來 1、案例 引用官方的購物案例： 小明購買一個100元的東西，賬戶扣款100元的同時需要保證在下游的積分系統給小明這個賬號增加100積分。賬號系統和積分系統是兩個獨立是系統，一個要減少100元，一個要增加100積分。如下圖： 2、問題 賬號服務扣款成功 ...

ActiveMQ的消息事務 消息事務，是保證消息傳遞原子性的一個重要特性，和JDBC的事務特征類似。 一個事務性發送，其中一組消息要么能夠全部保證到達服務器，要么都不到達服務器。生產者，消費者與消息服務器都支持事務性。ActiveMQ得事務主要偏向在生產者得應用。 ActiveMQ消息事務 ...

kafka消息順序 我們知道，kafka是一個高性能、分布式容錯的消息發布-訂閱系統，現在kafka也能處理流數據了。多個生產者在往kafka發送數據的時候，消息的順序是不能保障的，也就是無序的。 有些場景，比如在用maxwell解析mysql的binlog日志的時候，發送到kafka，后面 ...

接上一篇：RocketMQ入門到入土（一）新手也能看懂的原理和實戰！ 一、事務消息的由來 1、案例 引用官方的購物案例： 小明購買一個100元的東西，賬戶扣款100元的同時需要保證在下游的積分系統給小明這個賬號增加100積分。賬號系統和積分系統是兩個獨立是系統，一個要減少100元，一個 ...