イベント駆動アーキテクチャ

イベント駆動アーキテクチャとは

イベント駆動アーキテクチャは、 「注文が作成された」「支払いが完了した」のような出来事(イベント)を 発行し、それに関心のあるサービスがそれぞれ独立して反応する構成です。

サービスAがサービスBのAPIを直接呼び出す同期的な連携と違い、AはイベントをPublish(発行)するだけで、 誰がそれをSubscribe(購読)して何をするかを知る必要がありません。これによりサービス間の疎結合が実現します。

Pub/Subの仕組み

Order Service --publish--> [ "OrderCreated" event ] --> Event Bus / Broker
                                                              |
                          +-----------------------------------+-----------------------------+
                          |                                    |                             |
                  Inventory Service                    Notification Service          Analytics Service
                  (subscribe)                           (subscribe)                   (subscribe)
                  在庫を引き当てる                        確認メールを送る               集計データを更新する

擬似コードで表すと、PublisherはSubscriberの存在を意識せずイベントを発行するだけです。

// Publisher側(Order Service)
function createOrder(input):
    order = Order.create(input)
    save(order)
    eventBus.publish("OrderCreated", { orderId: order.id, items: order.items })
    // Inventory/Notification/Analyticsを直接呼び出さない

// Subscriber側(Inventory Service)
eventBus.subscribe("OrderCreated", (event) => {
    reserveInventory(event.items)  // 独立して在庫を引き当てる
})

// Subscriber側(Notification Service)
eventBus.subscribe("OrderCreated", (event) => {
    sendConfirmationEmail(event.orderId)  // 独立して通知を送る
})

主なパターン

メリットと注意点