Pikaを使用して非同期RPCクライアントを作成する方法は？

私は問題はナキウサギのRPC blocking exampleによると、RPCコールは使用していないということですPikaを使用して非同期RPCクライアントを作成する方法は？

、私は次の例で私のコードを基づかよ、ナキウサギを使用して非同期RPCクライアントを作成しようとしています交換をするときはいつでも交換機を開こうとすると、

self._channel.exchange_declare(self.on_exchange_declareok, 
            '', 
            self.EXCHANGE_TYPE)

私は切断されます。また、exchange_declare関数をスキップしてキューを宣言するようにジャンプしようとすると、同じ結果が得られます。これにアプローチする適切な方法は何ですか？

RabbitMQ接続を処理するバックグラウンドスレッドを追加することで、Async RPCクライアントを実装できます。私はピカとフラスコの利用可能な例を持っていますhere。

また、私自身のライブラリhereに基づいて、もう少し精巧な例があります。

これらは明らかにブロッキング接続に基づいていますが、少なくとも非同期ソリューションを提供しています。

2016-05-30 14:28:46 eandersson

RPC example on rabbitmq tutorialについてはどうですか？

2016-05-16 13:44:27 cantSleepNow

これはBlockingConnectionを使用する基本的な例ですが、私はTornadoアダプタなどの非同期接続を使用したものを探していました。 –

あなたは歓迎され、ごめんなさい - その部分を見逃しているに違いありません... – cantSleepNow

答えて