RabbitMQがメッセージの消失を防ぐ仕組み
メッセージの損失を防ぐために、RabbitMQ ではさまざまな手段を提供しています。
- メッセージを永続化: RabbitMQはデフォルトではメッセージをメモリ上に保持しているため、サーバの再起動時や停電時にはメッセージが失われます。このような事態を避けるためには、メッセージをディスク上に永続化します。メッセージを送信する際には、メッセージの配信モードを2に設定することで、メッセージを永続化するように指定します。また、キューとエクスチェンジも永続化するように設定する必要があります。
- RabbitMQがトランザクションを提供し、メッセージ送信前にトランザクションを開始し、送信後にコミットします。送信中に例外が発生した場合、トランザクションをロールバックし、メッセージの喪失を防ぎます。
- 送信者確認メカニズム：送信者は確認モードを設定することでメッセージが送信されたことを確認できます。送信者は、メッセージを送信した後、RabbitMQ からの確認応答を待ちます。確認応答が届かなかった場合、メッセージは RabbitMQ サーバーに正常に送信されておらず、メッセージの再送信を選択できます。
- 応答メッセージング機能:メッセージ処理中に、コンシューマーは RabbitMQ に成功を通知するために手動で応答信号を送信できます。メッセージ処理中にコンシューマーで例外が発生した場合、メッセージはキューに戻され、他のコンシューマーが再処理を待ちます。
- バックアップとミラーリングキュー: RabbitMQはメッセージのバックアップを他のノードにサポートしてメッセージの損失を防ぎます。ミラーリングキューを作成し、複数のノードにメッセージを複製し、1つのノードが故障した場合にも、バックアップノードからメッセージを復元できます。
おすすめのメッセージを消失させない方法をいくつかご案内しました。ビジネスシーンに応じた方法を選択することで、高信頼なメッセージ送付が可能になります。
