問題タブ [pika]

あるノードがメッセージを送信し、別のノードがメッセージの受信を待機し始めるシナリオが必要です。

メッセージが送信された後の各ノードはリスナーになり、メッセージを受信すると再びパブリッシャーになります。

AMQP プロトコルのいくつかの側面を理解しようとしています。現在、RabbitMQ を使用したプロジェクトがあり、python pika ライブラリを使用しています。したがって、質問は確認応答とメッセージのプリフェッチに関するものです。

1. コンシューマーのみのキューがあるとします (このキューが排他的として宣言されていることを確認してください)。だから私は正しく理解していますか: ack フラグの有無に関係なく? とにかく、複数のメッセージを同時に処理することはできません。他のまだキューに入れられているメッセージを受け取る可能性のある別のコンシューマーはありません。AMQP サーバーの負荷が軽減される可能性があるため、確認応答をオンにしない方がよいでしょう。

2. 確認応答がなければ、プリフェッチ カウントは何の意味もありません。正しい？

3. プリフェッチがどのように機能するかわかりません。新しいメッセージにコールバックがあり、その最終ステートメントでメッセージを承認または拒否します。これが唯一の機能であり、プリフェッチ カウントがどれほど大きくても、現在のメッセージが完了するまで別のメッセージは処理されません。では、なぜ prefetch_count 値を変更する必要があるのでしょうか?

前もって感謝します。

pika と rabbitmq を使用してラップトップから別のラップトップにメッセージを送信しようとすると、このエラーが発生します。これを解決する方法はありますか？

プロセスは終了コード 1 で終了しました

使用したコードは次のとおりです。

私はAndroid用の在庫管理システムクライアントに取り組んでおり、Pythonの経験がほとんどなく、Javaについて何も知らないため、SL4A Pythonを使用することにしました。

私はベースとしてrabbitmqとpikaライブラリを使用しています。Androidでピカライブラリが動作するようになりました。

問題は、私のコードが数時間でも失敗すると、プロジェクトに致命的なダメージを与えることです。SL4A は十分に信頼できると考えられていますか?

buildozer を使用して APK にすると、多かれ少なかれ安定しますか?

RabbitMQ send.pyの例に基づいた単純な python スクリプトがあります。元のsend.pyはセットアップで正常に動作しますが、追加のユーザーと仮想ホストを使用すると、実行時にスクリプトがハングしますconnection.channel()

実行すると、次のように表示されます。

その時点で、スクリプトは約 10 分間ハングします。次に、次のように出力します。

そして、pika.exceptions.ChannelClosed例外でクラッシュします。

私の推測では、チャネルは実際には存在しませんが、失敗したという兆候はありませconnection.channel()ん。

http://www.rabbitmq.com/tutorials/tutorial-two-python.htmlの「hello world」チュートリアルを使用しています。 worker.pyこのように見えます

このコードを使用して、仕事に実装しました。印刷後に例外が発生するキュー内のポイントが来るまで、すべてがスムーズに機能します[x] Done

プロセス間で接続が自動的に閉じられる方法がわかりません。キュー内の数百のメッセージに対してプロセスが正常に実行された後、突然このエラーが発生します。どんな助けでも感謝します。

rabbitmq を使用して rpc クライアントを実装したいと考えています。私のコードは主に次のようになります

このクライアントを停止する正しい方法は何ですか? 今、私channel.basic_cancel(self.on_cancel, self.consumer_tag)は別のスレッドから作成します。ただし、ピカFAQは言う It is not safe to share one Pika connection across threads.

消費をキャンセルする好ましい方法は何ですか?