我想要一个场景，有许多消费者监听新消息并处理它们。当消息不为空时，消费者应该始终在监听和处理消息。这是我写的代码： { using (var channel = connection.CreateModel())
queueMessage = queue.getQueue("myQ
浏览 110提问于2017-08-08得票数 0
我们最近经历了由RabbitMQ驱动的应用程序的意外行为。RabbitMQ版本为3.6.12，我们使用的是.NET客户端5.0.1
应用程序订阅两个队列，一个用于命令，另一个用于事件--我们还使用手动确认。我们的应用程序被配置为有7个使用者。每个通道都有自己的通道(IModel)，每个通道都有自己的EventingBasicConsumer，当EventingBasicConsumer.Received被触发时，我们最终会处理消息。当多个消费者订阅多个队列时，RabbitMQ是否可以分配一条消息，以便在当前空闲的消费者的情
浏览 1提问于2019-05-30得票数 1
回答已采纳
2回答
我正在通过我的web应用程序向rabbitMQ服务器发送一些值，这很好，我把它放在一个队列中，但是当移动应用程序接受请求时，我无法得到返回的值。RuleRabbitMQ.RequestAccepted(); } {
} {
throw new ArgumentException($"Thre w
浏览 0提问于2018-06-19得票数 0
回答已采纳
我使用Azure函数将消息从Rabbit MQ代理获取到Event Hub。下面是该函数的代码：using System.Dynamic;using CaseOnline.Azure.WebJobs.Extensions.Mqtt;using Microsoft.Azure.WebJobs;
using Newtonsoft.Json;
浏览 0提问于2021-04-27得票数 0
在此示例中，我需要通知C#应用程序已将新记录插入到队列表中。我已经阅读了许多关于Service Broker的文章，这似乎是一个很好的路径，但我还没有找到一个很好的示例，说明如何将记录插入到表中，然后通知C#应用程序，然后再进行处理。此外，我还有以下问题: 1)连续运行(或按需运行)此C#应用程序、windows服务、正在侦听的命令提示符应用程序等的最佳方式是什么?2)有没有从多个来源处理此队列的好方法，也就是我编写的C#应用程序可以在许多不同的机器上运行并通过一个队列进行处理？
浏览 0提问于2013-11-23得票数 3
使用RabbitMQ.Client，我想知道这是怎么可能的：2-队列绑定到什么交换？
3-如何获得所有被绑定到交换的队列？
浏览 0提问于2015-01-12得票数 7
回答已采纳
我们在生产者和消费者端都遇到了RabbitMQ的问题，随着时间的推移，大量的频道被创建，并且从未关闭。//suggested from http://public.hudl.com/bits/archives/2013/11/11/c-rabbitmq-happy-servers/model.BasicPublish(exchangeName, routingKey, basicProperties, messageBytes);
}
浏览 1提问于2015-10-22得票数 1
4回答
OutofMemory异常的可能原因是什么？
在我们的应用程序中，它出现在不同的地方，比如Stream.ReadToEnd()和DataTable.WriteXml(Memory stream环境是.Net C#
浏览 1提问于2009-10-26得票数 5
我有一个.net核心2 WebAPI，它将文件路径写入RabbitMQ队列，然后打开一个进程来消耗这些消息，并对可能需要一些时间才能完成的文件进行一些后台处理。
浏览 0提问于2018-09-18得票数 1
回答已采纳
2回答
我一直在尝试使用C#代码启用RabbitMQ管理插件。
通过使用以下代码，我成功地使用c#安装了RabbitMQ服务器。CommandParameter testParam = new CommandParameter("FilePath", @"C:\Users\saadp\Desktop\Dependencies\rabbitmq-serverCommandParameter testParam = new CommandParameter("FilePath&
浏览 29提问于2020-07-31得票数 2
回答已采纳
我使用RabbitMQ.Client(我从NuGet获得)来访问RabbitMQ。channel.QueueUnbind(queueName, EXCHANGE_NAME, "myTopic", null); }
它几乎是从RabbitMQ
浏览 0提问于2016-07-01得票数 2
我希望在我的开发机器上运行多个rabbitmq实例。似乎我只能安装一个rabbitmq服务，所以我想知道如何生成多个rabbitmq进程？我的目标是在我的自动集成测试中通过c#在本地启动和杀死"n“兔子My节点。
浏览 1提问于2013-10-02得票数 2
回答已采纳
我的C#代码使用一个COM对象。有时，COM对象方法将返回E_OUTOFMEMORY，但它将被转换为System.OutOfMemoryException，而不是使用适当的ErrorCode转换为System.Runtime.InteropServices.COMException当COM对象方法返回E_OUTOFMEMORY时，是否可以始终具有System.Runtime.InteropServices.COMException而不具有System.OutOfMemoryException
浏览 2提问于2012-12-03得票数 0
我正在试图获取RabbitMQ中特定队列的消费者总数。我在C#中使用RabbitMQ客户端为.Net编写了代码。factory.CreateConnection()) using (var channel = connection.CreateModel()) var consumerCount = ((RabbitMQ.Client.Impl.ModelBase)(channel)).m_consumers;}
我得到的var consumerCount = ((<e
浏览 11提问于2017-02-01得票数 1
回答已采纳
1回答
我目前正在使用spring连接到RabbitMQ。基本上，在我的消费者代码中，我是异步读取消息，并在弹性搜索中进行批量插入。-Xms1g -Xmx1g -Xss384k PermSize=256m MaxPermSize=256m
现在的问题是，当我正在执行ack = NONE时，虽然速度很好，但是JVM在一段时间后获得了OutOfMemory我如何用RabbitMQ实现这一点--还有什么其他方法可以在不使JVM崩溃的情况下实现400-5000毫希/秒的良好读取速度？
浏览 3提问于2013-09-25得票数 0
回答已采纳
2回答
有没有办法找出机器上是否安装了rabbitmq？{ var dirs = System.IO.Directory.EnumerateDirectories(@"C:\Program Files (x86)\RabbitMQ S
浏览 4提问于2021-01-15得票数 0
回答已采纳
我有两个程序，一个是游戏，一个是游戏的发射器。首先，我创建了发射器，以接收游戏中的基本信息，并检测出任何类型的退出(崩溃、任务管理器进程停止等) private void button1_Click(object sender, EventArgs e) using (Process exeProcess = Process.Start(new Proces
浏览 3提问于2013-04-21得票数 1
回答已采纳
2回答
我正在向使用RabbitMQ连接用不同语言编写的服务的人寻求建议。目前，我的组织只在C#中使用C#，而且都运行得很好。为了在RabbitMQ提供的基础上提供一些更好的附加功能，我们实现了MassTransit。MassTransit在RabbitMQ上提供了一些巨大的好处(抽象出RabbitMQ的细节，处理“有害”消息，重试，序列化，提供大量的消息传递模式等等)。当然，我们可以将用RESTful编写的C#端点进行表面处理，以允许其他服务连接，但这并不理想，因为其他服务应
浏览 0提问于2018-03-02得票数 2
我知道如何在C#或node.js中使用rabbitmq，但我正在尝试接收客户端(java脚本)的消息，所以我想知道有什么方法可以直接在java脚本中获取rabbitmq消息。谢谢
浏览 0提问于2018-06-19得票数 0
我正在阅读，这是非常好的信息，但我对RabbitMQ如何管理线程感到有点困惑。在并发考虑部分中，它声明每个IConnection都由单个后台线程备份。
浏览 4提问于2016-08-25得票数 1
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号