《rabbitmq》专题

我在可靠性模式中使用AMQP，我的用例是将消息放入队列中，然后消费它们并将信息插入web服务中。我的web服务很慢，我的队列可能有很多很多消息，我希望确保消费者不会杀死我的数据库。 在RabbitMQ中是否有一种内建的方式来执行节流，或者是基于时间的（每分钟/秒/小时仅有X条消息），或者是某种其他机制？

我们最近遇到了由RabbitMQ支持的应用程序的意外行为。RabbitMQ版本为3.6.12，我们使用的是.NET客户端5.0.1 应用程序订阅了两个队列，一个用于命令，另一个用于事件--我们还使用手动确认。我们的应用程序配置为有7个消费者。每个通道都有自己的通道(IModel)，每个通道都有自己的EventingBasicConsumer，当EventingBasicConsumer.Recei

我在我产品环境中发现了一个问题。 我们在一个mq集群中有6个队列，我们有200个线程的线程池（实际上会更多，因为它会在一个独立的线程池中安排一些特殊任务）来处理来自上游的请求，当处理请求时，我会发布一个消息给rabbitmq Broker。 所以我有200个线程将消息发布到这6个队列。 对于每个队列，我将创建一个AMQP连接，对于每个线程，我有一个Channel的threadlocal，这样每个线

下面的最小示例（针对我遇到的问题）将在通过同一通道发送的第二个命令时失败，错误为“channel closed”。 该方案应： 连接到RabbitMQ 打开RabbitMQ通道 声明simpe队列（名为“test”） 绑定到队列（名为“测试”） 发布消息（“你好，世界！”） 成功发布消息后，请稍候，然后发布另一条消息 为什么或RabbitMQ本身会关闭通道（而不是连接或我错过了什么）？

我有一个从Rabbit接收消息的应用程序。当收到一条消息时，它会对它进行处理，然后在完成时执行ACK。应用程序可以在一个固定的线程池中同时处理2个项目，有2个线程。Rabbit的QOS预取设置为2，因为我不想在一个时间框架内给应用提供超过它所能处理的内容。 现在，我的消费者的handleDelivery执行以下操作： 此时，您已经发现TestWrapperThread将调用作为最后一个操作。 根据

我有一个多线程应用程序，它将传入的消息发布到rabbitmq交换。使用rabbitmq java客户端，我在应用程序启动时创建一个rabbitmq连接，并在所有线程之间共享它。每个线程都创建一个新通道（threadlocal）,这样通道就不会像rabbitmq文档所建议的那样在多个线程之间共享。我正在使用netty，我看到相同数量的rabbitmq通道被创建为netty通道管道线程。到目前为止还不

我的应用程序有多个线程将消息发布到单个RabbitMQ集群。 阅读rabbit文档：我阅读了以下内容： 对于使用多个线程/进程进行处理的应用程序，每一个线程/进程打开一个新通道，并且不在它们之间共享通道是非常常见的。 而且我明白，与其开通多个连接（昂贵） 不如开通多个通道。 但是为什么不对所有线程使用单个通道呢？ 在单个通道上使用多个通道有什么好处？

我是新手RabbitMQ java客户端。我的问题：我创建了10个consumer并将它们添加到队列中。每个消费者使用10秒来处理我的流程。我检查了Rabbit的页面，我看到我的队列有4000条消息没有发送到客户端。我检查了日志客户端，结果是为一个消费者获取一条消息，10秒后，我为一个消费者获取一条消息，依此类推…我想要得到10个消息为所有消费者在当时（10个消息-10消费者过程在当时）请帮助我，

场景： 我只有一个生产者和消费者，只有一个队列来传输消息。使用者将根据已使用该值的消息更新DB上的值。不应将任何操作并行发送到DB。所以，我们不应该做任何导致数据库上数据并发的事情。我使用一次接收一条消息。删除是否会导致多个操作并行发送到DB？

我对RabbitMQ很陌生，所以如果我的问题听起来很琐碎，请原谅。我想在RabbitMQ上发布消息，它将由RabbitMQ消费者处理。 我的消费者机器是一个多核机器（最好是azure上的工作者角色）。但QueueBasicConsumer一次推送一条消息。我如何编程来利用我可以同时处理多个消息的所有核心。 一种解决方案是在多个线程中打开多个通道，然后在那里处理消息。但在这种情况下，我将如何决定线程

我想在多个python进程之间共享。以便从其他python进程发送。 如何跨多个python进程共享。 代码如下： 目标是从通道从其他python进程发送。

是否可以在Celery中使用不同的消息代理？ 例如：我想使用PostgreSQL而不是RabbitMQ。

我对RabbitMQ这样的消息代理并不熟悉，我们可以使用它为Celery这样的调度系统创建任务/消息队列。 现在，问题是： > 我可以在PostgreSQL中创建一个表，该表可以添加新任务，并由消费者程序（如Celery）使用。 null Redis也可以用作消息代理吗？我发现它更类似于Memcached，而不是rabbitMQ。 请把这件事说清楚！

有没有一种方法可以限制RabbitMQ队列只将固定数量的消息从队列发送给使用者？ 关于这一问题的更多背景资料： 为什么一次只处理2条消息？：Q2消息正在执行web服务调用，而web服务endpoint（第三方）只能同时服务2个消息。 我们不能使用并发吗？：如果我们使用ListenerContainer（Spring AMQP）,则容器是每个消费者的。我们可以限制一个消费者一次可以获取多少消息，但是

RabbitMQ的大部分文档似乎都集中在循环（round-robin）上，即单个消息由单个消费者使用。我有一个需求，其中希望从一个队列接收到多个订阅的消费者的相同消息。 下面是我的示例消费者代码。这里有两个侦听器在侦听同一个队列，但是只有一个使用者接收到消息。如何配置它，以便将相同的消息传递给两个消费者？（Consumer1和Consumer2)。任何帮助都将得到高度赞赏。