《rabbitmq》专题

RabbitMQ在下列情况下会循环分发消息吗？ RabbitMQ配置: 交换类型-主题 路由密钥-通知# 制片人正在将消息推送到上面的交流中，并遵循以下不同的主题 - notify.log.# ， notify.status.#， notify.priceChange.# 有4个消费者在不同的服务器上运行。 > 3个消费者在负载均衡器下执行相同的处理并在同一应用程序的不同实例上运行。（他们想消费生

它提供的Swagger UI和rest API规范给了我灵感。 最近，我开始使用消息代理（特别是RabbitMQ），我希望有一些工具来开始开发具有消息和队列规范的面向微服务的系统。 是否有任何工具允许制作这些规范？从代码生成文档还是从模型生成代码？ 提前感谢！ 更新: 如本文所述。队列，交换，填充，用户和权限可以用RabbitMQ配置文件来描述。 AsyncAPI 看起来是一个很好的解决方案

我所拥有的： 我用rabbitMQ作为代理运行芹菜，用redis作为结果后端。我有一个发送任务和处理任务的工人的应用程序。 我按如下方式进行了部署: 应用程序、redis、RabbitMQ和一个工作人员（让我们称他为“local_worker”）正在使用docker-compose在azure VM上运行，因此我使用docker版本的RabbitMQ和redis（6.2.5）。RabbitMQ和r

我是芹菜、Redis和RabbitMQ的新手。 目前，我正在使用RabbitMQ作为消息代理，并且在配置中没有设置任何内容。（使用Django、MySQL） 我想知道是否有可能使用Redis作为后端的结果存储，同时将RabbitMQ用作消息代理。 我知道的只是添加一些设置，

我的粗略理解是，如果您需要内存中的键值存储特性，Redis会更好，但是我不确定这与分布任务有什么关系？ 这是否意味着如果我们已经将Redis用于其他用途，那么我们应该将其用作消息代理？

我有一个RabbitMQ代理，它设置了多个队列。在客户端(Java ),我有多个消费者，他们都像这样监听他们的队列: 队列_1- 它们都使用一个连接但不同的通道。发生的情况是，当我加载所有队列并启动应用程序代理服务时，首先服务一个队列，而不是另一个队列，依此类推。因此，消息一次由各自的消费者一个队列接收。我还想提一下，我正在使用预取计数1来实现消费者流量的公平分配。 我怎样才能让它发生，让所有的队

我使用RabbitMQ作为不同消息的队列。当我使用来自一个队列的两个不同消费者的消息时，我会处理它们并将处理结果插入数据库： 我想大量使用队列中的消息，这将减少数据库负载。由于RabbitMQ不支持消费者批量读取消息，我将这样做smth： 消息在全部完全处理之前处于队列中 如果消费者跌倒或断开连接 - 消息保持安全 你认为这个解决方案怎么样？如果可以的话，如果消费者摔倒了，我怎样才能重新得到所有未

OpenStack使用RabbitMQ作为消息传递系统。为此，有几个交换机和队列。我发现名为“nova”的“topic”类型的交换用于消息传输。Exchange使用路由密钥将消息路由到队列(http://www.rabbitmq.com/tutorials/amqp-concepts.html). （有用图像位于http://www.rabbitmq.com/img/tutorials/intro

我们正在使用Rabbitmq-server_3.5.7及其相应的延迟消息交换插件 到目前为止，我们一直在使用直接交换并控制客户端应用程序上的消息生成器的延迟(并跟踪当前队列中的消息数量)。 我们已经开始成功使用延迟交换，但我们想知道如何检查当前延迟的消息数量（这是等待路由到队列）。 兔子是否提供了一种知道这一点的方法？是否有任何其他方法可以访问此信息？ 谢啦！

我已经开始使用RabbitMQ，我的用例非常简单——生产者将消息放在队列中，由消费者处理。每条消息最多由一个消费者处理，消息根据队列名称从生产者定向到消费者。 < code >直接交换看起来非常好，并且< code >默认交换是< code >直接交换。 是否有任何原因（性能、管理、许可等）不使用交换并创建自己的交换？例如，我将使用高可用性队列（https://www.rabbitmq.com/h

我已经建立了一个rabbit集群，每当数据库中发生变化时，我都会将消息发布到fanout交换中。 我为使用这些更新的一些微服务绑定了专用队列，我最初还为外部客户端设置了专用队列，以便他们可以将其与自己的rabbit基础架构联合起来，并使用每条消息的副本。 现在，我想知道，允许exchange联合而不是为每个新的外部消费者创建新的专用队列是否是更好的方法，因为将有越来越多的用户加入。 有哪些利弊？

可以通过多个RabbitMQ集群使用RabbitMQ HA吗？ 这是我的要求： 我们有2个RabbitMQ集群(每个集群有4个节点)。两个集群中的所有节点都将使用相同的Erlang cookie。因此，尽管这两个群集在物理上位于不同的位置，但将作为一个包含8个节点的群集。 我们计划使用HAProxy来负载平衡两个集群（8个节点）。发布者和消费者都将使用此代理连接到代理。 我们希望为HA使用镜像队列

我成功地建立了一个话题交换，并且能够同时向几个消费者传递消息。 我还想向竞争对手传递信息，并继续使用主题交换。我了解到，使用相同的队列名称可以让消费者竞争消息。然而，我可能弄错了，因为我无法使它工作。 为同一主题的多个侦听器设置： < li >申报话题交流 < li >对于每个侦听器，用自动生成的名称声明一个新队列 < li >用给定的主题路由关键字将此队列绑定到上面的交换 如何将相互竞争的消费者

我是AMQP的新手，正在尝试为RabbitMQ系统制定一个通知架构。 我想要一个主题交换（通知交换，比方说），特别是因为我想灵活地使用主题交换附带的路由密钥和队列，以及将来扩展该主题的更多选项。不过，我可能是错的，因为... 我还想让两个或更多的消费者使用每个通知。作为基线，我希望发布的每个通知都在数据库中结束。此外，我希望每个通知都可以由客户端应用程序使用(例如，web应用程序使用并进一步通过套

TL;DR：一旦我修复了最初导致消息被拒绝的消费者代码，我需要将死信消息“重放”回其原始队列中。 我已经为RabbitMQ配置了死信交换（DLX），并成功地将拒绝的消息路由到死信队列。但现在我想查看死信队列中的消息，并尝试决定如何处理每个消息。一些（许多？）一旦有问题的消费者代码被修复，这些消息中的所有消息都应该重放（重新排队）到它们的原始队列（在“x-death”标题中可用）。但我该怎么做呢？我