イベントバスパターン(Event Bus)は、システムのコンポーネント間の通信をイベントの公開とリスニングを通じて実現するアーキテクチャアプローチです。この場合、コンポーネントは直接お互いを認識せず、発行者と購読者の原則に基づいて緩やかな相互作用が行われます。
使用法: このパターンは、多くのモジュール間でスケーラブルで拡張可能な相互作用を確保する必要がある場合に役立ちます — たとえば、複雑なWebアプリケーション、デスクトップシステム、マイクロサービスプラットフォームなどです。
pyeeライブラリを使用したPythonのコード例:
from pyee import EventEmitter bus = EventEmitter() def on_user_created(user): print(f"ユーザーが作成されました: {user}") bus.on('user_created', on_user_created) bus.emit('user_created', {"id": 1, "name": "イワン"})
主な特徴:
イベントバスのすべてのイベントは永続的である必要がありますか?
いいえ、必ずしもそうではありません。ほとんどの場合、イベントバスは保存されない(エフェメラル)イベントを扱います。イベントの損失を避けることが重要な場合(たとえば、Kafkaを介して)、永続性が必要です。
発行時にリスナーが登録されていない場合、イベントは失われますか?
はい、システムがイベントを保存しない場合(エフェメラル)、イベントは失われます。保証されたデリバリーには耐久性のあるイベントバス(たとえば、永続的キューを持つRabbitMQ)が必要です。
同期コードと非同期コードのために同じイベントバスを制限なしに使用できますか?
いいえ、同期イベントバスはすべてのハンドラが完了するまでスレッドをブロックする可能性があり、高負荷には不適切です。スケーラブルなシステムでは、非同期イベントバスを使用するか、イベント処理を別のプロセスやスレッドに移行します(たとえば、Celeryを通じて)。