rabbitmq

1熱

1答えて

RubyプロジェクトではRubyプロジェクトでAMQPを使っていましたが、とにかくRabbitMQクラスタリングについて聞いたことがありますが、誰でも簡単な言葉で言えば、普通のRabbitMQサーバーとRabbitMQクラスタリング、なぜそれが必要か、それを実装する方法私は次の実装を考えていたと私はそのようなことを実装する方法を知っているのが大好きだ、スケーラブルになるようにし、非常に多くの要求

7熱

2答えて

WCFと永続的キューを持つRabbitMQ

rabbitMQバインディングで動作するwcfサービスを作成しようとしています。私は正常にサーバーとクライアントを作成し、クライアントがキューを介してサーバーにメッセージを送信させることができました。私は2つの問題について混乱しています。サービスがシャットダウンすると、キューは削除されます。キューが永続的になるようにwcfとrabbitMQを設定する方法はありますか？私のサーバーがクラッシュした

0熱

1答えて

マルチスレッドストレステストでJMeterとRabbitMQを使用するNoRouteToHostException

RabbitMQキューにメッセージを生成するAPIでJMeterテストを使用してストレステストを実行しようとしました。 ressourceは、RabbitMQへの接続を開くサービスを呼び出し、バインドされたエクスチェンジを介してキューにメッセージを発行し、接続を閉じます。 45000メッセージを生成するためにAPIを呼び出す単一スレッドでテストを実行すると、完全に機能します。 9000メッセージを

2熱

2答えて

PHPのセロリを使用していますか？

私は、ユーザーがアップロードしたイメージを拡大縮小するためのキューベースのシステムを構築しています。ユーザーは、ストレージサーバーに転送される画像をアップロードします。 Webサーバーはキューにメッセージを追加し、画像ファイルを取得してスケールし、ストレージサーバーに追加します。これはrabbitmqよりセロリを使用する予定ですが、私のWeb層はPHPを実行していますので、便宜上これを行うPH

8熱

3答えて

Djangoは私のmodels.pyでモデル

からセロリを通じてタスクを実行：これは、次を返して from celery.decorators import task from core.models import Image @task() def create_thumbnail(image_id): ImageObj = Image.objects.get(id=image_id) # other stuf

5熱

1答えて

ワーキングシャットダウンのセロリタスクに通知する

私はセロリ2.4.1をPython 2.6、rabbitmqバックエンド、およびdjangoで使用しています。私の仕事は、労働者が退職した場合に適切に清掃できるようにしたい。私が知っている限り、デストラクタを提供することはできませんので、worker_shutdownシグナルにフックを入れてみました。注：AbortableTaskはデータベースのバックエンドでのみ動作しますので、私はそれを使用で

24熱

1答えて

DjangoとCeleryの例：定期的な仕事

私はしばらくDjango/Celeryの文書と戦い続けていますし、助けが必要です。 django-celeryを使用してPeriodic Tasksを実行したいと考えています。私は、セロリを使ってこれを達成する方法についてインターネット（およびドキュメント）のいくつかの異なるフォーマットとスキーマを見てきました。ジャンゴ・セロリの定期的な仕事ですか？特に、PeriodicTaskクラスを拡張して登

9熱

2答えて

接続のないAMQP/RabbitMQチャネルはいつ鳴りますか？

私は単純なRabbitMQテストプログラムをランダムにエンキューしており、もう1つはSpring-AMQPを使っています。消費者が死亡した場合（例えば、接続やチャネルを閉鎖する機会を持たずにプロセスを終了させるなど）、承認されなかったメッセージは永久に未確認のままに見えます。チャネルが接続されていないときにチャネルが消滅し、残りのunack'dメッセージが再配信されると言う数多くの参照（たとえば

5熱

1答えて

rabbitmqはいつtcp backpressureを使用しますか？

Pika documentationによると、 "RabbitMQブローカーは、メッセージが速すぎる場合にクライアントを遅らせるためにTCP Backpressureを使用します。"バックプレッシャコールバックを登録しましたが、コールバックはまだありません。私のキューには4,000万件以上のメッセージがあり、成長しています。背圧乗数を-1に設定することで、すべてのメッセージ公開時に呼び出されるコー

0熱

1答えて

rubyのrabbitmqでオブジェクトをシリアライズして逆シリアル化する

オブジェクトをJSONにシリアル化して、rabbitmq経由でワイヤを介して送信し、それをデシリアライズしたいとします。私は、私は、次のオブジェクトを直列化していていること：他の側では lead = Lead.new lead.company = 'some company' operation = proc{ AMQP::Exchange.default.publish(