46得票2回答
为什么CELERY_ROUTES同时有“queue”和“routing_key”?

我理解AMQP的消息只有以下几个组成部分: 消息正文 路由键 交换机 队列附加在交换机上,消息不可能知道队列的存在。它们只是发布到一个交换机,然后根据交换机类型和路由键将消息路由到一个或多个队列。 在Celery中,推荐路由任务的方法是通过 CELERY_ROUTES 设置。根据文档...

45得票1回答
如何在RabbitMQ中重新排队消息。

消费者接收到消息后,进行一些验证操作,然后调用Web服务。在这个阶段,如果出现任何错误或验证失败,我们希望将消息放回最初消费的队列中。 我已经阅读了RabbitMQ文档。但我对拒绝(reject)、否定(nack)和取消(cancel)方法之间的区别感到困惑。

45得票9回答
如何使用Python列出或发现RabbitMQ交换机上的队列?

我需要一个Python客户端,可以在重新启动的RabbitMQ服务器交换机上发现队列,并启动客户端以从每个队列恢复消费消息。如何使用一些兼容RabbitMQ的Python API /库发现队列?

45得票5回答
低延迟、大规模的消息队列

在Facebook应用和云计算时代,我正在重新思考大规模多人游戏。假设我要在现有开放协议的基础上构建一个服务于100万并发玩家的系统。 假设每个玩家都有一个传入消息队列(用于聊天等),平均还有一个传入消息队列(公会、区域、副本、拍卖等)。因此我们需要2,000,000条队列。每个玩家会同时监听...

44得票2回答
RabbitMQ中的Ack或Nack意味着什么?

我正在使用RabbitMQ,通过basic_get从队列中获取每个消息,但不会自动确认过程,这意味着消息将保留在队列中,直到我确认或拒绝该消息。 有时候,由于某些异常抛出导致无法完全处理消息,因此会出现无法处理的消息。 问题是,在成功和异常情况下是否都确认消息,对于结果消息都将离开队列,...

43得票7回答
AMQP和amqplib - 哪个是更好的Node.js AMQP客户端库?

这些AMQP客户端库有哪些区别? 哪一个是最受推荐的? 主要区别是什么?

43得票4回答
在多租户系统中如何使RabbitMQ中的队列变得私有/安全?

我已阅读RabbitMQ提供的入门指南,甚至为stormed-amqp贡献了第六个示例,因此对AMQP有一点了解。 然而,该指南不够全面,并避免像身份验证和授权等事项。 我们正在设计一个多租户系统,将在其中使用RabbitMQ进行RPC类型的情况。这种RPC实现的不同之处在于远程过程实际上...

40得票6回答
在Pika(AMQP Python)中获取队列大小

这是一个简单的问题,但谷歌或Pika开源代码都没有提供帮助。是否有一种方法可以查询当前在Pika中队列的大小(项目计数器)?

38得票6回答
访问RabbitMQ(AMQP)的最佳PHP客户端库是什么?

在RabbitMQ网站上有一份PHP客户端列表。我发这个问题是想让使用过这些任何一个客户端的人在这里分享他们的经验。 安装时是否遇到任何问题? 稳定性如何? 是否存在性能问题? 文档/支持如何? 即使您只使用过其中一个库,请分享您的经验。 以下是其中一些客户端: AMQP PHP...

34得票3回答
消息代理与消息导向中间件(MOM)的区别

我有些困惑于消息代理(例如RabbitMQ)和面向消息的中间件之间的区别。除了维基百科上的信息外,我找不到更多资料。当搜索MOM时,我发现了关于AMQP的信息,它是MOM的协议...这是什么意思?那么MOM又是什么呢?我还读到RabbitMQ实现了AMPQ协议...那为什么RabbitMQ可以...