rabbitmq

8熱

2答えて

私の消費者は基本的に生産者です。最初のデータセットが取得され、キューに送信されます。消費者は、アイテムを取り、それを処理し、3つの可能性があります、その時点から：データは良好であり、データが不良であるストレージに「良い」キューを入れてデータを破棄します良いではありません（まだ）または悪い（まだ）ので、データはより小さな部分に分割され、さらに処理するためにキューに戻されます。私の問題は、キュ

0熱

1答えて

rabbitmqにさまざまなデータを送信するにはどうすればよいですか？

私の仕事では、キューには3つの異なるデータが必要です。 int、double、およびint []リストチュートリアルから、私は単一の文字列が送信されるのを見るだけです。キューに複数のタイプのデータを文字列に変換せずに送信できますか？編集：私はすべてを文字列に変換して、一度に1つずつ送信できると考えましたが、複数のデータが必要なキューはどうですか？

2熱

1答えて

カスタマーサービスソフトウェアのチャットサーバーアーキテクチャ

訪問者がオペレータとチャットできるサイトでチャットコンタクトを提供する必要があります。チャットは異なる事業整理キューに運ばれ：キュー・ルーティングとサーバ側のチャットサーバ、DB、オペレーターオンラインステータスを：などの販売、サポート、製品情報、は、あなたは私にカバーするアーキテクチャを提案することができますなどオペレータWebアプリケーション訪問者演算子リアルタイムモニタリングのウェ

1熱

1答えて

GrailsのRabbitMQのImmediateAcknowledgeAmqpException

私はRabbitMQのプラグインを使用しようとしていますし、私はorg.springframework.amqp.ImmediateAcknowledgeAmqpException を取得していないものは何でも：ACK 回収さメッセージ力（ACKモードがそれを必要とする場合）：... AMQP テンプレートを使用して純粋なSpringアプリケーションを使用してAMQPメッセージを送信し、Grai

5熱

1答えて

WCF経由で高可用性RabbitMQサーバーペアを操作する

wcf経由でrabbitmqクラスターを使用する最良の解決策は何かを突き止めようとしています。現在の設定： 2 IIS Webサーバ（メッセージなどの行為が発生し、クライアントWCF AMQPを経由してキューにメッセージを投稿します）。 rabbitmqブローカー（ミラーリングされたキュー、rabbit1、rabbit2でクラスタ化された）を持つ2台のサーバー受信メッセージをリッスンするamq

2熱

1答えて

メッセージ発行のための配布可能クライアントに関するアドバイス

WindowsとLinuxマシンの両方に配布してインストールする必要のあるソフトウェアを実装するための最良の方法についてアドバイスが必要です。私はマシン上でローカルに動作する小さなJavaメッセージングアプリケーションを作成し、メッセージをストリーミングするために特定のポートをリッスンします。このアプリケーションは、メッセージをJMSキューにプッシュします。私のWebアプリケーションは、JMSキ

1熱

1答えて

セロリの結果にamqpバックエンドとデータベースバックエンドを使用する違いは何ですか？

どちらの場合でも実際の結果がどこに格納されているのか分かりません。私は、テストアプリケーションでデータベースとしてdjango-celeryとsqliteを使用しています。私はRabbitMQをブローカーに使用しています。私はCELERY_RESULT_BACKEND = "amqp"を設定しようとしたともCELERY_RESULT_DBURI="mysqlitedb" と「データベース」へし

0熱

1答えて

マルチスレッドジョブを実行するワーカーでRabbitMQを使用する - 並列宝物

私は、ジョブリストを取得し、ウサギで待ち行列に入れてキューから作業者ポップジョブを実行するシステムをRuby（rabbitmq、parallel gem）それら。準備ができたら、キューから1つのジョブをポップするのは簡単ですが、各ワーカーに5つのスレッドを実行させて、5つのスレッドがすべて処理しているときにワーカーがポップしないようにしたいキューからジョブが削除されます。スレッドが解放されると、

4熱

1答えて

RabbitMQとのSpring統合の使用

私は、私たちのアプリケーションの1つのためのメッセージングインターフェイスを開発中です。アプリケーションは、「ジョブ」を受け入れ、何らかの処理を行い、結果を（実際にはファイルの形式で）返すように設計されたサービスです。メッセージインフラストラクチャとしてRabbitMQを使用し、プロトコル固有の詳細を処理するためにSpring AMQPを使用します。私のコードからSpring AMQPへの結合

4熱

2答えて

同時に実行してはいけないタスクをシリアル化するためにセマフォシステムを分散させるための分散セマンティックシステム

MySQLを使わずにデータストア内のデータに影響を及ぼすタスクをシリアル化する方法を探しています例： group1でアカウンティングを行っているワーカーは、グループ1のアカウンティングを実行し、別のワーカーがグループ1のアカウンティングを行っている場合はキュー内で待機する必要があります。これは、セマフォテーブルを設定し、トランザクションを開始し、グループ1の行を更新し、自分のタスクを実行し、コ