问题标签 [amqp]

此外，该 JSON 的大小是否可能为 5MB？

为什么要使用其中一个？

很多时候，我的队列将保持为空。但是当它填满时，该队列如何通知我的服务器执行 python 脚本？

我可以让 python 脚本每 5 秒进入一次队列，但这很愚蠢。

我正在构建一个基于 Web 的生产力应用程序，该应用程序必须处理适度的用户并发，并且我一直在探索各种选项来保持服务器和客户端之间的数据同步。应用程序数据在页面加载时被引导到 JavaScript，并且 websockets 用于将数据推送到服务器。

对于一些上下文，我目前正在使用 Node.JS 和 Socket.IO 创建一个持久的客户端-服务器网关，它充当 Django 后端的代理。

挑战在于，我希望使所有连接的客户端彼此保持同步，以便在一个客户端会话上对应用程序的任何更改都会立即反映在所有连接的客户端会话上。困难在于并非所有用户都必须被允许查看所有数据；有各种不同的用户级别，不同的用户可以拥有略有不同的数据集。

因此，当以某种方式更改对象并将更改提交到数据库时，我需要知道我可以安全地将数据推送到当前连接的用户中的哪些用户。

我一直在探索不同的解决方案，我觉得这似乎可以通过 pubsub 消息队列处理 - 使用 AMQP 之类的东西，但我正在努力弄清楚应用程序的结构。

在我看来，应用程序结构如下所示：

Client<--> Node.JS gateway<--> AMQP messaging queue<-->Django app

我是否应该只创建一个直接交换，将 Node.js 和 Django 实例视为单个客户端，然后以某种方式在 Node.js 中过滤结果？

或者这种过滤是消息系统可以处理的，例如，每个连接的客户端订阅一个相关的主题，并且只接收他们被允许查看的数据？

我几乎没有使用消息传递系统的经验，所以我很难弄清楚它们在应用程序中能够扮演什么样的角色。任何建议将不胜感激。

我正在使用 RabbitMQ 按主题将消息路由到感兴趣的订阅者。每个订阅者都有一个队列，我将队列绑定到他们感兴趣的主题。我想允许用户从他们的主题列表中删除一个项目。

在我的设置中，这将需要从该用户的队列中“解除绑定”绑定主题。

我正在使用 pyamqplib，但我没有看到通过通道对象执行此操作的方法。他们是一种从队列中删除先前绑定的路由键的方法吗？

我需要有一个 python 客户端，它可以在重新启动的 RabbitMQ 服务器交换上发现队列，然后启动一个客户端以恢复消费来自每个队列的消息。如何从一些 RabbitMQ 兼容的 python api/库中发现队列？

通常我习惯于在 beanstalkc 中放置字符串。但我想把字典作为 amqp 的工作。

Udi在这里提到“人们已经换掉了 NServiceBus 的 MSMQ 层并在其位置插入了 RabbitMQ”。

我希望做同样的事情，最终目标是能够在带有 AMQP 的 Mono/Linux 上运行使用 NServiceBus 构建的应用程序。

在深入研究之前，我想从可能已经这样做的人那里得到一些关于要避免的陷阱、红鲱鱼等的反馈。

或者，如果该方法是一项艰巨的任务，最好直接使用 RabbitMQ，但如果可能的话，我想坚持使用 NServiceBus。

我在我的一个项目中使用 django celery 并且收到 (13, Permisison denied) 错误。

请参阅下面的回溯：

我认为它与权限有关。服务器的登录凭据很好，除此之外一切正常。

celeryd 守护程序在我提供的 rabbitmq 连接凭据下运行良好。

当我以 root 身份运行开发服务器时，它不会给我这个错误。我认为它可能与文件或套接字权限有关，但我不知道去哪里修复它。

RabbitMQ 站点上有一个PHP 客户端列表。我问这个问题是希望用过这些的人可以在这里分享他们的经验。例如

• 你安装有什么问题吗？
• 稳定吗？
• 有没有性能问题？
• 文档/支持如何？

即使您刚刚使用过其中一个库，也请分享您的经验。

作为参考，这里列出了一些客户：

• AMQP 的 PHP 手册页
• php-amqp - StudiVZ 开发和使用的客户端，最初基于 RabbitMQ-C
• php-amqplib py-amqplib 的一个端口
• php-amqplib 更新为支持 PHP 5.3 的 php-amqplib 的一个分支
• AMQP 客户端的 PECL 版本

PS 我知道“Best ...”是“主观的”，但这个问题的重点是收集经验并帮助人们对这些 AMQP 库做出明智的决定。请不要仅仅因为它包含“最佳”这个词而下意识地关闭这个问题。

PPS 我在 RHEL 5 上使用 PHP 5.3。