メッセージブローカー

重複するメッセージの対応

メッセージブローカーは、基本的にAt least oneceを保証している。そのため、２回以上メッセージが飛ばされる可能性がある。

  • 冪等なメッセージハンドラ
    • アプリケーションのメッセージの処理が冪等であるように作る
  • 重複メッセージを破棄
    • メッセージを処理するときに消費したメッセージIDをテーブルに格納する
    • 消費済みのメッセージを受けたときは登録に失敗するため検知できる

TODO

Apache Kafka、RabitMQとかとか