問題タブ [php-amqplib]

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 投票する
1 に答える
620 参照

php - メッセージのみがある場合のphp-amqplibループ

デモコンシューマがあります。

チャンネルにコールバックが登録されている限りループします

たとえば、キュ​​ーから 100 個以下のメッセージを取得する必要があるということです。たとえば、80 しかない場合は、80 だけを返してループを終了する必要があります。

ありがとう

0 投票する
0 に答える
73 参照

php - WordPress での AMQPRuntimeException

WordPress 4.1.1 を使用していますが、投稿を作成または更新しようとすると、次のエラーが表示されます。

PhpAmqpLib\Exception\AMQPRuntimeException thrown Error Connecting to server(111): Connection refused

私の本番サーバーでは発生しますが、ローカルでは発生しません。

なぜこれが起こっているのか知っている人はいますか?

0 投票する
3 に答える
5763 参照

php - PHP から RabbitMQ 遅延メッセージ キューを使用するにはどうすればよいですか?

PHP から RabbitMQのDelayed Message Queueを使用しようとしていますが、メッセージが消えてしまいます。

次のコードで交換を宣言しています。

私はこのコードでキューをバインドしています:

そして、私はこのコードでメッセージを公開しています:

しかし、メッセージは遅れません。それはまだすぐに配信されます。私は何が欠けていますか?

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

php - RabbitMQ - How to check if queue is empty?

I have a web service interface that abstracts a RabbitMQ server (don't ask me why, I know it's an unnecessary step, but I have to). That is, I poll messages from the queue through a web service call, not directly over amqp.

Consuming via basic.consumer blocks the execution thread till there are messages in the queue. This makes the web service not return.

Code for illustration:

0 投票する
3 に答える
3873 参照

node.js - RabbitMQ 経由で配列を送信する

RabbitMQ を使用してメッセージの配列を送信するにはどうすればよいですか? すべてのメッセージを個別に送信したくありません。

例えば:

どうすれば次のようなものを使用できますか:

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

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

php - RabbitMQ で失われたメッセージ

私は、rabbitMq と videlalvaro/php-amqplib php クライアントを使用して単純なメッセージ サービスを実装しています。しかし、2 つのメッセージを送信すると、受信者は 1 つを失います。何が起こったのでしょうか?使用したコードは以下です。

send.php

受信機.php

send.php 出力応答

[x] メッセージ 0 を送信
[x] メッセージ 1 を送信
[x] メッセージ 2 を送信
[x] メッセージ 3 を送信
[x] メッセージ 4 を送信
[x] メッセージ 5 を送信
[x] メッセージ 6 を送信
[x] メッセージ 7 を送信 [x
] ] メッセージ送信 8
[x] メッセージ送信 9

receiver.php 印刷応答

[x] 受信: SEND MESSAGE 1
[x] 受信: SEND MESSAGE 3
[x] 受信: SEND MESSAGE 5
[x] 受信: SEND MESSAGE 7
[x] 受信: SEND MESSAGE 9