考虑一层N个订阅者，所有订阅者都使用相同的队列名称和路由键值连接到直接交换。这创建了一个负载平衡系统，其中以循环方式将入站消息发送给1个订阅者。这对于处理横向扩展问题非常有效，因为随着负载的增加，可以添加更多的订阅者，如果需要，可以在以后撤回订阅者。现在考虑能够向该层中的所有订阅者发送消息的要
浏览 2提问于2010-07-01得票数 0
回答已采纳
我是RabbitMQ的新手。在RabbitMQ中，一旦消息被使用者使用，它是否仍然在队列中可用？来自特定队列的单个消息能被多个使用者使用吗？与卡夫卡不同，在文件系统中存储消息是如何在RabbitMq中存储的？
浏览 4提问于2017-06-12得票数 1
回答已采纳
我有一个有一个生产者和一些消费者的环境。
对于消息类型2，扇出/直接/路由/主题是合适的。
但我该如何把它们结合起来呢？
浏览 10提问于2016-03-20得票数 3
回答已采纳
3回答
我有一个兔子mq服务器正在运行，其中有一个直接交换，我所有的消息都通过这个交换。这些消息被路由到单独的非永久性队列(它们可能持续几个小时)。我刚开始阅读有关到交换的队列绑定的内容，对于是否真的需要将队列绑定到exchange，我感到有点困惑。我使用的是、pika、、basic_publish和consume函数，所以这可能是隐含的吗？
浏览 1提问于2016-01-15得票数 1
回答已采纳
我正在尝试从我的Android应用程序连接到一个名为"messages“的队列。}
我试过用"amq.topic"，“amq.tope.*”，"amq.topic.messages“等……但是当我查看RabbitMQ队列部分时，"messages“是0个消费
浏览 0提问于2014-12-01得票数 7
我有一些问题，让皮卡与路由密钥或交换的方式是一致的，AMQP或RabbitMQ文档。我知道RabbitMQ文档使用了一个旧版本的Pika，所以我忽略了它们的示例代码。我想要做的是定义一个队列，"order“，并有两个使用者，一个处理交换或routing_key”生产“，另一个处理”测试“。从RabbitMQ文档中可以看出，通过使用直接交换</em
浏览 0提问于2011-03-27得票数 4
我一直试图使用RabbitMQ，并面临以下问题(非常类似于这个问题：)。我需要密集地广播大约800种类型的消息(因此每种消息类型都有许多用户)，我想知道以下哪种方法更好：
创建一个直接交换，其中将使用路由键(消息类型名称)发送消息，每个使用者都将通过一个临时队列绑定到该交换，并绑定相应的路由密钥。(因为没有像'key1.key2.*‘这样复杂的路由密钥，所以我决定不使用主题交换
浏览 3提问于2013-05-30得票数 5
2回答
我需要构建一个使用发布/订阅总线(例如，Mule、ZeroMQ、RabbitMQ)的系统，但文献都暗示，只要发布/订阅总线能够传递消息，订阅者应用程序就可以可靠地接收来自它们订阅的主题的消息。我有一个系统，其中一些应用程序将可靠地连接到发布/订阅总线，但其他应用程序将不会一直处于活动状态或连接到总线。显而易见的解决方案是在不可靠的应用程序和发布/订阅总线之间有
浏览 17提问于2011-06-28得票数 5
1回答
我正在使用使用RabbitMQ和MassTransit的pub/sub消息来集成几个RabbitMQ模块。大多数邮件订阅应该是持久的。但有些应该是暂时的。问题来了，因为现在发送方必须决定路由到哪个交换。这是错误的，因为我希望接收者决定是使用持久的还是暂时性的队列。
是否有更好的方法同时支持持久的和短暂的订阅？为什么MassTransit绑定消息交换到绑定到端点队列的端点<e
浏览 1提问于2017-11-08得票数 0
我已经了解了RabbitMQ的基本原理。有一件事我发现发布者不会直接在队列上发布。exchange根据routing-key和exchange类型决定消息应该在哪个队列上发布(下面的代码使用默认交换)。我还找到了publisher的示例代码。pdfprocess', body='User information')connection.clo
浏览 5提问于2021-02-24得票数 0
回答已采纳
1回答
我特别想知道，这种排队技术是否可以用于支持消息路由--类似于RabbitMQ的路由功能。
我们将用直接交换代替。直接交换背后的路由算法很简单--消息发送到绑定密钥与消息的路由密钥完全匹配的队列。在这个设置中，我们可以看到有两个队列绑定到它的直接交换X。第一个队列与绑定键橙色绑定，第二个队列有
浏览 2提问于2012-12-06得票数 11
回答已采纳
2回答
我正在尝试设计一种重放机制，使用户能够重播队列中的消息。对于包含多个队列和多个使用者的交换，我提出的最佳设计是：
在这个解决方案中，为每个队列创建一个交换以发布相同的消息。为了重播最后一天，消费者</
浏览 2提问于2015-04-15得票数 26
2回答
对于RabbitMQ中的路由密钥和绑定密钥，我有一个小小的疑问。我所理解的是，生产者用“路由密钥”向交换发送消息。使用绑定密钥将队列绑定到exchange。在默认交换的情况下，我遇到了这样的定义：“每个队列都使用与队列名称相同的路由密钥自动绑定到默认exchange。”
所以这里应该是“绑定密钥”而不是路由密钥吗？？还是这些条款几乎一样？每个队列都绑定到默认<em
浏览 0提问于2018-05-24得票数 6
预期的行为i想要发布消息到“直接”交换与路由密钥，这是绑定到两个不同的队列，以执行其他活动。using (var connection = factory.CreateConnection()) using (varnull, body
浏览 4提问于2015-05-10得票数 10
回答已采纳
我有一个服务器，它在交换上发布rabbitmq消息，因此我尝试创建以下异步api规范-info: version: 1.0.0HellowWorldEvent: type: object根据我的理解，它的意思是MyApp将使用路由密钥hello_world_routing_key在hello_world_exchange交换上发布he
浏览 4提问于2022-05-05得票数 0
回答已采纳
我有一个场景，我需要执行一系列流程，每个步骤都是在独立的应用程序中完成和缩放的。我在所有的交流中使用主题交换。当前的拓扑如下所示：我们正在对队列进行“版本控制”，以处理影响消息结构的可能的需求更改。绑定可能如下所示：步骤1.交换绑定到步骤1.v2的队列与绑定密钥步骤1.v2
还有其他与版本无关的绑定模式，它们也使主题<
浏览 4提问于2012-06-28得票数 24
2回答
我对RabbitMQ和AMQP协议有丰富的经验，并且构建了一个包含命令、请求和事件模式的系统。什么是相当于路由密钥？其他人是怎么处理的？在我看来，RabbitMQ是一个为满足消息总线的通常需求而构建的工具，其中AWS提供块，您必须自己设置/构建该功能。我说的对吗？
浏览 4提问于2017-10-22得票数 9
回答已采纳
1回答
我知道什么代表了(扇出、直接、主题、标题)交换、绑定、队列和几乎所有关于消息架构的内容。我有以下问题，我需要一些建议。
我想实现对我的应用程序的通知逻辑，其中每个用户将收到的实时通知只为他。(实际上，我不想提到我的UI和BE语言/框架是什么，因为有一个额外的抽象级别)，UI将使用WebSocket、SockJS和STOMP与WebSocket建立一个连接。我的UI将仅仅是一个使用者，be是编写者，它将向RabbitMQ添加一些消息。我非常清楚
浏览 4提问于2017-09-20得票数 1
回答已采纳
1回答
但是，我应该为每个进程创建一个队列，并为每个用户绑定一个单独的交换吗？或者在每个进程中为每个用户创建一个单独的队列，并以某种方式绑定到某个交换中。Fanout交易所浮现在脑海中，每个进程都有一个队列，我只是不确定队列与交换的关系，尽管我花了一些时间试图弄清楚它。我有一个分布式应用程序，需要通知产品更改。然后，每当一个实例对某个特定产品的更新感兴趣时，它就为该产品创建一个交换，并将其绑定到队列</em
浏览 2提问于2014-01-25得票数 0
回答已采纳
我试图更好地理解使用队列(尤其是RabbitMQ )设计分布式系统的细微差别。当每个人完成对文档的签名时，发布者将发送上述消息。消费者应该根据个人的角色去做不同的事情。应该将消息转到直接交换(没有的路由密钥)，并最终进入1队列吗？使用者需要侦听一个队列，因此它有责任确定参与者的哪种类型(基于角色)已签署了doc.。
是否应该将消息直接交换</e
浏览 1提问于2021-12-16得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
