rabbitmq

    0

    1答えて

    の下で、私は別のキューにいくつかのメッセージを公開している、シンプルなシンサーバーを実行している、コードは次のようになります。今、私は、サーバーを実行して、http://0.0.0.0:4001/command=r&number=123123123ような何かを行うとき require "rubygems" require "thin" require "amqp" require 'msgp

    2

    1答えて

    私はHerokuにNode.js UDPサーバを書いて、それを処理するためにRailsインスタンス(dyno)にデータをキューに入れる予定ですか? Delayed JobとRabbitMQの長所と短所は何ですか?おかげで、Chirag

    9

    1答えて

    メッセージを受信するサブスクライバがないことに関連するのではなく、「耐久性」と「永続モード」がリブートに関連しているように見えます。 私は、RabbitMQが購読者がいないときにメッセージをキューに保持したいと考えています。加入者がオンラインになると、メッセージはその加入者によって受信されるべきである。これはRabbitMQで可能ですか? コードサンプル: サーバー: namespace Rabb

    7

    2答えて

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

    0

    1答えて

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

    2

    2答えて

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

    8

    3答えて

    からセロリを通じてタスクを実行 :これは、次を返して 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を使用してPeriodic Tasksを実行したいと考えています。私は、セロリを使ってこれを達成する方法についてインターネット(およびドキュメント)のいくつかの異なるフォーマットとスキーマを見てきました。ジャンゴ・セロリの定期的な仕事ですか?特に、PeriodicTaskクラスを拡張して登

    9

    2答えて

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