message-queue

    6

    3答えて

    私はメッセージングを初めて使い、さまざまなサービス間でメッセージングを提供するために、システムアーキテクチャの一部としてRabbitMQを調査中です。私はbasic RabbitMQ exampleを持っており、それはバスを介して基本的なテキストメッセージを送信することができます。 EasyNetQのように見えるのは、RabbitMQを使うのが複雑になることがありますが、私はそれを動作させるのに少

    4

    2答えて

    私はLinux上でPosixメッセージキューを使用しています。基本的には、mq_timedreceiveへの呼び出しによって同じキューからメッセージを受け取る複数のスレッドがあります。 複数のスレッドが同時に実行されており、キューが空でない場合、メッセージが複数回受け取られないことが保証されますか?つまり、メッセージは複数のスレッドに配信されません。 確かに、私は受信をmutexと同期させることが

    1

    2答えて

    ウェブ開発では、レールとノードを混在させたいと思っています。両方の世界(高速ウェブ開発のためのレールと並行処理のためのレール)を最大限に活用したいからです。私は、一部の人々は、イベントコントローラを備えたフルルビースタックをレールコントローラに統合して、イベントループモデルでファイバを使用することですべての要求を非ブロックにすることを選択していることを知っています。私はそれがどのように大きな画像で

    1

    1答えて

    subjを達成するための文書化されたAPIはないようですが、文書化されていないAPIがありますか、これを行うにはいくつかのトリックがありますか?

    36

    3答えて

    RabbitMQを使用するアプリケーションがあり、階層間でメッセージを渡すためにいくつかの異なるキューがあります。 最初は、メッセージタイプごとに1つずつ、複数の直接交換を使用する予定でしたが、異なるルーティングキーバインディングを使用するキューとの単一のトピック交換が同じことを達成するように見えます。 1つのエクスチェンジを保有するのはちょっと簡単かもしれませんが、他の方法より片方向の利点がある

    1

    1答えて

    処理するジョブを格納するmysqlテーブルがあります。主に生データのテキストフィールドは処理するのにそれぞれ約1分かかります。 私は2台のサーバーがそのテーブルからデータを取り出して削除しています。 私は現在amazon SQSを使用している2台のサーバ間のジョブ割り当てを管理します。私はSQSで処理が必要なすべての行IDSを保存し、ワーカー・サーバーは新しい行を処理するためにSQSをポーリングし

    1

    2答えて

    私は、フォルダーをリッスンし、新しいファイルをすべてIBM WebSphere MQサーバーにアップロードするサードパーティ製品を探しています。 MQクライアントとして動作する必要があります。 この種の製品に詳しい人はいますか? MQ FTEを提案しないでください。 ありがとうございます!

    1

    1答えて

    私はネイティブC++とWinAPIを使ってプログラムを作っています。 このプログラムには、やや永続的にしたいアプリケーションウィンドウがあります。赤いXボタンでウィンドウを閉じるのは当然のようですが、実際にはプログラムを終了したくないときに押してしまいます(これはTeamspeakで私に起こります)。だから、私は偶発的な終了を避けるために、赤いXボタンを最小化ボタンに再利用しようとしています。 し

    0

    3答えて

    WASでは、jmsキューXを作成しました。別のキューYも作成しました。MQでは、YがXのバックアウトキューであると指定しています。 最大再試行回数は3回であり、バックアウトしきい値は2です。つまり、メッセージがXで消費されない場合は2回試行した後、キューマネージャはYにメッセージを書き込みます。この場合、最大再試行回数(3)は決してそれは決して3度目の試みではないからだ。そして、Xのリスナーは決し

    5

    3答えて

    このエラーは他の投稿では見られましたが、このような状況では発生しませんでした。 私は、MessageQueueで同じことをする2つのクラスを持っています。そのため、私はキューの作成と処分をヘルパークラスに抽象化しました。私はこのエラーが発生している、と私はキューが複数回配置することができないのか分かりません。 オブジェクトは「メッセージキュー「MsmqHelper.DisposeQueue(メッセ