问题标签 [php-amqplib]

有一个演示消费者：

只要通道注册了回调，它就会循环

例如，我需要从队列中获取不超过 100 条消息。例如，如果只有 80 个，它应该只返回 80 并退出循环。

谢谢

我有 WordPress 4.1.1，当我尝试创建或更新帖子时，我收到以下错误：

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

它发生在我的产品服务器上，但不在本地。

有人知道为什么会这样吗？

I'm trying to use the Delayed Message Queue for RabbitMQ from PHP, but my messages are simply disappearing.

I'm declaring the exchange with the following code:

I'm binding the queue with this code:

And I'm publishing a message with this code:

But the message doesn't get delayed; it's still immediately delivered. What am I missing?

我有一个抽象 RabbitMQ 服务器的 Web 服务接口（不要问我为什么，我知道这是不必要的步骤，但我必须这样做）。也就是说，我通过 Web 服务调用从队列中轮询消息，而不是直接通过amqp.

通过basic.consumer阻塞执行线程直到队列中有消息。这使得 Web 服务不会返回。

说明代码：

How can I send an array of messages using RabbitMQ? I do not want to send every message separately.

For example:

How could I use something like:

Thank you!

我用 rabbitMq 和 videlalvaro/php-amqplib php 客户端实现了一个简单的消息服务。但是当我发送两条消息时，我的接收者丢失了一条。知道会发生什么吗？使用的代码如下。

发送.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] 接收：发送消息 1
[x] 接收：发送消息 3
[x] 接收：发送消息 5
[x] 接收：发送消息 7
[x] 接收：发送消息 9

我只需要从一个队列中捕获一条实际消息。兔子试图抓住所有人。简化代码如下：

我向队列扔了几条消息，但是一旦我执行下面的部分代码，它就会从队列中获取所有消息，并且 $callbacks 只是第一个。

我正在尝试将消息传递到交换器，然后传递到特定队列。

交换的类型是“直接”，然后我添加了一个名为“foo_bar”的队列，作为“路由键”，我使用了相同的“foo_bar”字符串。

只是阅读文档http://www.rabbitmq.com/tutorials/tutorial-four-php.html我不明白我在哪里做错了:(

大家好！

我在php (Yii2) 上编写worker来使用php-amqplib处理 rabbitMQ 消息。

代码示例：

我使用主管妖魔化工人。

前两天一切正常，然后我在 RabbitMQ 中看到：

工人根本不阅读消息，数量增加了。

主管告诉工人工作正常，但可以阅读消息。

如果我重新启动主管 - 一切都开始正常工作，消息开始减少。

日志清晰=（

你们中有人有同样的问题吗？

我需要创建一个简单的队列管理器来将一个数字从发送者传递给消费者。RabbitMQ 提供的 Hello World 教程几乎涵盖了其中的 70%。

但我需要将队列更改为不要永远等待传入的消息。或者在收到一定数量的消息后停止等待。我阅读并尝试了其他帖子的一些解决方案，但它不起作用。

rabbitmq AMQP::consume() - 未定义的方法。还有另一种方法，wait_frame，但它受到保护。

和其他帖子在python中，我不明白。