message-queue

6熱

2答えて

Herokuで動作するNode JSサーバをメッセージキューアーキテクチャに移動する必要があります。現在、サーバーはHTTP要求を受け取り、何らかの処理を行い、応答します。問題は、特にリクエストがたくさんあるときは、処理に時間がかかることです。この長い処理時間は、サーバーのタイムアウト、過負荷、クラッシュを引き起こします。私の読書は、処理を行うバックグラウンドワーカーの必要性を私に教えてくれます。

6熱

1答えて

メッセージキューアーキテクチャ（クライアントからWebサーバへのクライアントとバックへ）

私は、Heroku上で動作するノードJSで書かれたWebサーバを持っています。サーバーにはWebサーバープロセスとワーカープロセスがあります。 Webサーバーは、RabbitMQキューを介して正常にワーカーにメッセージを送信します。ワーカーは処理されたデータをWebサーバーに正常に返します。ランダムに生成されたUuidを使用してメッセージを追跡し、適切なメッセージが正しい元のメッセージとペア設定さ

8熱

2答えて

メッセージングでの相関IDの使用例

誰も私がどのように相関IDを使用することができるかの例を教えてもらえますか？リクエスト/レスポンスタイプのメッセージで使用されていますが、どこで使用するのか分かりません。 1つの例（私は間違っているかもしれません）私は、5人の加入者を持つことができる公開購読シナリオであり、同じ相関IDを持つ5つの返信を受け取った場合、すべての加入者がそれを受け取ったと言うことができます。これが正しい使用方法であ

2熱

1答えて

未配信のJMSメッセージの元の宛先を検索する方法。

JMSメッセージの元のアドレスキューを取得する方法は、それが配信されなかったかどうかです。私はJBOSS HornetQを使用していますが、JMSMessageIDとTimestampと現在のキュー（デッドレターキュー）がメッセージに含まれていることがわかりましたが、どのキューからメッセージが発信されたのかを確認したいと思います。

10熱

2答えて

待機/通知はどのようにJVMレベルで機能しますか？

待機と通知はスレッド間でやりとりされるメッセージのように見えます。これが真実なら、これらのメッセージをバッファリングするためのキューが必要です。その場合、キューにメッセージを追加したり削除したりするためのアトミック操作が必要です。また、これらのメッセージをリッスンするJavaスレッドごとにヘルパースレッドが必要ですか？あなたの考えを聞くことは素晴らしいことでしょう。

73熱

2答えて

RabbitMQのメッセージサイズとタイプ

RabbitMQキューにはどのようなメッセージを格納できますか？文字列のみ？または、格納するタイプをint、binary、stringなどから選択できますか？ 1つのメッセージの最大サイズはどれくらいですか？作成できるキューまたはエクスチェンジの数はいくつですか？それともサーバーの能力に依存しているのでしょうか？

9熱

1答えて

Kafka：複数のストリームコンシューマを作成することを念頭に入れよう

私はKafka 0.8 beta 1で起動しています。私は本当に簡単なサンプルを作成して実行していますが、問題は、つまり、runSingleWorker（）メソッドは動作します。 run（）メソッドが動作しない： import kafka.consumer.ConsumerIterator; import kafka.consumer.KafkaStream; import kafka.con

11熱

2答えて

MassTransit with RabbitMQ：メッセージがエラーキューに移動したとき

私はRabbitMQバージョン3.0.2を使用しています&エラーキューには1000個近くのメッセージがあります。私は知りたいどの時点でメッセージがエラーキューに移動しますか？特定のメッセージがエラーキューに移動している理由を知る方法はありますか？メッセージをエラーキューから通常キューに移動する方法はありますか？あなたは、キュー内のメッセージで覗いたら... そうでもないというメッセージを5

6熱

3答えて

すべてのプロパティを指定せずにキューを取得する

既存のキューのコンシューマを書き込もうとしています。 RabbbitMQは別のインスタンスで実行されており、「org-queue」という名前のキューはすでに作成され、Exchangeにバインドされています。 org-queueは耐久性のあるキューで、いくつかの追加プロパティもあります。このキューからメッセージを受信する必要があります。は、私はそれが私に別の耐久性の性質を示すエラーがスローされま

7熱

1答えて

MSMQからのメッセージの受信をどのように高速化できますか？

私のアプリケーションのボトルネックは、MassTransitを使用してMSMQでメッセージを送受信しています。送信と受信の両方が同じアプリケーション内で起こっていますが、メモリ内のキューを使用するにはメッセージが多すぎます。ここでは私の単純なキューの設定です：私の実験のために messageBus = ServiceBusFactory.New(sbc => {