Ruby 2.2.0 リファレンスマニュアル > ライブラリ一覧 > drbライブラリ > DRb::DRbProtocolモジュール
クラスの継承リスト: DRb::DRbProtocol
drb で使われる通信プロトコルを取り扱うモジュールです。
通常ユーザが使うことはないでしょうが、drb の ための新しい通信手段を定義したい場合には このモジュールを使う必要があります。 通信手段を定義したクラスを DRb::DRbProtocol.#add_protocol で drb に登録することで、追加ができます。
デフォルトでは DRbTCPSocket クラスを用い、druby://... という URI を指定することで TCP/IP で通信します。
通信プロトコルを追加する例としては、 例としては drb/unix で定義している DRb::DRbUNIXSocket や サンプルの sample/drb/http0.rb、 sample/drb/http0serv.rb などを見てください。
これらの例を見てわかるように、通信クラスでは取り扱えない URI が open や open_server に渡された場合は例外 DRb::DRbBadScheme を raise することで、その URI が取り扱えないことを drb ライブラリに 伝えます。
上で説明した通信プロトコル定義クラスは、以下のクラスメソッドを そなえている必要があります。
uri で指定したサーバへの接続を開く。 返り値として、プロトコルクラスのインスタンスで、開いた接続を保持した オブジェクトを返さなければなりません。
サーバを起動し、 uri で指定した場所で接続を待ち受けます。 返り値として、プロトコルクラスのインスタンスで、接続を待ち受けている オブジェクトを返さなければなりません。
uri をパースして、そこに含まれるオプション("?param=val" など)を取り出します。 返り値として、[uri, option] という配列を返します。
プロトコルクラスは DRb::DRbProtocol.#add_protocol で登録します。
DRbProtocol module は登録された各プロトコルクラスに対して順に open/open_server を呼び出して、接続を確立しようとします。 各プロトコルクラスはその URI が取り扱える場合は接続を確立/待受けし、その 通信を取り扱うオブジェクトを返します。URI が取り扱えない場合は DRb::DRbBadScheme を発生させなければなりません。 DRbProtocol module に登録されたクラスでは URI を取り扱えない 場合は DRb::DRbBadURI が発生します。 URI は妥当であるが、通信に問題が発生した場合は DRb::DRbConnError を発生させる必要があります。
プロトコルクラスの open_server で返されるオブジェクトは以下のメソッドを 持っている必要があります。
接続を受け付けます。返り値としてクライアントとの通信ができるオブジェクト (後で説明します)を返します。
接続の待受を終了します。
接続を待ち受けている uri を返します。
プロトコルクラスの open で返されるオブジェクトは以下のメソッドを 持っている必要があります。
ref で指定されているオブジェクトの msg_id で指定されているメソッドを arg という引数と b というブロック付きで呼び出す、というリクエストを 送ります。DRbMessage#send_request を呼び出して通信オブジェクトが 保持しているストリームにデータを送る、というのが最も簡単なこのメソッドの 実装法です。
サーバからリプライを受け取り、[success-boolean, reply-value] という配列を 返します。DRb.recv_reply を呼び出し、通信オブジェクトが 保持しているストリームからリプライを受け取る、というのが最も簡単な このメソッドの実装法です。
接続が生きているならば真を返し、切れていれば偽を返します。
接続を閉じます。
プロトコルクラスの open_server で返されるオブジェクト の accept メソッドで返されるオブジェクトは以下のメソッドを持っている必要 があります。
クライアントからのリクエストを受け取り [object, message, args, block] という配列を返します。 DRbMessage#recv_request を呼び出してストリームから メッセージを読み取る、というのが最も簡単な このメソッドの実装法です。
クライアントにリプライを送る。 DRbMessage#send_reply を呼び出して ストリームにメッセージを書き込む、というのが最も簡単な このメソッドの実装法です。
接続を閉じる
add_protocol(prot) -> ()[permalink][rdoc]新たなプロトコルを DRbProtocol モジュールに登録します。