1回答
我正在将事件驱动的体系结构移植到容器环境(Docker)，我想知道如何在使用pub-sub时利用复制的优势:如果我只是增加副本，我就会得到许多进程进行同样的精化，我认为这不是一个好方法。我想用生产者-消费者取代pub-sub，所以消费者等待队列中的事件，只有一个人抓住它，但我想避免紧密耦合。
是否有“负载平衡”发布-订阅的解决方案？此外，商业工具可以检查。
浏览 0提问于2019-09-17得票数 4
实现下一步的最佳方式是什么： 我发布关于员工的消息。我想要关于几个员工的消费者流程消息。例如-我发送关于员工1,2,3,4,5的消息。我想以下一种方式处理消息:消费者1-接收关于员工1，3，5的消息；消费者2-接收关于员工2,4,5的消息 如果我为每个员工创建了一个特定的队列，我如何才能向消费者订阅一个以上的队列</em
浏览 17提问于2020-01-10得票数 0
在我的应用程序中，我有一个将消息发布到多个队列的系统。例如，我有3个RabbitMQ队列，消息被发布到这3个队列。目前，这3个队列有3个使用者。现在我需要做一个修改，我想让两个队列有一个消费者。我们是否可以将一个订阅者用于多个队列。在<em
浏览 1提问于2018-02-19得票数 3
我对RabbitMQ有一个比较独特的用例，我不确定如何解决这个问题。我希望有一个绑定了多个消费者的队列，然后让RabbitMQ一次只向一个消费者发送一条消息，并在向任何其他消费者发送另一条消息之前等待ACK。我意识到这会扼杀吞吐量，基本上会让其他消费者挨饿，但对我来说，这是可以接受的。出现这种奇怪用例的原因是，
浏览 1提问于2013-05-23得票数 1
3回答
它的配置乱七八糟，过于复杂，而且文档也不完整。
但是在芹菜中，所有的术语都是混乱的:在这里，您可以拥有一个，它向多个</e
浏览 3提问于2014-06-18得票数 13
回答已采纳
我有一个使用RabbitMQ构建的发布订阅场景。有一个交换，其中消息由发布者发送，订阅该交换的任何使用者都在各自的队列中接收这些消息。这是一个扇形场景，只有一个生产者，但有多个消费者。现在，我愿意将一个死信队列集成到系统中，以便稍后处理被拒绝的消息。我的问题
浏览 0提问于2017-03-09得票数 1
现在我正在使用Direct Exchanges (即每个“主题”只有一个队列，几乎可以直接将消息推送到队列中)。这是可行的，但我希望使用Topic Exchanges的灵活性，特别是多个订阅主题而不破坏消息的消费者(即每个主题多个队列)。即使所有的消费者都减少了，我们也希望生产者能排满队。我们仍然希望能够有多个消费者被旋转，以处理
浏览 0提问于2018-04-12得票数 1
1回答
我实现了多个消费者，他们从单个队列中获取消息，我使用类似于的方法来实现这一点，除了在无限循环上执行basic.get以进行轮询之外。知道我如何防止所有消费者之间的竞争，因为只有一个消费者将得到消息，而另一个消费者将继续进行轮询，直到另一个消息出现？我尝试实现一种逻辑，在此逻辑中，我一收到消息，就将其打包，以便将消息删除，但似乎其他队列在第
浏览 8提问于2015-09-30得票数 12
我正在使用RabbitMQ/Spring/Spring AMQP构建一个应用程序，并且在处理我的队列布局时遇到了问题。从本质上讲，我有一个每个消费者都会监听的队列，每个消息基本上都说“这个队列已经准备好由一个消费者来处理了”。然后，使用者将侦听消息中指示的队列，使用该队列中的</em
浏览 41提问于2019-10-02得票数 0
回答已采纳
它本质上是一个扇形交换，但我有它，所以它可以扇出不同的消费者基础上的routing_key。在这里，有两个用于两个消费者的队列，每个队列都绑定到路由密钥“泵”上，用户将回复到reply_to队列，然后确认消息，以便他们的独占队列删除发送到其队列的消息。每个收到消息的使用者都会这样做。，，代理将
浏览 2提问于2022-05-03得票数 0
1回答
我正在使用RabbitMQ进行一个项目，并将许多消费者连接到一个队列中。我想知道是否有一种方法来指定哪个使用者在使用来自队列的消息时获得“优先级”。有些消费者更适合这份工作，如果他们是可用的，我想先向他们传达信息，然后再通知其他消费者。
我正在使用RabbitMQ的最新版本(截至编写时)。我有一个PHP发布者和
浏览 1提问于2020-01-02得票数 0
回答已采纳
我有一个RabbitMQ设置，在这个设置中，作业被发送到一个交换，后者将它们传递给一个队列。消费者依次正确地执行队列中的作业。然而，这些作业是很长的过程(至少几分钟)。为了实现可伸缩性，我需要让多个使用者从队列顶部选择一个作业并执行它。
消费者正在一个名为“队列”的<
浏览 5提问于2020-01-11得票数 0
回答已采纳
我有一个包含大量队列的RabbitMQ设置。由于每个队列中数据的性质，它必须按严格的顺序处理，因此我们只能允许每个队列上只有一个使用者。这本身并不是一个问题，但我们确实冒着意外地在队列中启动第二个消费者的风险，这将是一件坏事。这里有大量的队列和应用服务器，我们只需犯一
浏览 5提问于2017-12-29得票数 5
回答已采纳
这似乎是一个简单的问题，但我很难找到一个明确的答案。如果在RabbitMQ 3.6.1中有一个如下所示的队列：我使用信息1，然后做：1最终是在队列的末尾还是在队列的顶端(为了简单起见，假设当时没有其他人在使用队列</e
浏览 2提问于2016-06-08得票数 12
回答已采纳
我已经了解了RabbitMQ的基本原理。有一件事我发现发布者不会直接在队列上发布。exchange根据routing-key和exchange类型决定消息应该在哪个队列上发布(下面的代码使用默认交换)。我还找到了publisher的示例代码。pdfprocess', body='User information')connection.close()
在第9行中</em
浏览 5提问于2021-02-24得票数 0
回答已采纳
1回答
在兔子MQ中，是否存在与活动MQ虚拟主题相同的内容？或者任何其他机制都可以实现队列语义。一些主题订阅者需要在返回联机时传递持久消息，并进行负载平衡。编辑作为一个简单的例子，每当用户登录失败时，主应用程序就会发布一条消息。其中一个侦听器为每次登录失败发送一封电子邮件，而另一个
浏览 3提问于2015-07-22得票数 2
回答已采纳
我定义了一个主题交换(警报)和多个队列，每个队列都有自己的路由密钥：
allAlarms队列中</em
浏览 8提问于2015-08-20得票数 0
我对关于使用队列和交换的RabbitMQ最佳实践感到有点困惑。假设我想为发票提供一些数据的GenerateInvoice消息，让多个消费者处理发票数据并生成一个PDF。每个GenerateInvoice只应由一个使用者处理。
一种方法是声明一个队列并将GenerateInvoice消息发布到这个队列中，并让所有消费者从这个<em
浏览 0提问于2019-01-15得票数 0
回答已采纳
1回答
我能够使用 RabbitMQ Java教程创建扇出交换，并且任何连接的消费者都将收到一份消息副本。我希望在连接任何使用者之前创建交换和绑定，而不是以动态/编程的方式声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而，由于某些原因，我的消费者正在以循环方式接收消息，而不是所有接收消息的副本。我遗漏了什么？以下是一些代码片段：channel.basicPublish("public&q
浏览 1提问于2013-03-11得票数 8
回答已采纳
2回答
目标是让每台机器接收发送到单个RabbitMQ交换的每条消息。这在本地可以正常工作，但是当我们使用多台机器时，似乎一次只有一台机器接收消息。这一点得到了一个古老的答案的证实。
我有几个
浏览 1提问于2019-05-30得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
