rabbitmq

2熱

1答えて

RabbitMQがキューの状態が管理ツールでアクティブであるかどうかを確認する方法

Web管理ツールにログインすると、「アクティブな接続」のキューにキューの詳細セクションに「アクティブ」のステータスが表示されます。私は永続的な接続を持っていないWeb上のクライアントからWebサービスAPIを介してこのキューを単にポーリングしているので、アクティブな接続の概念は私のものであることに注意してください。主な問題は、プログラムでこのステータスを取得する方法です。私はJava（Spring

36熱

3答えて

トピック交換とRabbitMQのダイレクト交換

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

4熱

2答えて

PHPは

マイAMQPの拡張バージョンは1.0.1 & AMQPプロトコルのバージョンであるRabbitMQのエラーからメッセージを取得0-9-1 がキューからメッセージを取得します <?php try { $conn = new AMQPConnection() ; $conn->setLogin('guest') ; $conn->setPassword('guest') ; $conn->c

2熱

1答えて

RabbitMQと同期Webサービス層を分離するのは良いか悪いのでしょうか？

私の現在のプロジェクトでは、Webサービス層を実装しており、RabbitMQを使用してこの層をデカップリングしたいと考えています。これは最後に私に非常に薄いwebservice層を与えます。これの課題は、すべてのWebサービス呼び出しが同期的であることです。 Webサービス層の呼び出し側は応答を取得する必要があります。私はRabbitMQでデカップリングを行うのが良いか悪いのだろうかと思っていま

0熱

2答えて

RabbitMQを設定するAntタスク

Antを使用してローカルビルドをセットアップしており、RabbitMQを使用することに決めました。私は、私のテストスイートの一部としてそれらを壊す（停止、開始、キューを作成するなど）を設定するために私のローカルインストールを設定するために使用できるAntタスクを持っていたいと思います。このような人は誰ですか？

0熱

1答えて

rabbitmqチャンネルからjava NIOチャンネルへのメッセージの受け渡し

私はチャットコンポーネント（すべてのディスカッションが保存されている場所）をアプリケーション用にビルドしています。クライアントマシンとrabbitmqサーバ間のインターフェイスとしてロングポーリングサーバを用意する予定です。それは、書式を解析し、セルリーによって処理されるジョブ待ち行列（rabbitmq上）のメッセージをエンキューします。そして、ポスティングが許可されているかどうかをdbで確認した

5熱

1答えて

セロリとRabbitMQを使ったトピック交換

トピック交換を設定するために私の設定がどのようになっているのか混乱しています。 http://www.rabbitmq.com/tutorials/tutorial-five-python.html これは私が達成したいものです。その後、 Task1 -> send to QueueOne and QueueFirehose Task2 -> sent to QueueTwo and Queue

4熱

1答えて

Celeryの設計の助け：同時に実行するタスクを防ぐ方法

私はCelery/AMQPをかなり使い慣れており、以下の要件を満たすためにタスク/キュー/ワーカーの設計を考えています。私は、複数の種類の「ユーザー単位」のタスクを持っています。たとえば、TaskA、TaskB、TaskCなどです。これらの「ユーザごとの」タスクはそれぞれ、システム内の特定の1人のユーザのデータを読み書きします。だから、いつでも私はタスクUser1_TaskA、User1_Tas

1熱

1答えて

Spring AMQPを使用するWebアプリケーションは、1クライアントであることになりましたか？

こんにちは私は春のAMQPを使用するWebアプリケーションを作成する場合は私は思っています。その1つのwebapp 1 AMQPクライアントですか？または、AMQPがクライアントを呼び出す結果となるすべての要求がユーザによって行われたことになります。

2熱

2答えて

リスナースレッドが死んだときに、サーバーを再起動せずにサーバーへの接続が失われる方法

ポーリングによってRabbitMQキューをリッスンしようとしています。しかし、何らかの理由でネットワークに問題が発生した場合、キューへの接続が失われると、スレッドは自動的に切断され、接続がすべて閉じられます。しかし、これはバックグラウンドタスクであり、キューが本当に大きくなり、通知を送信するまではわかりません。スレッドの正常なシャットダウンを手伝ってもらえますか（私はすでにcatch節で例外を注