RabbitMQ メッセージをリッスンし、各メッセージを少しだけ処理して、別の取引所に送信する必要があります。これまでに見た各例には、次のいずれかが含まれています。
reader_connection.ioloop.start()
またはこれ：
writer_connection.ioloop.start()
メッセージの受信と送信の両方が必要なので、おそらく両方のループを同時に実行する必要があります。それを達成する方法はありますか？
1 に答える
-1
パブリッシャーとサブスクライバーの間に違いはありません。同じ接続または別の接続を使用してパブリッシュとサブスクライブを行うことができます (両方の接続で ioloop を開始する必要があります) https://pika.readthedocs.org/en/0.10.0/examples/connecting_async. html
于 2016-03-17T16:56:36.367 に答える