問題タブ [rabbitmq]

基本的に、メッセージをキューに入れることができるキューイング技術が必要です。これらのメッセージは、後で SMS テキストとして送信されます。API について調べてみると、RabbitMQ は非常に適しているようです。

私の現在のアーキテクチャ計画:

1. クライアントは、RabbitMQ でメッセージをキューに入れます。
2. 別のデーモンが RabbitMQ からメッセージを読み取り、それらをサードパーティの SMS ゲートウェイに送信します。デーモンは、複数のリスナー スレッドを生成できる必要があります。
3. Ubuntu Hardy を使用して、slicehost.com ですべてをホストする予定です。

この設計に何か問題があると思いますか? 私は Erlang について大雑把な知識しか持っていないので、本番環境でそれを実行する方法についてはまったく考えていません。Erlang や RabbitMQ の経験があれば、戦争の話を聞きたいです。

問題：非同期ジョブをMQサーバーキューでリッスンしているいくつかのphp-workerプロセスを実装したいと思います。現在の問題は、サーバー上でデーモンとしてこのプロセスを実行するだけでは、インスタンス（ロード、ステータス、ロックアップ）を実際に制御することはできません...おそらくps-auxをダンプする場合を除きます。そのため、システム（プロセス）レベルまたは上位層（ある種のJavaスタイルのアプリサーバー）のいずれかでインスタンスを監視および制御できる、ある種のランタイム環境を探しています。

ポインタはありますか？

システムをmorbidの使用からrabbitmqに移行しようとしていますが、デフォルトで提供されているのと同じブロードキャスト動作のmorbidを取得できないようです。ブロードキャストとは、メッセージがキューに追加されると、すべてのコンシューマーがそれを受信することを意味します。うさぎの場合、メッセージが追加されると、すべてのリスナーにラウンドロビンスタイルで配布されます。

同じ種類のメッセージ配信を実現する方法を教えてもらえますか？

以下で使用されているストンプライブラリはhttp://code.google.com/p/stomppy/です。

stompで対応できない場合でも、amqplibの例でさえ本当に役立ちます。

現在の私のコードは次のようになっています

消費者

そして送信者はこのように見えます

クライアント アプリケーションから RabbitMQ キュー内のメッセージ数を確認する方法があるかどうかは誰にもわかりませんか?

.NET クライアント ライブラリを使用しています。

非同期タスクを実行するRoRアプリをデプロイしようとしています。そのためにworklingを使用し、メッセージキューはRabbitMQです。この組み合わせはStarlingで問題なく機能しましたが、MQforRabbitを変更することにしました。どこかで、environment.rbに次のコードを含める必要があることを読みました。

しかし、Apacheは次のメッセージで完全に失敗します：サーバーで内部エラーまたは設定ミスが発生し、リクエストを完了できませんでした

どちらを使うべきか少し混乱しています。どちらでもうまくいくと思いますが、どちらがもう一方よりも優れているのでしょうか、それとも適切でしょうか？

http://github.com/ask/carrot/tree/master

http://github.com/ask/celery/tree/master

私は Django プロジェクトのメッセージ キューに Carrot を使用しており、チュートリアルに従っていますが、正常に動作します。しかし、この例はコンソールで実行されます。これを Django でどのように適用するのか疑問に思っています。models.py のモデルの 1 つから呼び出しているパブリッシャー クラスなので、問題ありません。しかし、消費者クラスをどこに置くべきかわかりません。

.wait() でそこに座っているだけなので、いつでも実行してメッセージをリッスンできるようにインスタンス化する必要があるポイントや場所がわかりません!

ありがとう！

優先メッセージ（AMQPなど）を一貫してサポートしないメッセージ指向ミドルウェアの場合、キューにFIFOセマンティクスしかない場合に、優先消費を実装するための最良の方法は何ですか？一般的な使用例は、メッセージの大量のバックログがキューに存在する場合に、消費者が優先度の低いメッセージの前に優先度の高いメッセージを受信するシステムです。

RabbitMQに関して私が最近見たプレゼンテーションでは、メッセージの重複排除に「べき等バリア」と呼ばれるものを使用することに言及していました。これは単なるメッセージコンファイターの空想的な名前ですか、それとももっと具体的な名前ですか。もしそうなら、それは正確には何ですか？グーグル検索では、ほとんどがRabbitMQに関連する結果が得られましたが、それが何であるかについてはほとんど説明されていませんでした。