3

Majordomo API のpyzmq-mdpを使用したいと考えています。クライアントのリポジトリのは、よくわかりません。

myclient.py では、この例は MDPClient API を使用せずに手動でソケットを作成します。さらに悪いことに、リクエストの作成には mdp_request メソッドが使用されます。しかし、私はこれまでこれを試しました:

class Client(MDPClient):

    def on_timeout(self):
        print "Client Timed out."

def main():
    context = zmq.Context()
    mdp_client = Client(context, "tcp://127.0.0.1:8888", SERVICE)
    try:
        mdp_client.request(["hello"], timeout=5000)
    except RequestTimeout:
        print "Timed Out."


if __name__ == '__main__':
    main()

私はクライアントのみを実行しています。ブローカーなし。しかし、これは RequestTimeout 例外を発生させていません。次の疑問があります。

  • サンプルが MDPClient API を実装していないのはなぜですか?
  • 利用可能なリクエストメソッドがある場合、mdp_request メソッドの目的は何ですか?
  • 私のアプローチの何が問題になっていますか?

明らかな何かが欠けていますか?いくつかのガイダンスをお願いします。

4

1 に答える 1