许多消费者到manu队列。一个使用者对应RabbitMQ中的多个队列
RabbitMQ是一个开源的消息队列中间件，它实现了高效的消息传递机制，可以在分布式系统中进行异步通信。在RabbitMQ中，一个使用者可以对应多个队列。
概念： 消息队列（Message Queue）是一种应用程序间通信的方式，它将消息发送者和消息接收者解耦，通过消息队列来传递消息。消息队列中的消息可以按照一定的规则进行存储和转发，实现了异步通信和解耦的目的。
分类： RabbitMQ是基于AMQP（Advanced Message Queuing Protocol）协议的消息队列中间件，支持多种消息模式，包括点对点模式和发布/订阅模式。
优势：
- 解耦性：使用消息队列可以将消息发送者和接收者解耦，提高系统的可维护性和可扩展性。
- 异步通信：消息队列可以实现异步通信，发送者无需等待接收者的响应即可继续处理其他任务，提高系统的并发性能。
- 可靠性：消息队列可以提供消息持久化、消息确认机制和消息重试机制，确保消息的可靠传递。
- 削峰填谷：消息队列可以平衡系统的负载，将高峰时段的请求暂存到消息队列中，避免系统过载。
- 扩展性：通过增加消息队列的消费者节点，可以实现系统的水平扩展，提高系统的处理能力。
应用场景：
- 异步任务处理：将耗时的任务放入消息队列中，由消费者异步处理，提高系统的响应速度。
- 应用解耦：将不同模块之间的通信通过消息队列进行解耦，提高系统的可维护性和可扩展性。
- 流量削峰：将高峰时段的请求暂存到消息队列中，避免系统过载。
- 日志处理：将系统的日志消息发送到消息队列中，由消费者进行处理和存储。
- 分布式系统：在分布式系统中，使用消息队列进行异步通信，实现不同节点之间的数据交换。
推荐的腾讯云相关产品： 腾讯云提供了消息队列服务TencentMQ，它是基于RabbitMQ的托管式消息队列服务，具备高可靠、高可用、高性能的特点。您可以通过TencentMQ快速搭建消息队列系统，实现异步通信和解耦。
产品介绍链接地址：TencentMQ
相关·内容
我试图将消息发布到队列中，然后让特定的使用者只在它包含某个标头时使用它，如果它包含另一个标头，则让另一个使用者使用它。
到目前为止，我所做的是设置一个头-exchange，它只在包含消息头的情况下将消息路由到特定的队列。
这是我用来设置exchange、队列和侦听器的配置：
<!-- Register Queue Listener Beans -->
<bean id="ActionMessageListener" class="com.mycee.Action" />
<!-- Register RabbitM
浏览 3提问于2014-08-25得票数 2
回答已采纳
我希望在RabbitMQ中的队列中有这个约束：
队列中的下一条消息不能在前一条消息(正在处理的消息)被添加之前退出队列。
通过这个，我将实现事件的有序处理和跨多个队列的并行处理。如何为此配置RabbitMQ？
编辑(澄清)：将有许多消费者都试图从所有队列中获得工作，而且由于他们无法从一个队列中获得工作，而该队列中有一个事件正在被处理，而这个队列并没有被执行--有序处理是被维护的。
浏览 4提问于2015-09-07得票数 3
回答已采纳
1回答
我知道在主题交换中实现循环行为可能是棘手的，也可能是不可能的，所以我的问题是，我的问题实际上是，我是否可以从RabbitMQ中看出什么，或者把目光转向其他支持它的消息队列。
以下是我的应用程序需求的详细说明：
将有一个制片人，让我们称之为P
可能会有成千上万的消费者，让我们称他们为Cn
每个使用者可以“订阅”一个或多个主题交换，多个使用者可以订阅同一个主题。
发布到主题中的每一条消息只应由一个使用者使用。
用例#1
假设：
主题
foo.bar
foo.baz
消费者
使用者C1订阅主题#
使用者C2订阅主题foo.*
使用者C3订阅主题*.
浏览 4提问于2017-07-14得票数 2
我正在使用Spring 和RabbitMQ。
使用RabbitMQ启动码头后：
sudo docker run -t -i --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
我执行了发行者和订阅者应用程序的示例来观察消息的行为。
我在管理面板()中注意到的一件事是，在启动订阅服务器时创建的队列被配置为auto-delete: true。因此，当没有订阅服务器运行时，队列就不会创建，发布者发送的每一条消息都是丢弃的。这不是我所期望的默认配置！
因此，我想将创建的队列更改为auto-delete: false，因为这
浏览 2提问于2018-02-15得票数 1
回答已采纳
1回答
我能够使用 RabbitMQ Java教程创建扇出交换，并且任何连接的消费者都将收到一份消息副本。我希望在连接任何使用者之前创建交换和绑定，而不是以动态/编程的方式声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而，由于某些原因，我的消费者正在以循环方式接收消息，而不是所有接收消息的副本。我遗漏了什么？以下是一些代码片段：
出版商：
channel.basicPublish("public", "", null, rowId.getBytes("UTF-8"));
消费者：
QueueingConsumer consumer
浏览 1提问于2013-03-11得票数 8
回答已采纳
我有一个发布者，它将消息发布到rabbitmq://localhost/test123队列中。一个消息具有TestMessage类型，另一个TestMessage2类型。
Publisher配置：
sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { }));
sbc.UseLog4Net();
sbc.UseJsonSerializer();
sbc.EnableMessageTracing();
sbc.ReceiveFro
浏览 9提问于2017-07-07得票数 0
回答已采纳
最近，我开始使用和RabbitMQ绑定。
如果当两个服务想要传递消息时，我正确地理解了一切，那么一个应该配置发送消息的源，另一个应该配置接收器来接收消息--两者都应该使用相同的通道。
我有个频道叫testchannel。不过，我注意到该源代码创建了RabbitMQ绑定：
交换testchannel，
路由密钥testchannel
队列testchannel.default (持久的)，
接收器创建了RabbitMQ绑定：
交换testchannel，
路由密钥#
队列testchannel.anonymous.RANDOM_ID (执行)。
为了简洁起
浏览 3提问于2016-02-05得票数 3
回答已采纳
我有一个RabbitMQ设置，在这个设置中，作业被发送到一个交换，后者将它们传递给一个队列。消费者依次正确地执行队列中的作业。然而，这些作业是很长的过程(至少几分钟)。为了实现可伸缩性，我需要让多个使用者从队列顶部选择一个作业并执行它。
消费者正在一个名为“队列”的Heroku dyno上运行。当我缩放dyno时，它似乎为每个dyno创建了额外的使用者(我可以在RabbitMQ仪表板上看到这些)。但是，队列中的任务数量保持不变--额外的使用者似乎什么也不做。请看下面的图片，了解我的设置。
我是不是漏掉了什么？
为什么消费者表现为“懒散”呢？我从日志中了解到，至少有一个用户正在积极
浏览 5提问于2020-01-11得票数 0
回答已采纳
1回答
我试图弄清楚，即使在没有使用者运行的情况下，是否也可以将消息存储在RabbitMQ交换中。
我理解(可能是错误的)要实现交换需要“持久”，以及队列和消息需要用“持久”标志发送出去。
'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT
我的主要目标是将所有消息存储在交换中，以便在出于任何原因没有消费者运行的情况下，当我启动一个消息时，交换中的所有消息都可以被定向到绑定队列。我宣布我的交换和队列如下：
//Sender.php
public function sendToQueue(ActionMessage $m
浏览 1提问于2019-03-22得票数 3
2回答
RabbitMQ队列设计和扩展
、、、、
在我的应用程序中，我有一个可能会变得非常大的队列。如果我发现我的机器上没有更多的空间，该怎么办？如何在多台机器上拆分队列？也许RabbitMQ的理念是不同的，我应该创建多个队列而不是一个大队列。
最佳，弗拉维奥
浏览 1提问于2013-07-19得票数 6
我对RabbitMQ中的这两种类型的消息感到困惑。
我已经看到，我的一些队列有0个“未确认”和1000个“就绪”消息，而另一些队列有1000个“未确认”和0个“就绪”消息。
它们之间的区别是什么？
我如何知道消费者读取了多少消息？
浏览 1提问于2015-08-10得票数 101
回答已采纳
我正在尝试通过RabbitMQ分发一条包含许多任务的消息：
Producer --> RabbitMQ Exchange --> 10 Consumers
例如:用户向交换机发送包含1000个任务的消息。交换机需要将任务均匀地分配给队列最短的消费者。
由于生产者不了解RabbitMQ中使用的排队机制，因此交换需要一些自定义逻辑来将订单拆分成任务并将它们分发给消费者队列。
这是怎么做的？(我在生产者和消费者上都使用Python/Pika。)
浏览 2提问于2016-07-02得票数 0
我和我的同事讨论了RabbitMQ的设计，Server A和Server B之间，下面是流程图。
Server A通过exchange A和Queue B向Server B发送消息，并通过Queue A接收来自Server B的消息。反之亦然，对于Server B。
Server A中有两个用C++实现的类:一个是sender，另一个是receiver。对于用Server B实现的JavaScript，也有相同的代码结构。
sender和receiver在Server A。我同事的想法是：
发件人中的初始化：
创建与rabbitmq的连接
声明exchange A
声明
浏览 1提问于2015-07-21得票数 7
我正在尝试同步我拥有的三个微服务。
为了做到这一点，我实现了RabbitMQ。现在似乎一切正常，但我不确定我是否在遵循最佳实践，我找不到参考资料来查找它，也许有人能帮我做这件事？
简要介绍我要做的事情：我有一个服务应该更新另外两个，每个服务都应该接收发送的消息。我有两种类型的消息(保存和删除资源)。*在出现错误时，队列应恢复并重新发送消息。
我正在做的事情：，我已经设置了一个交换，我的每个使用者连接到两个不同的队列，每种类型的消息(保存/删除)一个。我已经使用了一个直接的交换来过滤以后的消息，即使目前我不需要过滤它们。
每个队列都是命名的，交换和消息都是持久的，我正在添加我使用过的消息。
问题
浏览 4提问于2016-07-11得票数 3
回答已采纳
1回答
我正在将事件驱动的体系结构移植到容器环境(Docker)，我想知道如何在使用pub-sub时利用复制的优势:如果我只是增加副本，我就会得到许多进程进行同样的精化，我认为这不是一个好方法。我想用生产者-消费者取代pub-sub，所以消费者等待队列中的事件，只有一个人抓住它，但我想避免紧密耦合。
是否有“负载平衡”发布-订阅的解决方案？此外，商业工具可以检查。
浏览 0提问于2019-09-17得票数 4
3回答
我的团队正在讨论如何使用RabbitMQ来进行微服务通信(除其他外)。我们还支持SAP后端，该后端将以目前尚未确定的方法(可能通过Boomi或Idocs)将数据推送给我们。我们对RabbitMQ几乎一无所知，除了消息队列的一般概念，以及我们能够从高层查看它们的文档时能够确定的内容。一般模式似乎是用户订阅了一个或多个队列，而兔子基于高度可配置的规则推送到这些队列，但是单个队列上的消息在被删除之前只被完全读取一次(这是一个泛化，因为关于确认和内容有很多选项)。
这是一个非常简单的设置图像，每个消费者只关心他们的不同主题：
📷
然而，这是一个更复杂的问题，其中一个主题被分割成多个队列。然而，当我们配
浏览 0提问于2018-08-17得票数 8
在RabbitMQ中有任何方法可以让多个消费者从同一个队列中获得相同的消息吗？
我需要发送同样的信息给任何正在倾听的人，但也要确保有人处理它。基本上，我需要交换的扇出功能与队列的basic.ack功能相结合。是否有任何方法可以以可伸缩的方式完成这一任务？
浏览 4提问于2013-10-15得票数 4
我们运行多个并发的RabbitMQ使用者，每个使用者在一个循环中执行“basicGet”。我们看到，单个消费者获得了大部分消息。有没有办法在所有消费者之间更均匀地传播信息？基本上，我们可以以某种方式中断为第一个客户提供服务的RabbitMQ，并切换到下一个客户。注意:必须拉取消息(basicGet)，不能切换为推流(basicConsume)，谢谢。
浏览 1提问于2016-05-31得票数 1
1回答
我有两个关于狂犬病消费者(接受者)的问题：
我如何定义(静态地从队列中)注册到某个队列的使用者是什么，以便如果有一个使用者下线，消息仍然会在该使用者再次上升之后被传递，或者有其他方法来实现这一点？
消费者如何连接到一个仍未创建的队列，在rabbitmq教程中，我可以在生产者之前给消费者打电话，它仍然能工作，有人能解释一下这是如何工作的吗？
谢谢
浏览 1提问于2016-06-23得票数 0
回答已采纳
如果我有一个RabbitMQ使用者批量检索100条消息，但在将这些消息标记为已处理之前就会崩溃，那么这些消息是否丢失了？我希望队列中的每条消息至少处理一次。在确认消息之前，有什么推荐的方法来处理那些崩溃的消费者？
RabbitMQ是否以某种方式将它们重新放到了队列中，或者我需要做些什么来实现它呢？
浏览 8提问于2017-02-21得票数 11
1回答
我正在尝试用RabbitMQ实现一个任务分发系统。我从本文中的代码开始： --有一个头交换，多个消费者队列被用不同的头值绑定到它。
每个消息(任务)都有一个标头"env“，指定要在其中运行任务的环境。将来可能有必要根据更多的头做出决定。使用者可以提供多个环境，所以我用不同的标头值多次将其队列绑定到报头。
这样，我可以设置两个消费者A和B。A提供环境"foo“和"bar”，而B只提供"bar“。现在，当一个需要环境"bar“的任务被交付给A和B时，但是我只想把它传递给其中的一个(哪一个并不重要)。
看起来，当消息发布时，如果消息与多个使用者的头相匹配，就会
浏览 3提问于2015-11-17得票数 2
回答已采纳
我的场景:我希望我的应用程序将日志发布到RabbitMQ，让另一个进程使用这些日志并写入DB。此外，即使目前没有使用者，日志也应该在RabbitMQ中持久存在。但是，使用我现在的代码，除非启动使用者，否则我的日志不会在RabbitMQ中显示。我做错了什么？
我的代码：
var amqp = require('amqp');
var connection = amqp.createConnection({
host: "localhost",
port: 5672
});
connection.on('ready', functi
浏览 0提问于2014-03-13得票数 3
回答已采纳
我计划为我们的系统实现一个message，并且大部分已经决定使用RabbitMQ。但是，我需要知道，使用RabbitMQ是可能的。
为对象O生成2条消息
1) A(创建O对象)，
B (更新同一个O对象).
在客户端(多个消费者)注册到队列以获取对象O的消息的，我希望B只在A被添加之后才被传递。
目标--为对象O处理创建，然后为该对象处理更新。
浏览 1提问于2015-11-18得票数 0
我有一个rabbitmq集群用作工作队列。有5种消费者想要使用完全相同的数据。
我现在知道的是使用扇出交换将数据“复制”到5个不同的队列中。而这5个消费者可以使用不同的队列。这有点浪费资源，因为文件队列中的数据是相同的。
我的问题是，rabbitmq是否支持将相同的数据推送给多个消费者？就像一条消息需要在指定的时间内被加加才能被删除。
我从电子邮件组得到了以下答案。简而言之，答案是否定的..。我以上所做的是正确的方法。
浏览 0提问于2014-06-12得票数 0
回答已采纳
我有一个可以水平缩放的API。API将确认客户端请求，并需要将工作分派到辅助系统。辅助系统需要以先到先服务的方式处理工作，即队列。此外，由于辅助系统正在访问可以共享的资源，因此在给定时间内只能有一个实例处于活动状态。辅助系统需要具有故障转移机制。如果辅助系统的第一个实例宕机，则需要另一个实例来取代它。
我在考虑使用RabbitMQ作为排队机制，让多个消费者连接，但只有一个活跃的消费者来处理工作。如果先前活动的使用者未能确认消息，则其他实例中的一个将接管处理消息的工作。使用RabbitMQ可以做到这一点吗？
另外，是否可以仅在作业完成后确认该消息？
谢谢。
浏览 1提问于2015-08-17得票数 11
1回答
我正在开发一个Qt5服务器应用程序，并使用QAMQP库。我想做的是：
当用户发生变化时，另一台服务器应该发送消息。
我的服务器分布在多台机器之间，每台机器都有多个进程，需要将这些更新通知服务器。
问题是，我不确定我应该建立什么样的架构。我只知道，每当某些用户发生更改时，服务器需要向RabbitMQ代理发送一条消息，而我对该特定用户的更新感兴趣的所有进程都应该得到该消息。但是，我应该为每个进程创建一个队列，并为每个用户绑定一个单独的交换吗？或者在每个进程中为每个用户创建一个单独的队列，并以某种方式绑定到某个交换中。Fanout交易所浮现在脑海中，每个进程都有一个队列，我只是不确定
浏览 2提问于2014-01-25得票数 0
回答已采纳
1回答
我在spring中构建了一个消息驱动的服务，它将在集群中运行，需要以循环的方式从RabbitMQ队列中拉出消息。该实现目前以先到先得的方式将消息从队列中拉出，导致一些服务器得到备份，而其他服务器则处于空闲状态。
当前的QueueConsumerConfiguration.java如下所示：
@Configuration
public class QueueConsumerConfiguration extends RabbitMqConfiguration {
private Logger LOG = LoggerFactory.getLogger(QueueConsumerConfigura
浏览 37提问于2016-07-21得票数 3
回答已采纳
我遇到了一个问题，就是在RabbitMQ中的共享队列中发布大约20条AMQP消息时，会在其他用户收到消息之前被批量延迟。我的应用程序拓扑有三个端点：
第一个端点将生成一批消息，每个消息都包含网络设备的FQDN，以便收集配置文件。将有此端点的一个实例，并且是称为net.svc.ssh.The第二个端点的直接队列的唯一发布者将使用其中一个消息，SSH进入指定的网络设备，运行一个CLI命令，并将结果从每个设备发布到另一个队列。这个端点将有多个实例，所有这些实例都使用net.svc.ssh并发布到net.svc.ssh，第三个端点将接收该结果并将其保存到它自己的单独文件中的本地磁盘中。此实例是net.
浏览 0提问于2012-01-13得票数 1
我在OpenShift上运行了一个MQTV3.6.10实例，并启用了RabbitMQ插件。我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。这是我为连接到RabbitMQ队列而编写的代码：
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName(username);
options.setPassword(pass
浏览 1提问于2017-11-24得票数 0
我们有三种不同类型的对象: 1. ObjectA 2. ObjectB
我们需要将这些对象信息发送到三个不同的API :1.api A-我们只需要发送ObjectA。2. API b-我们只需要发送ObjectB。3. API我们需要发送ObjectA和ObjectB。
由于这些对象将以非常高的频率推送到我们的系统，并且需要异步处理，所以我们决定使用rabbitmq将这些对象推送到相应的API中。
我们有两个选择：
创建一个使用者:对象将被推送为NameValueCollection，如果它的ObjectA，推到API A和API AB。如果是ObjectB，则将其推送到API和API。
浏览 3提问于2017-04-27得票数 0
回答已采纳
1回答
在这个php库的帮助下，我正在使用，现在我的代码以如下方式工作:每个队列都有单独的类来添加新的消息到队列中，以及单独的队列工作者，例如: SmsQueue和SmsWorker。我从cron运行队列工作者(例如SmsWorker)，问题是只有当它还没有运行时，我才想运行它。我认为RabbitMQ有一些方法可以查看当前是否有活跃的队列使用者，但我找不到它。这里的解决方案是什么，我做得对吗？
我刚刚开始使用RabbitMQ，如果这是个愚蠢的问题，我对此不太了解。
浏览 1提问于2016-11-29得票数 0
2回答
我的应用程序将消息发送到RabbitMQ exchange，然后exchange将消息重定向到绑定队列。我使用Springframework AMQP java插件和RabbitMQ。
问题:消息进入队列，但它停留在“未确认”状态，它永远不会变成“就绪”。
可能的原因是什么？
浏览 0提问于2012-08-13得票数 24
回答已采纳
与类似，我们有FIFO队列，消息必须按顺序处理。我们希望竞争来自不同机器的消费者，因为冗余和性能原因，但是只有一台机器上的一个使用者应该一次处理给定队列的消息。
我试着将预取计数设置为1，但我相信只有在一台机器上才能使用。在默认情况下，这在RabbitMQ中是可能的还是我们需要实现自己的锁？
浏览 1提问于2018-11-20得票数 2
回答已采纳
1回答
带Vue JS的RabbitMq
、、、、
我尝试使用rabbitMq来处理来自前端的消息，我已经有了rabbitMq和(AMQP)。我在rabbitMq中搜索Vue-Js或JavaScript，但没有找到任何有用的信息。
那么我如何使用javaScript/vue-Js从rabbitMq中消费呢？
谢谢。
浏览 1提问于2020-02-28得票数 0
在我的系统中，我使用spring-cloud-stream和RabbitMQ来发送和接收事件。我的RabbitMQ运行，服务A up和服务B停机。服务A向服务B发送事件。然后我打开了我的服务B，现在我希望兔子会对这一事件感到高兴--但什么也没发生。行为正确吗？我是RabbitMQ的新手，但我认为它应该保证所有事件最终都能找到它的接收者。我的应用程序很简单，基于，没有额外的配置。我错过了什么？
浏览 1提问于2017-12-12得票数 0
回答已采纳
这似乎是一个简单的问题，但我很难找到一个明确的答案。如果在RabbitMQ 3.6.1中有一个如下所示的队列：
5 4 3 2 1 <= head
我使用信息1，然后做：
channel.BasicReject(ea.DeliveryTag, true);
1最终是在队列的末尾还是在队列的顶端(为了简单起见，假设当时没有其他人在使用队列)？所以我最后会：
1 5 4 3 2 <= head
或者：
5 4 3 2 1 <= head
还有控制它的方法吗(一种方法是对消息进行加密并重新发布，我想是这样的)？实际上，我需要第一种情况，因为我拒绝1，因
浏览 2提问于2016-06-08得票数 12
回答已采纳
我在春季引导应用程序中使用了rabbitmq。我正在使用aws ecs进行部署。现在假设我的服务正在运行多个实例。和rabbitmq监听订单创建是通过直接交换注册的。那么下订单后会发生什么呢？我的两个服务实例会得到相同的消息吗？如果是，如何防止在这两个侦听器上重复消息？
浏览 0提问于2019-01-23得票数 3
回答已采纳
2回答
我有以下问题:我有一个RabbitMQ集群、一个消息生成程序和一个消费者集群(用于高可用性)。每当消费者收到消息时，它就会根据消息内容生成另一个进程并运行它。这个过程很长，大约需要30分钟。
我必须确保一次只处理一个消息。但是，有比一个更多的消费者，所以如果一个队列中有两个消息，一个消费者得到一个消息，另一个消费者得到另一个消息，并且它们被并行处理。
供参考:每个使用者驻留在不同的机器中。
在RabbitMQ级别上是否有任何机制允许我在使用下一条消息时等待，直到上一条消息是ACKed？还是我必须在服务器之间建立某种锁定机制？
浏览 2提问于2017-12-06得票数 4
回答已采纳
我有node.js服务器，它也是一个rabbitmq使用者。我希望将我的应用程序扩展到多个实例，但只保持消费者活动。我该怎么做呢？
谢谢
浏览 2提问于2017-09-11得票数 0
我正在学习https://www.rabbitmq.com/tutorials/tutorial-one-python.html上的教程 我已经使用docker设置了RabbitMQ。在那里定义了交换，等等。 管理UI显示创建的exchange。当第一次执行发送者脚本时，队列也会显示在UI中。 我首先运行消费者&然后是发布者。但是，当消息被发布时(假设消息已经发布，因为send脚本没有抛出任何错误)，消费者不会收到任何消息。我可以看到AMQP连接被正确地建立和关闭(在发布者的情况下)。但是队列是空的。 管理UI还显示一个空队列。我尝试使用UI本身发布持久和非持久消息，但即使在那里，当
浏览 257提问于2021-10-24得票数 0
我开发了简单的Grails服务，它使用Grails RabbitMQ插件并将消息发送到队列。
Grails - Config.groovy
queues = {
exchange name: 'my.topic', type: topic, durable: false, {
foo durable: true, binding: 'test.#'
}
}
在我的Java桌面应用程序中，我尝试使用Spring来听这条消息
Main.java
public static void main(String[] args) {
浏览 6提问于2014-10-17得票数 0
2回答
我正在构建一个记录桥，在rabbitmq消息和Django应用程序之间存储后台任务状态，以便进行进一步的调查/检查，并使通过Django管理界面重新发布任务成为可能。我想这没什么特别的，只是一个标准的生产者-消费者模式。
databaseConsumer，Web应用程序发布到消息队列，并将初始任务状态插入到单独的进程中，处理消息并根据任务输出更新任务状态。
问题是，有些任务在db中丢失，因此从未执行。我怀疑这是因为使用者在执行db提交之前就收到了消息。因此，基本上，从Model.save()返回并不意味着事务已经结束，整个通信中断。
我有办法解决这个问题吗？也许我需要某种post_transa
浏览 2提问于2010-06-14得票数 0
我一直在使用rabbitMQ学习AMQP，我遇到了一个叫做扇出交换的概念。从图解图中，我所看到的只是某种负载平衡器。有人能解释一下它的实际用途吗？
浏览 3提问于2016-12-22得票数 1
回答已采纳
我正在尝试看看，如果队列中的消息达到队列的大小或我在rabbitmq中指定的特定限制，是否可以让我的rabbitmq启动另一个worker，而不是监视队列并启动worker manually.Any的另一个实例。
浏览 1提问于2016-11-26得票数 1
1回答
据我所知，您可以使用channel.sendToQueue直接向队列发送消息，这会造成任务和工作人员的情况，在这种情况下，只有一个使用者将处理每个任务。
我还了解到，您可以在基于主题的交换中使用channel.publish，并且消息将根据路由密钥路由到队列。但据我所知，这将始终在任何匹配队列上向所有订阅者广播。
基本上，我想使用基于主题的交换，但每个任务只有一个使用者处理。我已经看过文档了，我看不出有什么方法可以做到这一点。
我的用例：
我在多个地点设置了一个微服务实例。加州可能有两个，伦敦有三个，新加坡有一个等等。当任务创建时，唯一重要的是它是由给定地点的一个实例处理的。
当然，我可以创建
浏览 4提问于2021-01-23得票数 0
2回答
我们有多台后端机器。目标是让每台机器接收发送到单个RabbitMQ交换的每条消息。
FooExchange设置为fanout (因此它向连接到它的所有队列发送一条消息)。FooExchange有一个队列，FooQueue，它被绑定到它。我们所有的机器都是FooQueue的消费者。
这在本地可以正常工作，但是当我们使用多台机器时，似乎一次只有一台机器接收消息。它接收消息，特别是1次/不管有多少台机器。这一点得到了一个古老的答案的证实。
我有几个问题：
在每台机器上创建一个队列是最好的方式吗？
“机器”实际上将是K8S吊舱--在队列名中，我应该使用什么作为唯一的机器标识符？还是让它实例化一
浏览 1提问于2019-05-30得票数 0
回答已采纳
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？
RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
我遇到了一个问题，我在共享模式下设置了一个队列，并将多个使用者绑定到它。问题是rabbitmq似乎正在序列化消息，也就是说，一次只有一个使用者能够运行。我需要这个是并行的，然而，我似乎想不出怎么做。
每个使用者都在自己的进程中运行。队列中有很多消息。我使用py-amqplib与RabbitMQ接口。
有什么想法吗？
浏览 0提问于2010-05-09得票数 2
是否有一种方法可以限制RabbitMQ队列只将固定数量的消息从队列发送给消费者？
我有两个队列Q1和Q2，10个consumers.Every使用者可以处理来自Q1和Q2的消息，在任何给定的时间，只有两个消费者应该处理来自Q2的消息，所有这10个消费者都可以同时处理来自Q1的消息。
在RabbitMQ中是否有我们可以指定的配置，以便RabbitMQ只将2条消息从Q2推送给任何空闲的使用者，并且只有在它们被确认之后才将下一条消息推送到下一条消息中，即使其他消费者是免费的，并且可以使用。
关于这一问题的更多背景资料：
为什么每次只处理2条消息？：Q2消息正在进行web服务调用，web服务端点(第三
浏览 0提问于2019-03-09得票数 1
回答已采纳
对于RabbitMQ非常陌生，我正试图看看我是否能够用它来实现我所需要的。
我正在寻找工人排队模式，但有一个警告。我希望每个路由密钥只有一个工作人员并发运行。
一个需要澄清的例子：
如果我按顺序发送以下带有路由密钥的消息：a、a、b、c，我希望只有3个工作人员同时运行。当接收到第一条a消息时，工作人员会将其捡起并处理。
当接收到下一条a消息并且仍然处理(未确认)之前的a消息时，新的a消息应该在队列中等待。当接收到b和c消息时，它们都会得到一个处理它们的工作人员。当第一个a消息被确认时，任何工作人员都可以接收下一个a消息。
该模式是否可能以一种自然的方式使用RabbitMQ (而不需要在我这边编
浏览 2提问于2016-08-14得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
