問題タブ [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.
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 を返します。
誰かがこれに対する解決策を見つけましたか? ありがとう!!!
php - 複数のキューを優先的に消費する
Producer がトピック交換にメッセージを送信しています。各メッセージにはルーティング キーが含まれています。(初歩的な図で申し訳ありません)
私はphp-amqplibを使用しており、多数のキューを消費しようとしています。私が達成しようとしているのは、各キューを順番にテストし、メッセージがあるかどうかを確認し、メッセージがある場合は処理し、そうでない場合は次のキューに移動することです。また、メッセージが見つかった場合は、再度 Q1 からチェックを開始してください。次のコードは機能しませんが、私がやりたいことのロジックを示します。
php - PHPやSymfony2で複数のRabbitmq/AMQPコンシューマーを並行して実行するには?
このライブラリを介してメッセージをブロードキャストするニューススクレーパー/ RSS アグリゲーションがあります。
https://github.com/vidalvaro/php-amqplib/
私は現在、1 人の放送局/プロデューサーと 1 人の消費者を抱えています。
PHP経由で複数のコンシューマーを並行して実行する方法はありますか? PHP がこれをネイティブにサポートしていないことはわかっています。cURL を介して仮想的に行うこともできますが、cURL は主にネットワーク/Web ベースの要求に使用されます。
それで、PHPでこれを達成する方法はありますか? もちろん、Python/Java でもできますが、私のレベルはどちらもあまりよくありません。
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
php - 動的メッセージ更新用の RabbitMQ PHP
私はRabbitMQを学んでおり、Facebookが友人から動的なフィードを提供するのと同じように、ユーザーに「動的メッセージ」の更新を提供するためにそれを使用することを考えました。
私のアイデアは:
ユーザーが作成されるたびに、ユーザーの userId という名前のキューを作成するので、キュー名は "
100_message_queue
" (userId_message_queue) にすることができます。Producer は、すべての更新をこのキューにプッシュします。
クライアント側 (javascript) から " " のような REST API を呼び出し、
GET http://example.com/getliveupdates/100
新しい更新をすべて取得し100_message_queue
て応答として送信します。
RabbitMQ php チュートリアルを読みましたが、これがどのように可能かわかりませんか? さらに、消費者は永久に実行されるため、REST リクエストを作成できないようです。それは私にタイムアウトを与えています。
この種の構造を実装する方法はありますか?
ありがとう
php - Web ブラウザーで php-amqplib rabbitMQ を使用する方法
メッセージの送受信に php-amqplib を使用しようとしています。端末上で送受信を行います。しかし、Web ブラウザーにアクセスすると、キューから受信できず、メッセージを継続的に待機します。以下のコードを receive.php に使用しました
コールバック関数の代わりに以下を使用すると、キューから最初のメッセージを取得しますが、キューからは消費しません
これは、キュー「test22」でメッセージが利用可能であることを意味します。手がかりを教えてください。