问题标签 [rabbitmq]

如何检查消息队列是否已存在？

我有 2 个不同的应用程序，一个创建一个队列，另一个从该队列读取。

因此，如果我运行首先从队列中读取的客户端，它就会崩溃。
所以为了避免这种情况，我想先检查队列是否存在。

这是我如何读取队列的代码片段：

我想发布/生成一条带有一些消息 id 的消息，就像每条消息都有一个特定的 id 一样。

在消费者端，我想通过提供 ID 来检索消息。假设我们有多个消费者，而不是每个消费者应该只获得他们通过消息 ID 请求的那些消息。（我希望我足够清楚）。

似乎我看过的大多数消息传递系统都具有对优先级消息队列的基本支持（如果有的话）。例如，AMQP 仅指定至少 2 个优先级。RabbitMQ 是一种 AMQP 实现，不支持任何优先级。ActiveMQ 将在几天后在 5.4 版中获得对 10 个消息优先级的支持。JMS 规范指定了 10 个优先级。

单词的非消息传递意义上的优先级队列基于具有不受限制的优先级范围的任意字段对其内容进行排序。为什么像这样的实现不作为消息传递系统的一部分存在？正如我在标题中所问的，优先级本质上是非消息传递概念吗？

我意识到一个答案可能是优先级的概念引入了消息在队列中无限地等待处理更高优先级消息的可能性。还有其他原因吗？

如果我在我的 web 应用程序（spring）中使用队列，我可以这样做：

要响应添加到队列中的新项目，还是必须是在服务器上运行的单独服务？

即这不能在 Web 应用程序中持续正确吗？

我正在编写 .Net 4.0 Web 解决方案的组件（在 IIS7、WS2008 上），并且需要提供可以使用消息队列中的消息的服务。我找到了使用 MSMQ 配置 WAS 服务激活的设置示例……但我们没有使用 MSMQ（使用 RabbitMQ），我很确定我必须实现自己的某种侦听器。

我想我的问题是我必须设置的配置设置系统非常不透明，文档也不清楚。

所以 A：我如何为 WAS 服务激活实现和配置自定义侦听器。

和 B：任何有关配置此设置其余部分的建议都会很棒。

谢谢

我希望能够中止从芹菜队列运行的任务（使用rabbitMQ）。我使用

其中 AsyncBoot 是一个已定义的任务。

我可以获取任务 ID（假设是apply_async返回的长字符串）并将其存储在数据库中，但我不确定如何调用中止方法。我看到如何使用 Abortable 任务类使方法可中止，但如果我只有任务 ID 字符串，我如何在任务上调用 .abort() ？谢谢。

到目前为止，我们还没有真正需要在我们的基础设施中实现队列系统，但现在我们需要一些无法通过 cron 作业完成的功能（太慢了）。

我们的基础设施是带有一些 NoSQL 的 LAMP (PHP)。

我看过 Gearman，它似乎非常适合我们的需求。我知道 Digg 和 Yahoo 都使用它，所以它一定是可靠的。

• 是否有任何管理工具可以在工人死亡或创建新任务时自动启动它？

• 如何在同一个基础架构下处理多个项目（项目 A 有 5 个任务，项目 B 有 10 个，项目 C 有 1 个）

• 有没有办法轻松完成周期性任务？

我见过 Celery，它看起来不错，但它似乎只适用于 AMQP（或仅适用于 RabbbitMQ），但它是在 python 中，我还没有找到关于你是否可以使用非 python 任务的太多信息。

谢谢

RabbitMQ 不断失败，我们通过重新启动服务来修复它，但我们不知道它为什么会失败。有没有其他人遇到过这些问题？

我有一个生产者，我想通过一致的哈希在消费者之间一致地分配工作。例如，对于消费者节点 X 和 Y，任务 A、B、C 应该总是去消费者 X，而 D、E、F 应该去消费者 Y。但是如果 Z 加入消费者池，这可能会发生一点变化。

我不想编写自己的逻辑来连接到消费者节点，尤其是不想管理加入和离开池的节点，所以我走上了使用 RabbitMQ 的道路，每个消费者节点都有一个独占队列.

我遇到的一个问题是列出这些队列，因为生产者需要在分配工作之前知道所有可用的队列。AMQP 甚至不支持列表队列，这让我不确定我的整个方法。不过，RabbitMQ 和 Alice（目前不完整）添加了该功能：是否有用于在 RabbitMQ 上列出队列和交换的 API？

这是对兔子的明智使用吗？我应该使用消息队列吗？是否有更好的设计让队列可以始终如一地在消费者之间分配我的工作，而不是我需要这样做？

How to use RabbitMQ message broker in Java application? I have not found any document or link to understand how to do it.