message-queue

0熱

1答えて

私は、rabbitmqの既存のキューに加入しているワーカーがいます。冗長性のために、同じキューに接続する別のワーカーを追加することにしました。第1ワーカーがキューとの排他接続を取得して、第2ワーカーがメッセージをデキューできず、スタンバイワーカーとして機能するように設定できますか？

1熱

3答えて

メッセージキューはどのように動作するはずですか？

メッセージキューを理解しようとしています。私が見た例では、msgのstrunctは、最初のもの（型）以外の属性が1つだけあり、それはlongでなければなりません。だから、struct msg{long mtype; char text[100]};のようなものになります。新しいint属性を追加しようとしましたが、xという文字と数字の両方を受け取ったかどうかを確認しました。メッセージキューはどの

1熱

1答えて

このシナリオでAmazon SQSはどのように動作しますか？

コンシューマがキュー（FIFOまたは標準キュー）でリッスンしている場合、プロデューサはキューにメッセージを生成します。 Amazon SQSキューは、消費者から確認応答を受け取ると自動的にキューからメッセージを削除しますか？キューがメッセージを削除する代わりに保持し、メッセージが再び配信されないようにする方法/構成がありますか？プロデューサはキューにメッセージを生成します。ネットワークの問題のた

0熱

1答えて

Spring DefaultMessageListenerContainerコンシューマ

WebLogic JMSからのメッセージを待機するようにDefaultMessageListenerContainerをコンフィグレーションしました。 WebLogicインスタンスには2つのインスタンスがあります。私は、消費者が常に1つのインスタンスだけに行き、インスタンス間で共有していないことに気付きました。 JMSインスタンスでDefaultMessageListenerContainer設定

1熱

2答えて

メッセージがサブスクライバを持たないキューに発行された場合はどうなりますか？

これは私にインタビューで尋ねられました。メッセージが午前10時にキューに登録されていないとどうなりますか？適切なフィルタを持つサブスクライバは、同じキューに10.02 AMでサブスクライブします。メッセージがブローカに到達した後にサブスクライバがサブスクライブするとメッセージが配信されますか（サブスクライバが見つかるまでメモリに格納されます）デフォルトの動作は何ですか？また、JMS、STOMP、

-2熱

1答えて

RabbitMQメッセージ暗号化

RabbitMQにメッセージ/データ暗号化はありますか？（AmazonがServer SideまたはClient側の暗号化と暗号化キーなどでやっているのと同じように）？ RabbitMQの暗号化は設定可能で、AWSクラスタで使用するのは安全ですか？

-2熱

1答えて

ユースケースはWebサーバーの分散キューですか？

私はちょうど分散システムについて読んだ初心者です。私は、各マシンのキューとは対照的に、分散キューのユースケースをいくつか考えています。たとえば、RabbitMQをさまざまなWebサーバーで使用する方法。ロードバランシングなどでどのように使用されていますか？

0熱

1答えて

CreateRequestClientとCreatePublishRequestClientの違い

RabbitMQでMassTransitを使用したリクエストレスポンスパターンで、リクエストクライアントを作成しようとしています。私は2つの可能性を見たインターネット上でいくつかの研究行っているときしかし： CreateRequestClientとCreatePublishRequestClient を誰かがそれらの2とするときにそれらを使用する方法との違い何を知っていますか？は、方法については

3熱

0答えて

再キューした後の配信の順序を保つ

私はRabbit MQを使ってメッセージングのためのアプリケーションを開発しています。 model.BasicConsume(queueName,false, consumer); とメッセージを処理した後、ACKを実行します：私は、明示的なACKを使用 consumer.Received += (ch, ea) => { try {

0熱

1答えて

JMSリスナーに「オブジェクトなし」メッセージを通知する方法

1つのマスターサーバーによって管理される1つのリポジトリに、いくつかの 'カー'リポジトリ（異なるスレーブサーバーによって管理される）を同期する必要があります。私はActiveMQを使用しています。マスターが聞く待ち行列（master.car.queue）を定義しました。すべてのスレーブは、そのカー・リポジトリーを（5分ごとに）ポストします。私は、1つのスレーブがそのレポジトリに1台の車を持