Amazon SQSを使ったSpringアプリケーション(1)

今回からは数回に渡り、Spring Cloud AWSを用いてメッセージキューサービス「Amazon SQS(Simple Queue Service)」へアクセスするSpringアプリケーションの実装方法について解説していきます。

解説にあたっては以下の前提知識がある開発者を想定しています。

また、動作環境は以下のバージョンで実施しています。

なお、将来的には、AWSコンソール上の画面イメージや操作、バージョンアップによりJavaのソースコード内で使用するクラスが変更される可能性があります。

Amazon SQSの概要

Amazon SQSはS3と同じく、リージョン単位で提供される完全マネージド分散型キュー配信方式のメッセージサービスです。複数のサーバに複数のメッセージのコピーを保存し、信頼性を確保しながら最低1度の配信を保証しています。大容量のデータを高スループットで転送可能であり、メッセージ送信の信頼性が高く、各コンポーネントを疎結合にして、アプリケーションを構成することが可能です。

メッセージキューは以下のようなURLフォーマット、メッセージID、受信ハンドル(ReceiptHandle)で識別され、操作用のAPIが提供されています。

http://sqs.<region>.amazonaws.com/<accout-id>

キューの属性は、以下の通りです。

SQSでは、通常メッセージの処理順序でシーケンス性が保証されません。メッセージ順序を保証する場合はFIFOキューを利用します。また、SQSには「可視性タイムアウト(Visibility Timeout)機能」があります。

「可視性タイムアウト」とは、あるキューが処理中に異常処理した場合、別のノードでキューを処理するために、キューをロックした状態で残しておく時間のことです。ロックをかけることで、複数のノードが同じキューを処理することを回避します。

また、処理できなかったキューを除外し、「デッドレターキュー」として、別のキューに蓄積しておくことも可能です。キューはほかのユーザーとも共有することができ、暗号化オプション、匿名でほかのAWSユーザーと共有するオプション、アクセス許可を利用して特定のユーザーとシェアするオプションがあります。なお、その場合、料金を負担するのはメッセージの所有者です。

SQSを使ったアプリケーションの処理パターン

上述のような特性を持つキューですが、アプリケーションの処理中にキュー操作を組み込むことにより、疎結合で耐障害性／パフォーマンスに優れたアプリケーションを構築することができます。キューを使った代表的な処理パターンは以下の通りです。

1. Webアプリケーションが処理要求を受け付け、クライアントには受付要求が完了したことを返却する。
   ・後続の処理は別のイベントを契機として、後続の処理を１つのトランザクションとして非同期実行します(翌日付の振込などが代表的な例です)。
   ・Webアプリケーションの受付とは別に負荷が高い処理を別プロセスで実行します(ディレードバッチとも呼ばれます。帳票データを一括してPDF化する処理要求などが代表的な例です)。
2. 他のアプリケーションからの処理要求を契機として、一括処理を起動する。
   ・マネジメントセグメントにある運用端末から、バックヤードでフロントから受け付けたデータの一連の業務処理実行を行います(銀行口座開設の受付に対する審査などが代表的な例です)。
3. クラウドサービスへのイベントを契機として、一括処理を起動する。
   ・共有ストレージへの書き込み、メタ情報の永続化を１つのトランザクションとして実行します(画像データのサムネイル作成やそのファイルパスをデータストアに保存する処理などが代表的な例です)

処理やワークロードに応じて、適切なユースケースでSQSを活用することで、一部のサーバに障害が起こった場合でも安定して処理を行うことができます。ただし、上記の非同期処理においては、同期型処理の場合に比べ、実行エラーの対処が複雑化しがちです。そのため、ユーザビリティを損なわない適切な例外ハンドリング設計が重要になります。

SQSキューの作成

それでは、早速AWSコンソールからキューを作成して使用してみましょう。サービスメニューから「SimpleQueueService」を選択し、「新しいキューの作成」ボタンを押下し、キュー名を入力してキューのタイプを選択します。

前節で説明した、デフォルト可視性やデッドレターキューなどのオプション設定を行う場合は、「キューの設定」ボタンを押下します。オプションのパラメータを必要に応じて入力し、「キューの作成」ボタンを押下してください。

これでキューの設定が完了しました。次回以降は、このキューにメッセージを送信／ポーリングで取得するProducer、Consumerアプリケーションと、そこから実行されるSpringBatchアプリケーションを実装していきます。