怎么拖延?- php-amqplib
我想知道如何使用 Amqpphplib 进行延迟. 我使用了这个很棒的咖啡脚本教程: https://github.com/jamescarr/rabbitmq-scheduled-delivery 但它似乎不适用于 PHP-amqplib. 消息如我所愿过期，但似乎“x-dead-letter-exchange"不起作用.我使用了 RabbitMQ 管理控制台，我可以实时
..
amqp相关内容
如何有选择地从 AMQP(RabbitMQ)队列中删除消息?
我想有选择地从 AMQP 队列中删除消息，甚至不读取它们. 场景如下: 发送方希望基于 X 类型的新信息到达的事实使 X 类型的消息过期.因为订阅者很可能还没有消费 X 类型的最新消息，所以发布者应该删除以前的 X 类型消息并将最新的消息放入队列中.整个操作对订阅者应该是透明的——事实上他应该使用像 STOMP 这样简单的东西来获取消息. 如何使用 AMQP 做到这一点?或者也许
..
等待一条带有超时的 RabbitMQ 消息
我想向 RabbitMQ 服务器发送一条消息，然后等待回复消息(在“回复"队列上).当然，我不想永远等待，以防处理这些消息的应用程序出现故障 - 需要超时.这听起来像是一项非常基本的任务，但我找不到这样做的方法.我现在遇到了 py-amqplib 和 RabbitMQ .NET 客户端. 到目前为止，我得到的最佳解决方案是使用 basic_get 和中间的 sleep 进行轮询，但这很丑:
..
PHP致命错误:找不到类'AMQPConnection'
我已经看过这个问题.它表明未安装 AMQP PECL 扩展.但是，我已经成功安装了 RabbitMQ 以及构建的 PECL AMQP 扩展.以下是phpinfo()的输出. 可以清楚地看到，AMQP 加载正确.但是，当我尝试建立连接时，它显示 PHP 致命错误:找不到类 'AMQPConnection'.下面是代码. $connection = new AMQPConnection();
..
如何使用 python 列出或发现 RabbitMQ 交换中的队列?
我需要一个 python 客户端，它可以在重新启动的 RabbitMQ 服务器交换上发现队列，然后启动一个客户端来恢复消费来自每个队列的消息.如何从一些 RabbitMQ 兼容的 python api/库中发现队列? 解决方案 据我所知，没有任何方法可以做到这一点.这与 Python 无关，但因为 AMQP 没有定义任何队列发现方法. 在任何情况下，在 AMQP 中，声明队列的是客户
..
rabbitMQ 中的 Ack 或 Nack
我正在使用rabbitMQ，我使用basic_get从队列中获取每条消息而没有自动确认程序，这意味着消息一直在队列中，直到我确认或确认消息. 有时我的消息由于引发了一些异常而无法处理，这阻止了它们被完全处理. 问题是，如果我同时确认消息成功和抛出异常有什么关系，我的意思是结果消息总是会从队列中出来，所以在这种情况下我使用 ack 或 nack 有什么关系?也许我在使用每个操作时错过了一
..
如何让 Spring RabbitMQ 创建一个新队列?
根据我对 rabbit-mq 的(有限)经验，如果您为尚不存在的队列创建新侦听器，则会自动创建队列.我正在尝试将 Spring AMQP 项目与 rabbit-mq 一起使用来设置侦听器，但我得到了一个错误.这是我的 xml 配置: 我在我的 RabbitMq 日志中得到了这个: =错误报告==== 3-May-2013::23:17:24 ===连接 ，通道 1 -
..
Objective-C RabbitMQ 客户端未将消息发布到队列
我正在尝试使用 RabbitMQ for iOS 制作消息传递应用程序.我正在将此包装类用于目标 c，并带有 RabbitMQ-C 客户端库. https://github.com/profmaad/librabbitmq-objc 交换、队列和队列绑定一切正常，但我的代码没有将消息发布到 RabbitMQ 服务器.请帮帮我，什么问题? 这是我的代码: NSError *er
..
将消息从 RabbitMQ 转换为 string/json
我目前正在努力解决一个相当简单的问题.我想接收来自 RabbitMQ 的消息并将其转换为字符串(或稍后的 json 对象).但我得到的只是字节. Message 对象以这种方式将自身显示为字符串 (Body:'{"cityId":644}'; ID:null; Content:application/json; Headers:{}; Exchange:; RoutingKey:pages
..
使用 pika 发布消息时如何添加标题键:值对
我正在编写一个自动化测试来测试消费者.到目前为止，我不需要在发布消息时包含标题，但现在我需要.而且似乎缺少文档. 这是我的发布商: class RMQProducer(object):def __init__(self, host, exchange, routing_key):self.host = 主机self.exchange = 交换self.routing_key = routi
..
AMQP 0-9-1 对 1-0
我正在为一个新项目寻找消息服务，该项目必须将一些 C# 应用程序与一些 Java 应用程序连接起来.我真的很喜欢 RabbitMQ，因为它似乎对这两种技术都有惊人的支持.我在 RabbitMQ 规范中看到，目前只提供了 AMQP 0-9-1 模型. 那是节目的终结者吗?我应该向提供 AMQP 1.0 的 ActiveMQ 发送地址吗? 感谢您的建议 解决方案 您的问题在官方 中
..
如何使用 cygwin/mingw 在 windows 上编译 PHP 扩展?
我正在尝试构建 RabbitMQ PHP 包装器 和 AMPQ PHP 包装器 在 Windows (64) 上使用 Cygwin.我已经成功构建了底层 C 库(librabbitmq.dll)，但我被困在“phpize"步骤: phpize &&./configure --with-rabbit &&制作&&须藤制作安装 如果我理解正确，windows 上没有“phpize"，那么我
..
rabbitmq 队列上有多个消费者-只有一个消费者收到消息
我实现了多个消费者，他们从单个队列中获取消息，我使用类似于 这个例子，除了我在一个无限循环中执行 basic.get 以进行轮询. 知道如何防止所有消费者之间发生竞争，因为只有一个消费者会收到消息，而另一个消费者将继续进行轮询，直到另一条消息到来吗? 我尝试实现一个逻辑，在该逻辑中，一旦我收到消息，我就确认它以删除消息，但似乎其他一些队列在第一个队列确认并删除它之前设法获取了该消息.所以每
..
找不到记录器“pika.adapters.blocking_connection"的处理程序；
类似的问题似乎都基于使用自定义记录器，我很高兴只使用默认值/根本不使用.我的 pika python 应用程序运行并接收消息，但几秒钟后崩溃，找不到记录器“pika.adapters.blocking_connection"的处理程序，有什么想法吗? 导入鼠兔凭证 = pika.PlainCredentials('xxx_apphb.com', 'xxx')参数 = pika.Connectio
..
Azure IoT 中心 AMQP 通信多路复用
在一些 Microsoft 文档中在使用 Azure IoT 中心时，它提到可以在单个 TLS 连接(使用 AMQP 协议)下多路复用多个设备的通信，用于多个简单设备与一个功能强大的本地中心设备通信的场景物联网中心.是否有任何示例说明如何实现这种多路复用?DeviceClient 库 似乎不支持这一点(尽管我可以错误的).也有人提到了用于此场景的 IoT 网关 SDK，但我还没有找到有关如何使用它
..
Celery 不释放内存
看起来celery在任务完成后没有释放内存.每完成一个任务，就会有 5m-10m 的内存泄漏.因此，如果有数千个任务，很快就会耗尽所有内存. BROKER_URL = 'amqp://user@localhost:5672/vhost'# CELERY_RESULT_BACKEND = 'amqp://user@localhost:5672/vhost'CELERY_IMPORTS = ('ta
..
由于 SocketException，RabbitMQ 新连接被拒绝
尝试创建与在不同服务器上运行的 rabbitmq 的新连接时，出现以下错误: java.io.IOException在 com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)在 com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)在 com.rabbitmq.
..
在 FIFO 队列系统中，实现优先消息传递的最佳方式是什么?
对于不始终支持优先级消息的面向消息的中间件(例如 AMQP)，当队列只有 FIFO 语义时，实现优先级消费的最佳方法是什么?一般用例是这样一种系统，其中当队列中存在大量消息积压时，消费者会在收到较低优先级消息之前收到较高优先级的消息. 解决方案 鉴于给定的单个队列仅支持 FIFO，您当然必须引入多个队列、中介或具有更复杂的消费者.> 可以通过多种方式处理多个队列.生产者和消费者可以同意在
..
RabbitMQ:默认的 x-message-ttl 值是多少
我在 RabbitMQ 文档中找不到安装时附带的默认 x-message-ttl 值. 我知道如何将其设置为所需的值，但我很想知道默认值. 解决方案 broker 端默认没有设置 x-message-ttl 参数，所以基本上你可以将默认值解释为无穷大. 如果您将没有 ttl 的消息发布到没有设置 ttl 的队列(是的，有每个消息和每个队列的 ttl 参数，请参见下面的注释):
..
通过 PECL 安装 AMQP
我正在尝试安装 RabbitMQ PECL 扩展，但在运行之后 sudo pecl install amqp 我收到以下神秘的错误消息，大量的谷歌搜索没有帮助解决. 我安装了这些软件包: librabbitmq - RabbitMQ C 客户端本身) librabbitmq-dev - 开发标头等 和RabbitMQ在本地主机上成功运行 也许是 C 客户端的版本与 P
..