message-queue

0熱

1答えて

私は、メッセージがコンシューマ（「ワーカー」）によって順番に処理されるようにするキューイングメカニズムを使用する必要があります。私は過去にRabbitMQを使用しており、メッセージを受信した順序を保証しています。しかし、もしその順序が正しいのではないでしょうか？私はメッセージ[4,5,3,2,1]を提出したとしましょう、RabbitMQの消費者はその順序でメッセージを処理します。メッセージが互

3熱

1答えて

POSIXメッセージキュー - mq_sendスレッドウェイクオーダー

メッセージキューが複数のスレッドを1つのメッセージキューでブロックされた複数のスレッドをブロックする方法を説明できますか？私の状況は、完全なメッセージでブロックする複数のライターを持っていますキュー、それぞれ優先度がスレッドと等しいメッセージを投稿しています。私は彼らが目覚めて優先順に投稿したいと思っていますが、私のアプリケーションはFIFO順で目覚めているかのように動作しています（つまり

0熱

1答えて

RabbitMQ遅い受信速度

私は、データプロデューサからデータを受け取り、処理する必要があるアプリケーションを作成する必要があります。私はメッセージブローカーとしてRabbitMQを選びました。私のテストでは、最良の結果ではないことが分かりました。送信 - 100 msg; プロデュース - 100 msg/s; 消費 - 6 msg/s; これを解決するには、listenerContainer.setAcknowledg

0熱

1答えて

メッセージキュー内のアイテムのステータスを報告する方法

メッセージキュー（RabbitMQ）を使用してアプリケーションに非同期ファイル生成モジュールを実装する予定です。ユーザーがWebアプリケーションUIを介してデータを入力すると、そのデータはMQに入れられます。データには、要求しているユーザーのIDも含まれています。キューをポーリングするワーカーアプリケーションがあります。作業者は、キューから項目を削除し、レコードを処理し、結果としてファイルを作成し

0熱

1答えて

Pythonのメッセージキュー2.2

メッセージキューを行う方法python 2.2？ Python 2.2である必要があります。私はレガシーシステムが必要です。私はすでに多く見てきましたが、何も見つかりませんでした。私はすでにそれができないと考えています。私は疑問に思っていませんが、Python 2.2はかなり古くなっています。

5熱

1答えて

PHPでMSMQメッセージの回復可能な属性を設定する

MSMQに送信するRecoverable attributeフォームメッセージを設定したいと思います。私はいくつかのリソースをPHPでこれを行う方法を探してきましたが、何も見つかりませんでした。私はこれを試しました if(!$msgOut = new COM("MSMQ.MSMQMessage")){ return false; } $msgOut->Body

1熱

1答えて

メッセージをどのHornnetQサーバーから別のサーバーにコピーするのですか？

私はホーネットキューメッセージのバックアップをサーバーの1つから約6000万メッセージが含まれていると私は別のサーバーのHornetQにバックアップをコピーしようとしていますが、私はJconsoleでキューをチェックするときにバックアップを別のサーバーにコピーした後、そのキュー。私はそれをするか、私は何かが欠けています特別な方法はありSERVER1からサーバに2 をページングとバインディングのフ

0熱

1答えて

のRabbitMQ：私はRabbitMQの</p> <p>とRPCについてこの<a href="https://www.rabbitmq.com/tutorials/tutorial-six-go.html" rel="nofollow noreferrer">tutorial</a>を読んでいますd.Ack（）近いチャネル

は、次の行は、キューチャネルを閉じるようだ： d.Ack() 誰もがd.Ack()がために、実際に何であるかを説明してもらえますか？キューチャネルを閉鎖するのはなぜですか？

2熱

2答えて

200+カフカのトピックでスケーリングする

膨大な数のトピックを消費するアプリケーションを動的にスケールアウトする方法を理解しようとしています（残念ながら、それらの数を減らすことはできません - 各トピックは特定の種類のデータ用です）。私は自分のアプリケーションクラスタがすべて200件の以上のトピックから負荷を共有したいです。たとえば、新しいアプリケーションノードがクラスタに追加されると、古いノードからのサブスクリプションを「盗む」必要

0熱

1答えて

ブル・キュー内の特定のタスクを中止する方法は？

このパッケージによれば、「待ち行列」内の特定のタスクを中止することは可能ですか？私のユースケースは次の通りです：私は、mongodbコレクション "users"と、両方のユーザーの名前とアバターを保存するコレクション "friendship"を持っています。だから私は特定のユーザーの友人リストを取得するために1つのクエリが必要です。ユーザーが自分のアバターを変更すると、このユーザーのすべてのド