問題タブ [node-amqp]

SSL経由でrabbitMQサーバーに接続するためにMeteorアプリでnode-amqpを使用しています。ここに私の接続文字列があります：

ただし、接続は行われません。以下は、RabbitMQ エラー ログにあります。

レコード オーバーフロー エラーで見つけられるのは、実行中の Erlang のバージョンを確認することだけです。接続しようとしているボックスは最新バージョンを使用しています。RabbitMQ を実行しているボックスについてはわかりませんが、調べてみます。それ以上の助けをいただければ幸いです。

私は、rabbitmq(AMQP) からのメッセージを消費する node.js クライアント (サブスクライバー モジュール) を作成しようとしています。rabbitmq でトピック (exchangeName) を実装しようとしています。

このタスクに (easy-amqp) または postwait を使用しようとしています。

パブリッシャー メソッドを Java で記述しましたが、サブスクライバー メソッドを javascript(node.js) で記述したいと考えています。

私の Java プログラムは正常に動作し、rabbitmq にメッセージを送信できます。

サブスクライバーメソッドを台無しにしたと思います。サブスクライバー メソッドを実行すると、エラーは発生せず、コンソールにもメッセージが出力されません。

私のJavaメソッドはやや似ています

//js のサブスクライバー メソッド (node.js) //using (postwait- node-amqp )

これによりエラーは発生しませんが、コンソールにメッセージが出力されません。

そこで、easy-amqp という別のライブラリに出会いました。私はそれを試してみました

// easy-amqp を使用する加入者。

これも私に望ましい結果を与えません。

アドバイスが必要です。

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

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

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

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

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

次のコードを使用して、RabbitMQ にメッセージを送信するとします。

...その後、メッセージは送信されず、プロセスは終了します。を削除するprocess.exit()と、メッセージは送信されますが、プロセスは終了しません。

node-amqpがメッセージを送信したときに教えてもらうにはどうすればよいですか?

Node.js で次のエラーを受け取りました。これは AMQP に関連していると思います。

誰でも問題が何であるかを指摘できますか?

接続に使用するモジュールのコードは次のとおりです。

そして、ここでそのメソッドを呼び出します。

デフォルトの取引所に発行したときに、確認が返ってこないようです。現在、この投稿で提案されている node-amqp のマスター ブランチを使用しています。

コード：

デフォルトの交換は、空の文字列を使用した直接交換だと思います (他のすべてのオプションはデフォルトです)。exchange.publish メソッドによると、confirm オプションが true の場合、指定されたコールバックが呼び出されます。自分で交換を作成しようとしましたが、運もありませんでした。

RabbitMQ Web サイトの基本的な Python 受信スクリプトを使用して、メッセージを正常に発行していることを確認できます。

デフォルトの交換は、publish メソッド内で ack メッセージを発行しますか? 私はこれを間違って呼んでいますか？

クラスターとして接続された 2 つの Rabbitmq ノード (キューのレプリケーションなし) があり、4 つのワーカーがあり、すべてが同じキュー "myqueue" にバインドされています。今、手動でそのキューにメッセージを発行します (パブリッシャーは Rabbit のいずれかに接続できます)。ノード .. 結果には影響しません)。

今、これが起こります: そのキューにメッセージをパブリッシュするたびに、コンシューマーまたはパブリッシャーがどのノードに接続されているかに関係なく、ラウンドロビン方式でワーカー/コンシューマーに配信されたメッセージを見つけます。同じ結果です。

これはRabbitmqの「prefetch_count」の影響だと言われたのですが、それがどうしてなのか、というか、それが正しいかどうかもわかりません。