rabbitmq

0熱

1答えて

アムのRabbitMQからのメッセージを消費しますが、消費者は、その後 [MainProcess] Received message: RT @Iamsidneyy: Kenya in scientific terms [WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!? The

0熱

1答えて

コンシューマからプロデューサへの応答を送信するRabbitMQ

RabbitMQを使用して、サーバから複数のコンシューマにデータを送信しています。キューからメッセージが削除される時期を決めなければならないので、コンシューマーがサーバーにメッセージを送信するように実装したいと思います。すべての消費者が応答を送信した場合は、メッセージを削除します。私は既にRPC呼び出しを検出しましたが、それは私が持っている問題のために複雑であると思います。サーバーにすばやい応答

0熱

2答えて

デベロッパーとプロダクションに同じrabbitmqを使用するとセロリのキューを保護する方法

私はrabbitmqとセロリをバックエンドタスクに使用していますが、dev/testと同じrabbitmqを使用したいと思いますが、誰かが誤って製造待ち行列のためにセロリの労働者を出し、dev/testのためにそれらを使用します。可能であれば、同じrabbitmqバックエンドにもアクセスできるセロリのワーカーが、セロリのキューにアクセスするのを防ぐ方法を教えてください。

1熱

1答えて

FilebeatでRabbitMQを設定する方法

私たちは、ELKを使用してログを制御し、木場でそれらを可視化します。私たちはグリッドマシンとクライアントサイドマシンの両方から約30種類のログを送信しています。クライアント側のマシンがfilebeatと連携 - > logstash - >弾性 - > Kibana 私はから設定を変更したい： filebeat - > logstash - >弾 - > Kibana に： filebeat

1熱

1答えて

spring amqpで非デバッチ処理メッセージ

BatchingRabbitTemplateを使用して、メッセージをバッチでamqpエンドポイントに送信しています。今、もう一方の受信側では、私は@RabbitListenerを使ってメッセージを受け取ることができますが、私の問題はメッセージが自動的にバッチ処理され、@RabbitHandler public void receive (List<SomeObject> so)を使用できないことで

0熱

1答えて

マイクロサービス - マイクロサービス間の非同期呼び出しAMQP/RabbitMQベストパターン

サービスA、B、Cの3つのマイクロサービスがあります。サービスAはBとCを非同期に呼び出す必要があります。私はasync ipcにRabbit MQを使用しています。試したRabbitTemplateのdirectSearchAndRecieveをdirect-replyToオプションで使用すると、現在の処理スレッドは非同期呼び出しを完了するまで待ちます。 convertAndSendを使用

0熱

1答えて

Ribbit MQ ClusterのMaster Queue Nodeへの接続をSpring AMQPが常に保証する方法

3ノードRabbit MQのセットアップがあります。実行時にすべてのキューが作成されています。私はその後、キューを反映していない特定のキューは考えNode1で作成され、私はそれを確実にする方法として、その後春AMQPクライアントを使用する場合は、ノード2とノード3今に存在しない場合ノード1で提供されていますQUEUE1は、それは常に他の方法は、任意のノード上で作成された各キューはに複製されます

1熱

1答えて

RabbitListenerバインディングキューと複数のエクスチェンジ

RabbitListenerアノテーションを使用してキューを複数のエクスチェンジにバインドできるようになっていますが、これまでに失敗しています。私が今持っていることは次のとおりです。 @RabbitListener(bindings = @QueueBinding(value = @Queue( value = "${subscriber.queueInbound}", du

1熱

2答えて

純粋なRabbitMQに対してNServiceBus + RabbitMQを使用する利点は何ですか？

純粋なRabbitMQに対してNServiceBus + RabbitMQを使用する利点は何ですか？私はそれが追加のインフラストラクチャを提供すると思います。しかし、他に何がありますか？

0熱

2答えて

セロリタスクで非同期rabbitmqクライアントpikaまたはピラビットを実装するにはどうすればよいですか？

私はceleryとrabbitmqを使って、約1,000万のタスクを処理しています。タスクの出力は、リモートrabbitmqに格納されているjsonです。私はPikaを使って、リモートのrabbitmqの異なるキューにメッセージを公開していました。現在、私はpikaが非同期ではないので、このエラーpika.exceptions.ConnectionClosed: Connectionを取得していま