Stream 分組消費與持久化

比如在如下場景中，訂單系統我們做集羣部署，都會從RabbitMQ中獲取訂單信息，那如果一個訂單同時被兩個服務獲取到，那麼就會造成數據錯誤，我們得避免這種情況，這時我們就可以使用Stream中的消息分組來解決。 注意在Stream中處於同一個group中的多個消費者是競爭關係，就能夠保證消息只會被其中一個應用消費一次。 不同組是可以全面消費的（重複消費），同一組內會發送競爭關係，只有其中一個可以消費

>>阅读原文<<