0

我正在尝试使用 videlalvaro/php-amqplib 库进行 AMQP 通信,但似乎无法让非阻塞版本工作。运行 demo/amqp_consumer_non_blocking.php 只是不断地显示以下错误消息:

PHP Warning:  stream_select(): supplied argument is not a valid stream resource in RabbitMQ/test/amqp_consumer_non_blocking.php on line 86
PHP Stack trace:
PHP   1. {main}() RabbitMQ/test/amqp_consumer_non_blocking.php:0
PHP   2. stream_select(*uninitialized*, *uninitialized*, *uninitialized*, *uninitialized*) RabbitMQ/test/amqp_consumer_non_blocking.php:86

使用 @ 符号抑制此消息可以消除错误,但我仍然无法让它显示任何内容。

假设我正确地向它发送了一条消息:我正在使用 Web 界面,只是将一条消息直接发布到队列中,但就像我说的那样,我在我的非阻塞循环中没有得到任何东西。

使用阻塞演示 (demo/amqp_consumer.php) 执行相同的过程可以按预期工作。

有没有其他人遇到过这类问题,或者他们可以指导我找到一些可能的解决方案吗?谢谢。

4

0 回答 0