php-amqplib相关内容

RabbitMQ 错误超时

我设置了 RabbitMQ 以解析来自外部 API 的大约 20.000 个请求,但几分钟后它一直超时.它确实可以正确解析总共 20.000 个请求中的大约 2000 个. 日志文件说: =INFO REPORT==== 16-Feb-2016::17:02:50 ===接受 AMQP 连接 (127.0.0.1:33091 -> 127.0.0.1:5672)=错误报 ..
发布时间:2022-01-11 17:40:47 PHP

RabbitMQ 和 PHP 中如何将任务返回到队列中?

如果处理结果不适合我,我如何将消息返回到队列.仅找到有关消息确认的信息,但我认为它不适合我.我需要,如果作为处理的结果我得到参数 RETRY 消息被添加回队列.然后这个工人或另一个工人又把它捡起来并试图处理它. 例如: channel();$channel->queue_declare('test', false, false, false, false);$callback = 函数($ ..
发布时间:2021-07-02 18:39:55 PHP

RabbitMQ - 如何检查队列是否为空?

我有一个抽象 RabbitMQ 服务器的 Web 服务接口(不要问我为什么,我知道这是一个不必要的步骤,但我必须这样做).也就是说,我通过 Web 服务调用从队列中轮询消息,而不是直接通过 amqp. Consuming via basic.consumer 阻塞执行线程,直到队列中有消息.这使得 Web 服务不返回. 示例代码: $connection = new AMQPStr ..
发布时间:2021-07-02 18:38:19 PHP

与RabbitMQ的主题交流歧义

我有点困惑.我正在尝试进行主题交流,不确定是否需要什么. 我想要几个路由键和1个主题交换(默认为amq.topic).我的钥匙是这样的: customer.appA.created customer.appB.created 客户.*.创建 我希望我的队列是持久的,但是我需要1个“客户"队列还是2个appA和appB队列? 我已经知道我的出版商了; 连接,交换声明,基本发布. ..
发布时间:2020-07-05 04:40:30 PHP

RabbitMQ错误超时

我已经设置RabbitMQ来解析来自外部API的大约20.000个请求,但是几分钟后它一直保持超时.确实可以正确解析20.000个请求中的2000个. 日志文件显示: =INFO REPORT==== 16-Feb-2016::17:02:50 === accepting AMQP connection (127.0.0.1:33091 -> 127.0.0.1: ..
发布时间:2020-05-17 20:56:28 PHP