问题标签 [rabbitmq]

我基本上需要一种能够对消息进行排队的排队技术。这些消息随后将作为 SMS 文本传输。RabbitMQ 似乎很适合在我掩盖了 api 之后。

我目前的架构计划：

1. 客户端在 RabbitMQ 中排队消息。
2. 另一个守护进程将从 RabbitMQ 读取消息并将这些消息发送到第 3 方 SMS 网关。守护程序应该能够产生多个侦听器线程。
3. 我计划使用 Ubuntu Hardy 在 slicehost.com 上托管所有内容。

你预见到这个设计有什么问题吗？由于我对 Erlang 有粗略的了解，因此我不知道如何在生产环境中运行它。如果您对 Erlang 或 RabbitMQ 有任何经验，我想听听您的战争故事。

我们很想听听有关 ActiveMQ、RabbitMQ 和 ZeroMQ 优缺点的任何经验。也欢迎提供有关任何其他有趣消息队列的信息。

问题：我想实现几个 php-worker 进程，它们在 MQ 服务器队列上侦听异步作业。现在的问题是，简单地将这些进程作为服务器上的守护进程运行并不能真正让我对实例进行任何级别的控制（负载、状态、锁定）......除了转储 ps -aux 之外。因此，我正在寻找某种运行时环境，可以让我在系统（进程）级别或更高层（某种 Java 风格的应用服务器）上监视和控制实例

任何指针？

我试图将系统从使用 morbid 转移到 rabbitmq，但我似乎无法获得默认提供的相同广播行为 morbid。通过广播，我的意思是当一条消息被添加到队列中时，每个消费者都会收到它。使用rabbit，当添加消息时，它们会以循环方式分发给每个听众。

谁能告诉我如何实现相同的消息分发？

下面使用的 stomp 库是http://code.google.com/p/stomppy/

如果无法使用 stomp，即使是 amqplib 示例也会有帮助。

我目前的代码看起来像这样

消费者

发件人看起来像这样

有谁知道是否有办法从客户端应用程序检查 RabbitMQ 队列中的消息数量？

我正在使用 .NET 客户端库。

我正在尝试部署一个执行一些异步任务的 RoR 应用程序。我为此使用工作，消息队列是 RabbitMQ。这种组合与 Starling 完美配合，但我们决定为 Rabbit 更改 MQ。我在某处读到我应该在我的 environment.rb 中包含以下代码

但是现在 Apache 完全失败并显示消息：服务器遇到内部错误或配置错误，无法完成您的请求

我有点困惑我应该使用哪一个。我认为任何一种都可以，但是一种比另一种更好或更合适吗？

http://github.com/ask/carrot/tree/master

http://github.com/ask/celery/tree/master

我在 Django 项目中将 Carrot 用于消息队列并按照教程进行操作，并且效果很好。但是该示例在控制台中运行，我想知道如何在 Django 中应用它。我从models.py 中的一个模型调用的发布者类，所以没关系。但我不知道把消费类放在哪里。

由于它只是与 .wait() 一起坐在那里，我不知道在什么时候或在哪里需要实例化它，以便它始终运行并侦听消息！

谢谢！

对于不始终支持优先级消息的面向消息的中间件（例如 AMQP），当队列只有 FIFO 语义时，实现优先级消费的最佳方式是什么？一般用例是这样一个系统，当队列中存在大量消息积压时，消费者在接收优先级较低的消息之前接收优先级较高的消息。

我最近看到的关于RabbitMQ的一个演示文稿提到了使用称为“幂等性屏障”的东西来进行消息重复数据删除。这只是消息混合器的一个花哨名称还是更具体的名称。如果是这样，它到底是什么？谷歌搜索产生的结果大多与 RabbitMQ 相关，几乎没有解释它是什么。