問題タブ [py-amqplib]

Python amqplib ライブラリを使用して、Rabbitmq キューの最大長を設定しようとしています。しかし、キューは制限されません。

http://www.rabbitmq.com/maxlength.html

キューを削除するたびにRabbitmqサーバーをリセットしました。

私は何を間違っていますか？

ありがとう

アドバイスが必要です。

これは、node.js で開始する例です。

これをログに記録する ActiveMQ の書き込み:

61616ポートのプロトコルはtcpですが、amqpではないため、このエラーが発生したと思います。しかし、コンソール出力でポートを 5672 に変更しようとすると、次のように表示されます。

netstat -antp はこれを返します:

ご覧のとおり、ActiveMQ は 5672 でリッスンしますが、接続しません。どうして？？？node-amqp.js などの他の node.js モジュールを試してみましたが、何も変わりません。connection_tunnig で何かを見逃しているのでしょうか? (frameSize など) Pls、本当にアドバイスが必要です。ありがとうございました。

私はpy-amqpモジュールとPython 3.4を使用しています。複数のリスナーを実行し、1つのプロデューサーを開始してメッセージを公開すると、リスナーは1つのメッセージを受け取り、同時に処理を開始します。メッセージはDBに一度だけ書き込まれる必要があるため、そのような動作は必要ありません。そのため、最速のワーカーが DB にメッセージを書き込み、他のすべてのワーカーはそのメッセージが既に存在すると言います。

プロデューサー：

ワーカー：

また：