SQS+BeanstalkでSpringBootのworkerアプリを構築する #AWS

キューを使ったシステムというのを自分で実装したことがなかったので、社内AWS勉強会のネタもかねて、SQSに挑戦してみました。

全体構成

AWSが提供するメッセージキューサービスである「SQS」にデータを登録すると、AWS ElasticBeanstalkで構築したworkerアプリ(SpringBoot製)がキューを処理していくという作りです。

workerについてはこちらを参考に。
http://dev.classmethod.jp/cloud/aws/aws-job-worker-beanstalk/

このWorker tierが実によくできているんです。この環境で提供されるEC2の中ではaws-sqsdというデーモンが動いており、指定したキューのメッセージをポーリングしてくれます。メッセージが配信されてくると、aws-sqsdは、そのメッセージをlocalhostに対して、HTTP POSTしてくれる、という仕組みです。

バッチを作ってキューのメッセージを取得しているのが通常だと思うのですが、そこの作りこみがしなくてもいいのが素晴らしいですね。既存アプリにキューを挟みたい場合の手間も軽減されます。

実際動かしてみる

キューを取得して、Chatworkに通知するworkerアプリを動かしてみます

workerアプリのビルド

サンプルアプリをGitHubから取ってきて、ビルドします。

git clone https://github.com/nyasba/awssqs-sample.git
cd ./awssqs-sample/aws-sqs-consumer
./gradlew clean build

./build/libs/aws-sqs-consumer-1.0.jar が作られたと思います。
これはメッセージ情報を受け取り、Chatworkへ通知するだけの簡単なアプリです。

Dockerfileのカスタマイズ

今回、ElasticBeanstalkのプラットフォームとしてDockerを利用しますので、Dockerfileを用意します。先ほどcloneしたeb 配下にaws-sqs-consumer-1.0.jarをコピーし、Dockerfileの設定値を書き換えます。

# Java8のDockerイメージを利用
FROM java:8

# workerアプリケーションをローカルからコンテナ側に追加する
ADD aws-sqs-consumer-1.0.jar aws-sqs-consumer-1.0.jar

# コンテナ側の8080ポートを外部に公開する
EXPOSE 8080

# SpringBootの起動コマンド
CMD ["java", "-Droomid=<ROOM_ID>", "-Dapitoken=<API_TOKEN>", "-jar", "./aws-sqs-consumer-1.0.jar"]

以下の2点は書き換える必要があります