《rabbitmq》专题

我们正在尝试用nodejs、rabbitmq和MongoDB构建一个聊天应用程序。为了更快地传递消息，我们正在使用rabbitmq。因为我对这个概念是新的，如果有人可以的话，请帮我一下。我正在使用node amqp模块连接到rabbitmq服务器（https://www.npmjs.org/package/amqp）。 我声明如下所示的交换： var amqp=require('amqp')；va

我有两个队列，我需要对其中一个队列执行以下操作：生产者应该向这个队列发送一条消息，但所有消费者都应该接收它。因此，如果我在这个队列中有5个spring侦听器，那么每个侦听器都应该接收消息，而不是生产者。我这样做是因为我有一个tomcat集群和rabbitmq异步消息，如果我从工作者那里得到响应，我不知道如何将它分派到正确的tomcat节点。所以我决定将所有工作者回复广播给所有tomcat节点。每个

首先，我知道这里已经有一个类似问题的答案了，但我仍然不能确定这是因为RabbitMQ的不可能，还是因为我研究得不够。 我来自事件pub/sub模式是这样工作的JS/Node背景：当许多消费者用pub/sub模式订阅同一个主题时，无论何时某个生产者发布它，所有人都应该得到相同的消息。 我希望用消息代理实现相同的模式。 例如： 生产者%1发布到主题 生产者2发布到主题 RabbitMQ的实际操作（根据

示例:                               >>>服务B（获取消息） 服务A>推送消息>>>服务B（不应接收消息，已复制）                         >>>服务C（获取消息） 我认为它是“路由”和“工作队列”的组合，我需要什么？ 但我怎样才能正确地做到这一点呢？我使用node.js或C#（如果您有示例的话）。

使用.NET rabbitmq客户端（https://www.rabbitmq.com/dotnet.html）。创建了一个库，其他项目可以引用该库在总线上订阅/取消订阅/发布消息。 根据这里和这里提供的信息，为了让每个订户接收所有消息，每个客户端需要为每个订户定义一个不同的队列，绑定到交换机。我遇到的问题是如何在“客户端”应用程序使用队列完成后删除队列（因为这将以指数级增长，而且永远不会被清理掉

是否可以使用topic将消息发送到队列，并有2个消费者接收和处理相同的消息？目前，我已经创建了两个消费者，他们正在观察与一个exchage主题绑定的队列，但是第一个消费者使用了该消息并删除了该队列，第二个消费者没有接收到该消息。

我想在负载均衡器后面设置一个rabbitmq集群，并使用spring AMQP连接到它。问题： > spring客户端是否需要知道RMQ集群中每个节点的地址，或者只知道负载均衡器的地址就足够了。 如果Spring客户端只知道负载均衡器，那么它将如何为集群中的每个节点维护连接/连接工厂。 是否有任何代码示例，说明如何使spring客户端与负载均衡器一起工作。

你为什么要这么做？我理解增加消息的持久性（如果一个节点关闭，其他队列仍然获得消息）。但是性能呢？集群如何提高性能。难道所有的消费者/生产者都不会连接到主节点的队列吗？如果是这样，我们不是仍然在单个节点上获得流量吗？我们是否设置了负载均衡器，使得流量每次都指向不同的节点？ RabbitMQ集群如何提高性能？

对于一个幼稚的开发人员来说，他们似乎可以发布到集群中的任何节点，并从这些节点消费，这会给他们一种高可用性的错误感觉。 如果承载队列的节点死亡，使用者将不再能够从另一个节点到达队列。 是否有一种方法可以禁用这种行为，这样就可以很明显地看到，您要么必须有一个镜像队列，要么需要在每台服务器上创建一个不同的队列，从这两个服务器中使用，然后处理重复的队列。 谢谢

我用开发了一个web应用程序，它运行良好。 现在我正在尝试为其他开发人员设置相同应用程序的更多实例。因此，现在我有9个实例(dev01-dev09)。我已经为每个dev实例创建了数据库并设置了文件，除了之外，它们都运行良好。例如，由创建的消息队列，但它是由dev02的使用者处理的（它应该由dev01处理）等等。 [更新于美国东部时间1月23日凌晨4点]为了尝试一下，我将queue_options中

我正在尝试用https://github.com/php-amqplib/rabbitMQBundle和Symfony2框架实现RabbitMQ。 我已经设法使这个东西在一个生产者和一个消费者的情况下工作，但问题是当我使用多个消费者的时候。 这是我的配置： [Symfony\Component\DependencyInjection\Exception\ServiceNotFoundExcepti

我目前正在尝试使用RabbitMQ（具有出色的RabbitMQBundle）来处理大量的异步工作。 目标是让一个队列发布相同类型的消息，并让多个服务器上的X个工作者在同一时间内查看消息。 每个工人都要偷看一条消息，完成工作，然后偷看另一条消息，等等。 这里是我的conf： 在我的consumer中，我有一个日志文件中的条目和120秒的睡眠。 我启动了php app/console rabbitmq

在尝试创建到运行在不同服务器上的rabbitmq的新连接时，我得到了以下错误： null 命令PID用户FD类型设备大小/关闭节点名称 beam.smp 3084 rabbitmq 15u IPv6 18611 0T0 TCP*:AMQP（侦听） rabbitmqctl列表连接 tcp 0 0:::5672:::*侦听3084/beam.smp

有线索吗？

我需要创建一个队列进行处理。队列本身的容量相对较低。每小时可能会有1000封信。每个任务的执行可能需要大约一分钟的时间，并且几乎在项目添加到队列后立即进行处理。 我有没有理由想要实现RabbitMQ而不是像Amazon SQS这样的现成的东西？为什么应用程序需要自己的队列系统而不是像SQS这样的东西？