我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息 configurator.ReceiveEndpointcfg.ConfigureConsumer<MyConsumer>(context); });
因此，当我启动我的应用程序时，我在兔子管理UI中只看到一个使
浏览 22提问于2021-05-31得票数 0
回答已采纳
在Rabbitmq中，一个具有多个通道的单个线程可以消费来自单个队列的消息，并将同一消息消费两次吗？我们有从以前的开发人员传递的代码，该开发人员在一个似乎在队列中找到重复消息的库中。但是，当使用具有单个通道的简单单个使用者使用同一队列时，很明显队列中没有重复的消息。这引起了一些激烈的<
浏览 4提问于2017-01-17得票数 3
我用皮卡为蟒蛇与RabbitMQ沟通。我有6个线程，它们使用和确认来自同一个队列的消息。对于每个线程，我使用不同的连接(和通道)。在重新连接之后，我将以相同的顺序接收相同的未确认消息，或者它将开始在所有线程之间重新分发它们，还是从重新连接点开始？这在我的应用程序中很重要，因为在消息接收和确认之间存在延迟，我希望在接下来的过程中避免重复。
浏览 3提问于2015-09-16得票数 3
回答已采纳
我有一个关于RabbitMq消费者确认的查询，我阅读了RabbitMq上的文档，声明确认消息应该在消费者接收到的同一个通道上。但是，由于某种原因，在收到消息之后，由于某种原因消费者进程被停止，并且没有确认Rabbitmq，当消费者进程重新启动时，消费者开始从RabbitMq获得未被确认的消息，
浏览 3提问于2018-11-22得票数 0
我负责维护一个用Golang编写的生产软件，它使用RabbitMq作为消息队列。
对于所有信道，autoAck、exclusive和noWai
浏览 0提问于2018-01-23得票数 2
1回答
在要求后保持交货顺序
、、、、
我正在开发一个使用兔子MQ进行消息传递的应用程序。我使用显式ACK：并在处理消息后执行ACK： throw; };
问题是，当处理消息时出现错误，而兔子没有接收到ACK时，它会以不同顺序的
浏览 2提问于2017-02-15得票数 3
我有一个队列和两个消费者c1和c2。我的两个消费者已经启动并运行。当消息发布到队列时，JMS broker (RabbitMQ)如何确保该消息只由一个使用者使用？
浏览 9提问于2021-01-28得票数 0
如果我有一个RabbitMQ使用者批量检索100条消息，但在将这些消息标记为已处理之前就会崩溃，那么这些消息是否丢失了？我希望队列中的每条消息至少处理一次。在确认消息之前，有什么推荐的方法来处理那些崩溃的消费者？
RabbitMQ是否以某种方式将它们重新放到了队列中，或者我需要做些什么来实现它呢？
浏览 8提问于2017-02-21得票数 11
1回答
我正在阅读关于狂犬病Channel.basicCancel手术的文档，。docs说，可能的取消情况之一是当使用者在它正在监听的同一频道上发送取消信号时。我试图从另一个进程发送取消请求。当我这样做时，它以一个异常结束，java.io.IOException: Unknown consumerTag就像这样的操作被限制在取消本地使用者(在自己的通道</em
浏览 0提问于2018-06-21得票数 3
回答已采纳
我的系统如下所示：我有N个消息生产者，N个RabbitMQ实例，N个消息使用者和1个服务。生产者产生相同的消息，而消费者使用相同的消息。这就是问题所在。使用者必须就谁调用服务API达成一致，因为使用相同的消息两次调用服务API会导致错误。我不知道消费者怎么能决定谁打电话给服务。
我有一些想法。我们可以创建一个RabbitMQ集群(使用一个检
浏览 0提问于2019-11-05得票数 1
我需要在多个消费者上实现顺序消息处理，但每次在队列上只有一条消息。我有很多队列，但它们都是连续的，我需要多个使用者支持负载平衡和冗余。任何人都能判断将未确认消息的数量限制为每个队列1是真实还是不真实的？
浏览 0提问于2016-05-04得票数 0
使用RabbitMQ，有没有一种方法可以将消息从队列“推送”到消费者，而不是让消费者“轮询并从队列中提取”消息？
这已经引起了一些关于我正在做的项目的争论。一方的论点是，让消费者(即，windows服务)在新消息到达之前“轮询”队列在某种程度上是低效的，并且比使消息从队列自动“推入”到订户/consumer(多个)的想法更不可取。我似乎只能找到支持<em
浏览 1提问于2014-10-23得票数 17
我在Micro CloudFoundry中部署了两个Spring MVC应用程序，一个是通过topic Exchange读取文件并向RabbitMQ中的队列发送近3325条消息，另一个是在异步MessageListener的帮助下使用这些消息。问题是，监听器在没有任何序列的情况下获取消息。我认为监听程序至少有两个线程同时运行。我尝试打印OnMessage()方法中的消息序列，如下所示。消息不在序列中，例如12、13、
浏览 0提问于2013-01-30得票数 1
每个通道都有自己的通道(IModel)，每个通道都有自己的EventingBasicConsumer，当EventingBasicConsumer.Received被触发时，我们最终会处理消息。下表描述了我们在为跨多个队列的消息分配多个通道方面所观察到的情况：
一旦Message5用C1在30秒后完成，那么Messaqe9立即被分配给C1，并且在Message
浏览 1提问于2019-05-30得票数 1
回答已采纳
2回答
我的应用程序将消息发送到RabbitMQ exchange，然后exchange将消息重定向到绑定队列。我使用Springframework AMQP java插件和RabbitMQ。问题:消息进入队列，但它停留在“未确认”状态，它永远不会变成“就绪”。
可能的原因是什么？
浏览 0提问于2012-08-13得票数 24
回答已采纳
4回答
我正在编写一个简单的类，我的应用程序将使用它通过RabbitMQ发送和接收消息。我已经阅读了尽可能多的关于RabbitMQ的操作指南、博客文章、白皮书和类似的东西。大多数示例都将连接和通道包装在using块中，并指出您可能应该将它们实现为单例，这与之相矛盾。具体地说，关于通道，我看到有评论说，不应该有超过一个线程同时使用一个通道。
我正在用C#编写我的库。我考虑过对通道执行相同<e
浏览 2提问于2011-04-16得票数 16
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
我已经创建了一个具有20个内核的指定线程池的连接。虽然我发现虽然可以使用线程来使用消息，但始终只有一个线程在使用消息，即使消息在服务器中大量积累。这是令人困惑的，因为使用者被绑定到一个通道，并且在最后一个任务块完成之前，通道不会释放到队列中，这意味着线程池总是只为该使用者提供一个线程。问题：
我们如何优化这个问题？将任务提交到handleDelivery中的独立线程池以同时
浏览 2提问于2017-08-01得票数 1
想知道rabbitmq多个发布者和消费者的行为。rabbitmq服务器一次只给任何一个消费者一条消息，而其他消费者在那个时候是理想的吗？或基本上，我正在设计一个数据库队列，不希望一次插入一个以上。
浏览 0提问于2010-12-05得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
