rabbitmq

0熱

1答えて

トピックを使用してキューにメッセージを送信し、同じメッセージを受信して処理する2人のコンシューマを持つことはできますか？現在、私は2つの消費者を作成しているが、キューに入っているトピックを見ているキューを見ているが、最初のコンシューマはメッセージを消費してキューを削除し、2番目のコンシューマはメッセージを受信しない。

0熱

1答えて

ノードアプリケーション用のRbbitMQとの接続は1つだけで、パブリッシュコールは1つではありません。

新しいメッセージを発行するたびに、新しい接続が1つ作成されます。すべてのパブリッヒコールに1つの接続と1つのチャネルしか持たせたくありません。 rabbitmqのWebサイトからお読みください。 AMQPブローカーへの複数の接続が必要なアプリケーションがあります。ただし、同時に多数のTCP接続を開いておくことは、システムリソースを消費し、ファイアウォールを構成するのが難しくなるため、望ましくありま

3熱

1答えて

RabbitMQリクエストレスポンスメッセージ

私はJavaとSpring FrameworkでRabbitMQを使用していますが、プロデューサとコンシューマがあり、両方とも複数のインスタンスが実行されますが、プロデューサに送信される各リクエストは、その消費者は同じプロデューサ（要求を保持しているものとまったく同じもの）に返答することができるはずです。だから要件は次のとおりです。プロデューサーは、HTTPリクエストを受信するには、メッセージ

1熱

1答えて

RabbitMq：auto-ack = falseでプリフェッチを無効にする（prefetch_count = 0）

auto-ack = falseでプリフェッチを無効にすることはできますか？メッセージを確認するたびにキューからメッセージ（プリフェッチ）を読み取らないようにしたいだけです。私は 'consume_message'を呼び出すときにだけメッセージを読んでみたい。 prefetch_count = 0に設定すると機能しないようですが、「特定の制限はありません」と扱われます。 UPDATED：「pre

0熱

1答えて

Node.jsを使ったRabbitMQ RPC

私はRabbitMQを使ってNode.jsにRPCを実装しています。私はチュートリアルに従う、私は高権威であるために「rpc_client」として、すべてのクライアントのためのキューの同じ名前を主張し、ここでclient.jsは、サーバー内の関数を呼び出すことです： const amqp = require('amqplib'); async function client(){

0熱

1答えて

RabbitMQ Cマスタ経由で画像を送信することができません

私はRabbitMQ Cマスタ経由でバイナリデータをメッセージとして送信し、それを転送して別の画像ファイルにコピーしようとしています。私のコードは次のとおりです。クライアント/送信者： #include "amqp_wrapper_library.h" int main(int argc, char const *const *argv) { char const *hostn

0熱

1答えて

RabbitMQでメッセージをキューにルーティングする方法

さまざまなキュー（10000以上のキュー）にメッセージを動的にルーティングできるソリューションを開発したいと考えています。それは今まで私が持っているものです：交換タイプがtopicに設定されています。ルーティングキーに基づいて異なるキューにメッセージをルーティングすることができます。ルーティングキーが#.%numberOfQueue.#の10000個のキュー。 %numberOfQueue%は

0熱

1答えて

Django Celery：amqpに接続できません：// [Errno 10054]リモートホストによって既存の接続が強制的にクローズされました

プロダクションの準備中です。私はOS Xでテストしていましたが、今はWindows 2008に移行しています。OS Xでは正常に動作しました。私は新しいユーザーを作成しました。仮想ホストを使用しているユーザーに仮想ホストとアクセス許可を追加しました。 RabbitMQサービスが実行中です。アクセス許可セット：rabbitmqctl set_permissions -p vhost user "

0熱

1答えて

Haproxy Sockjs Websocket loadbalancingとRabbitMQのロードバランシングを同じ設定で

websocketロードバランスとRabbitMQロードバランシングを可能にするhaproxy（HAProxyバージョン1.5.18）の設定を探しています。私は多くのオプションを試してみましたが、どれも以下、動作するようには思えない私のhaproxy設定ファイルです： global log 127.0.0.1 local2 chroot /var/lib/hapro

0熱

1答えて

ウサギリスナー注釈は、私は現在、私のウサギのリスナー注釈のように設定しているYAML

からキュー名を取得します私のyamlファイルから。これをやりたいのは、yamlファイルのキュー名を変更するだけで、自分のキューを統合テスト用のテストキューに変更できるからです。注釈は一定の文字列を受け入れる必要があります。おかげで、