對任何一條消息都要做到精確一次的消費，才能保證系統的正確性，kafka並不提供准確一致的消費API，需要我們 ...

rocketMq實現順序消費的原理 produce在發送消息的時候，把消息發到同一個隊列（queue）中,消費者注冊消息監聽器為MessageListenerOrderly，這樣就可以保證消費端只有一個線程去消費消息 注意：是把把消息發到同一個隊列（queue），不是同一個topic，默認 ...

1.定義 精確一次消費（Exactly-once） 是指消息一定會被處理且只會被處理一次。不多不少就一次處理。 如果達不到精確一次消費，可能會達到另外兩種情況： 至少一次消費（at least once），主要是保證數據不會丟失，但有可能存在數據重復問題。 最多一次 ...

1. 保證消息被消費 即使消息發送到了消息隊列，消息也不會萬無一失，還是會面臨丟失的風險。 我們以 Kafka 為例，消息在Kafka 中是存儲在本地磁盤上的， 為了減少消息存儲對磁盤的隨機 I/O，一般我們會將消息寫入到操作系統的 Page Cache 中，然后在合適的時間將消息刷新到磁盤 ...

一次 RocketMQ 順序消費延遲的問題定位 問題背景與現象 昨晚收到了應用報警，發現線上某個業務消費消息延遲了 54s 多（從消息發送到MQ 到被消費的間隔）： 查看 RocketMQ 的監控，發現確實發生了比較多的消息積壓： 從 RocketMQ-Console 上面查看 ...

至少一次(At least Once)指每個消息必須投遞一次。Consumer先Pull消息到本地，消費完成后，才向服務器返回ack，如果沒有消費一定不會ack消息，所以RocketMQ可以很好的支持此特性。 生產者 在同步非順序投遞的時候，每次都是輪詢到不同的隊列 ...

簡使用pop，不能保證最少消費一次，比如pop超時可能中途丟失，或者消費者處理過程中異常而未能處理完。 解決此問題有多種方法： 1) 方法一：使用rpoplpush替代pop 這種方法相當於建立了一個回滾，由於操作是在redis端完成的，可保證數據不會丟，當消費者完成業務邏輯后，再清掉 ...

線上有一個消息消費服務xxx-consumer，使用spring-kafka框架，主線程批量從消費隊列（kafka）拉取交易系統生產的消息，然后提交到子線程池中挨個處理消費。 public abstract class AbstractMessageDispatchListener ...