rabbitmq

5熱

1答えて

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(

1熱

1答えて

RabbitMQクラスタリングとは何ですか？

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

3熱

1答えて

トラフィックの多いチャットコンポーネントにRabbitmqまたはHornetqを使用する

私は、アプリケーションのトラフィックが多いチャットコンポーネントを構築する作業をしています。メッセージキューの上に構築することに決めました。これをHornetqとRabbitmq 。誰がより良い選択になると思われる意見がありますか？（Java Nioを使用してWebsocketとCometタスクの待ち行列とユーザーの間にサイトを配置するサーバーもコーディングする予定です）これらのテクノロジを

1熱

2答えて

セロリー、1つのキューと複数のキューが並行して並んでいます

タスクを管理するためにセロリを使用しようとしています。私は多くのマイナーな仕事（電子メール、クロスサーバ投稿など）を持っています。ファイルアップロードのような時間のかかるタスク。アップロードが常に1つずつ行われることを指定する方法はありますか。時間内に実行されるタスクは1つだけですが、他の作業者は他のキューで作業します。

9熱

1答えて

RabbitMQと承認

私のプロジェクトの1つに、RabbitMQを使用するための認証が必要です。認証されたユーザだけがrabbitmqサーバに接続してキューに登録することができます。たとえば、ユーザが最初にサーバに接続し、認証データ（ログイン、パスワードなど）を送信すると、サーバはそれをチェックし、彼はキューに登録することができます。それ以外の場合、サーバーはユーザーを切断します。これには解決策がありますか？あまりに

6熱

2答えて

そのタスクをインポートできないときにCeleryタスクを実行する

私は2つのサーバーを持っています：1つはdjangoアプリケーションを実行し、もう1つはrabbitmqキューとCeleryワーカーの両方を実行します。次のようにキュー/労働者を実行しているサーバー上の私のtasks.pyは、タスクが含まれています @task(queue="reports") def test_task(): time.sleep(120) 私の目標は、Djang

4熱

1答えて

RabbitMQ + PHPデプロイメント戦略

私はRabbitMQを使用するPHPプロジェクト（Symfony2）を持っています。私は単純なメッセージキューとしていくつかのジョブ（メール、APIから重要なデータを送信する）を遅延させるために使用します。コンシューマーはウェブサーバー上で動作し、そのコードはウェブサーバーの一部であり、ウェブと同じに展開されます。質問は次のとおりです。デーモンとしてコンシューマを起動し、常に実行する方法を教え

7熱

3答えて

Ubuntu 10.04サーバのRabbitMQ

Ubuntu 10.04でVPSでRabbitMQを実行しようとしています。いつものようにすべてをやっ：はRabbitMQのDEBレポにapt-getをapt-getのUbuntuの11.10で私のローカルマシン上のRabbitMQサーバをインストールしてがインストールされた更新プログラムで更新を追加し、同じ10.04を持つ別のVPSはうまく動作します。これは何私が間違ってやっているとWT

1熱

2答えて

rabockmqを模倣しようとしたときにScala Testで/ returnRockがnullを返す場合ConnectionFactory

私はRocketMQ ConnectionFactoryオブジェクトをモックしてスカラーテストとmockitoを使って擬似接続を返そうとしています。以下は私が使用しているテストの例です： class RabbitMQMockTest extends FunSuite with MockitoSugar { test("RabbitMQ ConnectionFactory is corre