LaravelでFanoutパターン

---

ユースケース

• あるアプリケーションで発火した1つのイベントを複数のアプリケーションでサブスクライブしたい
  • CQRSとかで

ソリューション

• AWS SNS + AWS SQS の Fanout Pattern

Laravel用ライブラリ

github.com

サンプルアプリケーション

github.com

• terraformで立ち上がるSNS/SQSインフラ一式
• アプリケーション2つ
  • app_a: publisher / subscriber
  • app_b: subscriber

処理の流れ

1. ユーザがapp_aの/publishにアクセスする
2. app_aはSNSメッセージをトピックにpublishする
3. SNSはapp_a,app_b用のSQSキューにメッセージを複製してpushする
4. app_a, app_bのジョブワーカーは自分のSQSキューのメッセージをpullする (subscribe)
5. app_a, app_bは、メッセージに含まれているSNSのarnから実行すべきジョブを特定し、ジョブを実行する。

ジョブの特定のためにarnや決めのフィールドの値(このライブラリではSubject)を使うのがミソのよう。

hackernoon.com

Laravel Worker

one interesting option is to tie the SNS Topic ARN to a specific Job class.