パブ/サブ付きRuby on Railsについてさらに詳しく

Ruby on Rails (Rails、RoR)で書かれた有名なWebアプリケーションフレームワークです。 ルビー プログラミング言語。 パブ/サブ と呼ばれるソフトウェアデザインパターンの略称である。 パブリッシュ・サブスクライブ.Railsのソフトウェア・コンポーネント間の通信をPub/Subでどのように処理できるかを説明する。

パブ／サブとは？

パブ/サブ は、サービス間通信を提供するソフトウェアのデザインパターンである。サービス
は、発行者（生産する人）と受信者（消費する人）の2つの役割のいずれかを伴う。何が
消費されるべき生成物は、イベント、メッセージ、通知として決定される。その中で
本記事では、両者は同じものを指す言葉として同じ意味で使われている。
生産するサービスは消費する人を知らない。消費するサービスは
メッセージの発信元を知ることができる。お互いに知らないままでいられる。これは
メッセージキューでは、メッセージを送信するコンポーネントがその宛先を知っていることが多い。
- このスタイルのメッセージングでは、どこにいてもメッセージを送ることができる。このメカニズムは
の パブ/サブ そしてそれは、両者が切り離されていることを意味する。

相互の利益を表現するためには、共通の理解が必要である。したがって
この2つの役割には、メッセージのプロデューサーと、メッセージのプロデューサーの間のスティックという暗黙のメカニズムがある。
メッセージの消費者が出会う。このメカニズムは、サブジェクト、サブスクリプション、またはトピックと呼ばれる。これは
メッセージのサブジェクトへの分類を担当し、本質的にはステートレス・メッセージ・フィルタである。
トピックは放送局の役割を果たす。パブリッシャーはトピックへのメッセージを作成する、
サブスクライバはトピックからのメッセージを即座に受け取る。なぜなら
サービスでは、メッセージを交換する最も効率的な方法は、それらを非同期で処理することである。

Pub/SubなしのRails

デフォルトでは、コンポーネント間でメッセージを受け渡すソフトウェアデザインパターンにRailsのオーバーヘッドはありません。開発者は標準の オブジェクト指向プログラミング (OOP）パラダイム：関数にパラメータを渡し、値に関するクラスを求める。

アプリケーションがそれほど複雑でない場合は、これで十分かもしれない。アプリケーションの規模が大きくなると、例えば、いくつかの操作を非同期で行う必要が出てくる。 プロジェクト は、そのデータ・ワークフローを解決する抽象化を必要としている。車輪を再発明する代わりに、開発者は パブ/サブ この抽象性の欠如を埋めるために。

RailsによるPub/Subの長所

• アクティブレコードのコールバックを避ける。
• システムに非同期並列処理を追加することで、パフォーマンス、信頼性、スケーラビリティが向上する。
• メッセージは、システムのさまざまな部分に非同期にブロードキャストすることができる。
• システムのさまざまな部分にメッセージを非同期にブロードキャストできるようにする。
• デカップリング - 機能の追加や変更は、Pub/Subのため何も影響しない。
  すべての相互作用の仕方を変更することができる。
• メッセージコンシューマーは、定期的にアップデートや新しいメッセージをチェックする必要がなくなります。
  情報を提供します。特に、以下のようなシステムで問題となる配信遅延を減らすことができる。
  遅れは許されない。
• システムが処理できる加入者数に制限はない、
  アップグレード、増殖、消滅はいつでも可能だ。

RailsによるPub/Subの欠点

• Pub/Subシステムの主な欠点は、パブリッシャーとサブシステムが切り離されていることである。
  契約者

Rails Pub/Subの紹介

Railsのソースの例は、ライブラリ
パブ／サブ・オン・レイルズ (Rubyの命名法では、ライブラリのことをgemと呼びます）：詳細はgemのreadmeを参照してください。実装はモジュールで構成されています：

1. ドメイン
2. イベント
3. イベントハンドラ、
4. イベント出版社
5. 購読。

ドメイン

Pub/Subのコンテキストを提供するために、ビジネスロジックを記述する。 コード.

 モジュール Notifications
   extend PubSub::Domain
 終了

 モジュール Reports
   extend PubSub::Domain
 終了

イベント

これは、何が起こったかを記述するクラスである。例えば、キャンセルされた、変更された、作成された、破壊された、送信された、更新された。イベント名は次のようになります：これは財務諸表が作成されたことを意味します。

 クラス Reports::ProfitAndLossStatementCreatedEvent < PubSub::DomainEvent
   属性 :profit_and_loss_statement_id, Types::Strict::Integer
 終了

イベントパブリッシャー

イベントを発することができるクラス。この例では、サービス・レポートを作成しています。レポートが正常に作成されたら、そのレポートを作成したイベントを発行します。

クラス Reports::ProfitAndLossStatementService
   include PubSub::Emit
    def execute
     emit(:report_profit_and_loss_statement_created, profit_and_loss_statement_id: id) if result.ok?
   end
 end

イベントハンドラ

このクラスは、イベントの処理に応答して実行されなければならない。

モジュール Notifications
 class ReportsProfitAndLossStatementCreatedHandler < PubSub::DomainEventHandler
   def call
     ReportMailer.profit_and_loss_statement(profit_and_loss_statement).deliver_now
   終了

   プライベート

   def profit_and_loss_statement
     ProfitAndLossStatement.find(event_data.profit_and_loss_statement_id)
   終了
 終了
終了

サブスクリプション

イベントは、サブスクリプションを通じてハンドラに結び付けられる。

を通知します：
 reports__profit_and_loss_statement_created: async

使用例：

• ソーシャルネットワークの「フォロー」機能、
• モノのインターネット
• 郵送、
• 生成されたファイルに関する通知。

似たようなパターン

1. イベントバス - コンポーネントは、誰がそれを拾うのか、何人の回答者が反応するのかを知ることなく、EventBusにイベントを送信することができます、
2. オブザーバー - サブジェクトは、オブザーバーと呼ばれる依存者のリストを保持し、その状態が変化するたびに通知する、
3. プーリング - ポーリングでは、クライアントは定期的に新しいイベントやデータがあるかどうかをシステムに問い合わせる。

宝石

• https://github.com/edisonywh/rocketman

• https://github.com/krisleech/wisper

• https://github.com/stevo/pubsubオンレール

概要

Pub/subはRuby in Railsでは一般的なアプローチではありません。記事で紹介したように、このパターンはプロジェクトに多くの利点をもたらします - コードをクリーンにし、サービスを切り離し、簡単にスケーラブルにすることができます。