問題タブ [amqp]

RabbitMQ を介したジョブ キューのようなものがあります。ジョブをキャンセルするリクエストがあった場合、まだ処理を開始していないタスク (メッセージが確認されていない) を取り消したいと考えています。これは取り消しに対応します。ルーティングされたキューからのこれらのメッセージ。

AMQP または RabbitMQ API でこの機能を見つけられませんでした。おそらく私は十分に検索していませんか？または、回避策を使用する必要がありますか (難しいことではありませんが)。

AMQP のアドオンがまもなく提供されることがわかりました。

RabbitMQ で AMQP を使用する方法を学習しようとしています。そのアドオンはRabbitMQを扱っていないと思います。

AMQP は単なるプロトコルではありません。RabbitMQ や ActiveMQ などの AMQP ブローカーを使用していますか?

最初は QPID のドキュメントは素晴らしいと思っていましたが、今ではわかりにくいと感じています。qpid::messaging名前空間で QPID-0.6 の C++ API を使用しています ( qpid::clientを使用して低レベルの AMQP にアクセスできることがわかりましたが、今は望んでいません)。

AMQP では、型で交換を宣言し、メッセージを送信する前にキューとバインディングを宣言します。QPID を使用すると、送信先の送信者に 1 つのアドレスを指定できます。同じことを行うアドレスの例を含むドキュメントはありますか? （さまざまな交換、キューを作成し、バインディングを作成します）。

特に、node、link、x-declare、および x-binding フィールドを含む Address 構文をオンラインで見つけました。しかし、0.6 のコードを掘り下げても、これは見つかりませんでした。代わりに、より単純な構文 (node-properties および x-properties という名前のフィールドを使用) が見られます。また、そのドキュメントはあまり単純ではなく、例もありません。

examples/messaging/client.cpp で、これは私が見つけたほとんどのものです: #response-q; {create:always, type:queue, node-properties:{ x-properties:{auto-delete:true}}}

• この単純なアドレス構文を使用して、さまざまなタイプの交換、キュー、バインディングを設定できますか?

• それとも、0.6 以降のものに移行するのが望ましいでしょうか? （それが十分に安定していて、厄介な構文が少ない場合）

• または、私のアプローチが間違っているので、高レベル API を使用して交換用のレシーバー キューを事前に作成してバインドする必要はありませんか?

ありがとうございました。

セロリで使用するさまざまな AMQP 実装のメリットについて、ご意見をお聞かせください。特に、メッセージの優先度とジョブ キューのサイズに注目しています。あなたの考えは何ですか？

分散タスク処理にセロリを使用しています。プロジェクトの動作を示すためだけに、自分の作業をWebホストにデプロイしたかったのです。では、どうすればdjceleryにデータベース（sqlalchemy）をバックエンドとしてrabbitmqや他のamqpサーバーの代わりにdjangoで使用させることができますか？

メッセージ指向のミドルウェアとは、Advanced Message Queuing Protocolなどのテクノロジーを指しています。

明らかに、AMQP は MPI とは異なる獣ですが、マスター/スレーブ方式で動作する分散メモリ計算は、AMQP を使用して自明に実装できると思います。AMQP は、スレーブのキューを管理する代わりに、ピースを完成させるときにスレーブへの公平な作業分配を処理できます。マスターで明示的に動作します。

AMQP の追加の利点 (何千ものマシンが一緒に動作している場合) は、単一のマシンが停止してもMPI_Bcasts での計算の進行が停止しないMPI_Bcastことです。計算全体の進行を妨げます。

AMQP が分散計算のタスク調整に使用されている例はありますか?

更新: Gearmanは、フォールト トレラントな分散計算に対する非常に優れたアプローチを提供します。

私はapacheQpidがどのように機能するかについてより多くの情報を学ぼうとしています、そして私は公式のsvnからの例に従うことによってそうします：

http://svn.apache.org/repos/asf

私が見ていた：

http://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java

この構成/プロパティファイルを使用するもの：

http://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/hello.properties

誰かが私に構成からのこの行が表すものを分解できますか？

私。私はguest：guestがqpidに接続するときに使用するクレデンシャルになると思います

ii。ローカルホストと5672はhostname：portである必要があると思います

私の質問は何test?を表すのですか？それはキューの名前ですか、それとも何ですか？このamqpURLでキュー名を直接指定することは可能ですか？

私は pylons ベースの webapp を持っており、タスクを取るためにセロリ + rabbitmq を使用したいと思っています。celery-pylons プロジェクトを見てみましたが、うまく使えませんでした。

セロリに関する私の主な問題は、次のとおりです。セロリconfig.pyファイルをどこに置くか、またはセロリオプションを指定する他の方法があります。BROKER_HOST など、pylons アプリ内から (django-celery を使用する場合、django settings.py ファイルにオプションを入れることができます)。

基本的に、私は2つのオプションを調査しました.セロリをスタンドアロンプ​​ロジェクトとして使用することと、セロリパイロンを使用することですが、どちらもあまり成功していません.. :(

よろしくお願いします。

私の質問は実際には問題ではなく、意見を求めるものです。おそらく、これは投稿するのに適切な場所ではありません。それにもかかわらず、ここのコミュニティは非常に情報が豊富であり、試してみても害はありません...

私は、高度にスケーラブルで、とりわけ高度にモジュール化されたバックエンドアーキテクチャを作成する方法を考えていました。たとえば、大規模なサイトへの将来性のある進化の可能性を秘めた大規模なサイトのバックエンドエコシステム全体。

これには、関心の分離が非常に高度になり、（たとえば）基盤となるDBを置き換えることができるだけでなく（つまり、OracleからMySQLに）、実際のタイプのデータベースを置き換えることができます（SQLからKV、または逆に）。

各サブシステムがバックエンドエコシステム内で独自のAPIを公開する状況を想定しています。このようにして、APIは一定のままでありながら、実装は時間の経過とともに（根本的にさえ）変更される可能性があります。

システムは、特定の言語に関連付けられていないという点で異種である必要があります。異なる言語を使用するモジュールまたはサブシステム全体に対応できる必要があります。

それから、私が想像していたのは、単にWeb自体のアーキテクチャーであることに気づきました。

だからここに私の議論のポイントがあります:(主に）テキストベースのプロトコルを使用するオーバーヘッドとは別に、複雑なバックエンドアーキテクチャを私が説明する方法で実装すべきではないという最優先の理由がありますか、または私がいくつかの強力な論理的根拠がありますTwisted、AMQP、Thriftなどの通信プロトコルを使用するためにmがありませんか？

更新：@meagarからのコメントに続いて、おそらく質問を再定式化する必要があります：明らかなパフォーマンスヒットを補うのに十分な、非常にシンプルで柔軟性があり、よく理解されているアーキテクチャ（つまり、一連のRESTful APIとして公開されているすべての機能）を使用することの明らかな利点ですこのアーキテクチャをバックエンドコンテキストで使用するときに発生しますか？

Windows サーバーで最新バージョンの RabbitMQ 2.1.1 を実行し、.Net クライアントを使用しています。次のようにテストを実行しています: 500000 メッセージを一時的な非持続的ファンアウト交換に発行し、クライアントは自動削除キューを使用します。キューは 1 つだけです。パブリッシャーは 1 秒あたり最大 10,000 件のメッセージを送信します。すべてのメッセージが送信された後、切断されます。rabbitmqctl ツールは、キュー サイズが 0 であることを示していますが、受信側は数秒間メッセージを受信して​​おり、メッセージの 60% しか受信していません。このような遅延が発生する理由と、それを最小限に抑える方法を知っていますか?

乾杯！