问题标签 [rabbitmq]

Greetings,

I'm evaluating some components for a multi-data center distributed system. We're going to be using message queues (via either RabbitMQ or Qpid) so agents can make asynchronous requests to other agents without worrying about addressing, routing, load balancing or retransmission.

In many cases, the agents will be interacting with components that were not designed for highly concurrent access, so locking and cross-agent coordination will be needed to avoid race conditions. Also, we'd like the system to automatically respond to agent or data center failures.

With the above use cases in mind, ZooKeeper seemed like it might be a good fit. But I'm wondering if trying to use both ZK and message queuing is overkill. It seems like what Zookeeper does could be accomplished by my own cluster manager using AMQP messaging, but that would be hard to get really right. On the other hand, I've seen some examples where ZooKeeper was used to implement message queuing, but I think RabbitMQ/Qpid are a more natural fit for that.

Has anyone out there used a combination like this?

Thanks in advance,

-Chris

通常在 Windows 中工作，但尝试在我的 Mac 上设置 RabbitMQ。有人可以让我知道下面的行是做什么的吗？

具体来说，我对[ "x" = "x$RAB..."]语法很好奇。

我正在寻找允许我执行以下操作的开源队列平台：我有多个生产者，多个消费者将数据放入具有特定用例的多线程环境中的队列中：我希望消费者能够执行以下操作

1. 查看队列中的消息（应在队列中将消息标记为不可见，以便其他消费者无法使用相同的消息）
2. 消费者处理消费的消息，如果它能够成功完成工作，它会将消息标记为已消费，这应该将其从队列中永久删除。
3. 如果消费者在将消息标记为已消费后突然死亡或在一定超时后未能确认成功消费，则该消息将再次在队列中可见，以便另一个消费者可以拾取它。

我一直在研究 RabbitMQ、hornetQ、ActiveMQ，但我不确定我是否可以开箱即用地获得这个功能，有什么建议可以提供给我这个功能的系统吗？

我遇到了一个问题，我在共享模式下设置了一个队列并且多个消费者绑定到它。问题在于，rabbitmq 似乎正在序列化消息，也就是说，一次只能运行一个消费者。我需要它是平行的，但是，我似乎无法弄清楚如何。

每个消费者都在自己的进程中运行。队列中有大量消息。我正在使用 py-amqplib 与 RabbitMQ 交互。

有什么想法吗？

我想向 RabbitMQ 服务器发送一条消息，然后等待回复消息（在“回复”队列上）。当然，我不想永远等待，以防处理这些消息的应用程序出现故障 - 需要超时。这听起来像是一项非常基本的任务，但我找不到这样做的方法。我现在在py-amqplib和RabbitMQ .NET 客户端都遇到了这个问题。

到目前为止我得到的最好的解决方案是使用中间进行轮询basic_get，sleep但这很丑陋：

当然有更好的方法吗？

是否可以使用我的 Rails 应用程序启动 AMQP 订阅者？可能通过初始化程序或其他方式。

我想让它同时运行，也可以与 Rails 模型交互。下面是我的意思的伪代码示例。

我已经看了很多，但我还没有找到一种好的编程方式来列出 RabbitMQ 服务器上的队列。

这很重要，因为当我完成队列和交换时，我需要清理它们。我并不总是有一个很好的“完成”事件可以用来触发清理，所以我想用更多的垃圾收集模型来做。如果我可以列出队列，我可以验证与它们相关的对象不应该产生更多条目并清理它们。

我知道我可以用rabbitmqctl它来做，但这需要提升权限。

由于我无法找到以编程方式列出队列的方法，因此我一直在数据库中保留一个名称列表。这行得通，但它很丑。

我正在编写一个小型 Django 应用程序，我应该能够为每个模型对象创建其定期任务，该任务将以一定的时间间隔执行。我正在为此使用 Celery 应用程序，但我无法理解一件事：

然后我做以下事情：

第一次调用成功，但其他定期调用返回错误 - TypeError: run() 在 celeryd 服务器中恰好采用 2 个非关键字参数（1 个给定）。我可以将自己的参数传递给 PeriodicTaskrun()吗？

在我的工作团队中，我们大量使用 IBM MQ 技术进行跨应用程序通信。我最近在 Hacker News 和其他地方看到了有关其他 MQ 技术（如RabbitMQ ）的信息。我对它是什么有一个基本的了解（一个通常检查的区域来放置和获取消息），但是我想知道它到底擅长什么？我怎么知道我想在哪里以及何时使用它？为什么不坚持使用更基本的进程间消息传递形式？

我有一些代码会产生大量应该存储在数据库中的数据。问题是数据库无法保存它生成的数据。所以我想知道某种排队机制是否会在这种情况下有所帮助 - 我特别在 RabiitMQ 考虑将数据存储在其队列中是否可行，直到某些消费者从中获取数据并将其推送到数据库. 另外，我对这些数据是否进入数据库并不特别感兴趣，因为很快，相同的数据将被更新。