問題タブ [php-amqp]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
2 に答える
817 参照

php - RabbitMq: PHP AMQP を使用して Exchange で AMQP_AUTODELETE フラグを設定する

AMQPExchange::setFlags ( int $flags ) を使用して、交換に AMQP_AUTODELETE フラグを設定しようとしています。

http://php.net/manual/en/amqp.constants.php http://www.php.net/manual/en/amqpexchange.setflags.php

動作しません... :(

$exchange->getFlags() は、16 (AMQP_AUTODELETE の整数値) ではなく 0 を返します。

しかし、同じ方法で AMQP_DURABLE フラグを設定すると機能し、$exchange->getFlags() は 2 を返します。

誰かがこれに対する解決策を見つけましたか? ありがとう!!!

0 投票する
1 に答える
1494 参照

php - 複数のキューを優先的に消費する

Producer がトピック交換にメ​​ッセージを送信しています。各メッセージにはルーティング キーが含まれています。(初歩的な図で申し訳ありません)

私はphp-amqplibを使用しており、多数のキューを消費しようとしています。私が達成しようとしているのは、各キューを順番にテストし、メッセージがあるかどうかを確認し、メッセージがある場合は処理し、そうでない場合は次のキューに移動することです。また、メッセージが見つかった場合は、再度 Q1 からチェックを開始してください。次のコードは機能しませんが、私がやりたいことのロジックを示します。

0 投票する
1 に答える
273 参照

php - PHP AQMP メッセージ形式

キューに入れることはできますか、それともキューに入れる前にシリアル化してからシリアルPHP objects化を解除する必要がありますか?

キューからのメッセージを処理するには?

0 投票する
1 に答える
2445 参照

php - PHPやSymfony2で複数のRabbitmq/AMQPコンシューマーを並行して実行するには?

このライブラリを介してメッセージをブロードキャストするニューススクレーパー/ RSS アグリゲーションがあります。

https://github.com/vidalvaro/php-amqplib/

私は現在、1 人の放送局/プロデューサーと 1 人の消費者を抱えています。

PHP経由で複数のコンシューマーを並行して実行する方法はありますか? PHP がこれをネイティブにサポートしていないことはわかっています。cURL を介して仮想的に行うこともできますが、cURL は主にネットワーク/Web ベースの要求に使用されます。

それで、PHPでこれを達成する方法はありますか? もちろん、Python/Java でもできますが、私のレベルはどちらもあまりよくありません。

0 投票する
1 に答える
4576 参照

php - autoload.php の問題: ストリームを開けませんでした: そのようなファイルやディレクトリはありません

私はPHPが初めてで、autoload.phpの問題を理解しようとしています。php-amqplib パッケージをダウンロードしました。これは依存関係であり、PHP ページをテストしようとしています。ストリームを開くのに失敗しました: No such file or directory 'D:\inetpub\wwwroot\test\vendor\videlvaro\php-amqplib\demo/../vendor/autoload.php' (include_path='.;C: \php\pear')。私は 5.3.13 を使用しており、「D:\PHP5313」フォルダーにインストールされています。「梨」フォルダはありません。何か不足している場合はお知らせください。提案をありがとう。

autoload.php

0 投票する
1 に答える
639 参照

php - 動的メッセージ更新用の RabbitMQ PHP

私はRabbitMQを学んでおり、Facebookが友人から動的なフィードを提供するのと同じように、ユーザーに「動的メッセージ」の更新を提供するためにそれを使用することを考えました。

私のアイデアは:

  1. ユーザーが作成されるたびに、ユーザーの userId という名前のキューを作成するので、キュー名は " 100_message_queue" (userId_message_queue) にすることができます。

  2. Producer は、すべての更新をこのキューにプッシュします。

  3. クライアント側 (javascript) から " " のような REST API を呼び出し、GET http://example.com/getliveupdates/100新しい更新をすべて取得し100_message_queueて応答として送信します。

RabbitMQ php チュートリアルを読みましたが、これがどのように可能かわかりませんか? さらに、消費者は永久に実行されるため、REST リクエストを作成できないようです。それは私にタイムアウトを与えています。

この種の構造を実装する方法はありますか?

ありがとう

0 投票する
1 に答える
1079 参照

php - Web ブラウザーで php-amqplib rabbitMQ を使用する方法

メッセージの送受信に php-amqplib を使用しようとしています。端末上で送受信を行います。しかし、Web ブラウザーにアクセスすると、キューから受信できず、メッセージを継続的に待機します。以下のコードを receive.php に使用しました

コールバック関数の代わりに以下を使用すると、キューから最初のメッセージを取得しますが、キューからは消費しません

これは、キュー「test22」でメッセージが利用可能であることを意味します。手がかりを教えてください。