我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息 configurator.ReceiveEndpointcfg.ConfigureConsumer<MyConsumer>(context); });
因此，当我启动我的应用程序时，我在兔子管理UI中只看到一个使用者(和<
浏览 22提问于2021-05-31得票数 0
回答已采纳
我一直在尝试使用PreFetch，并试图弄清楚为什么队列的管理接口上的PreFetch总是设置为0。在RabbitMQ管理界面中，我可以看到通道上已配置的预取，但看不到队列本身。我还注意到它们被注册为“全局”而不是“每个消费者”，但是对于我的生活，我似乎找不到在MassTransit中改变这一点的设置，尽管我猜我对它的工作原理有一个误解，文档也没有帮助给我一个ELI5。作为一点背景知识，我们有几个运行消费者的
浏览 63提问于2020-04-29得票数 3
我正在尝试使用MassTransit.ExtensionsDependencyInjectionIntegration和PrefetchCount进行实验。我注意到，对于多个消息，有时会使用相同的消费者。 有没有办法强制masstransit为每条消息创建消费者？我的服务逻辑需要为每条消息创建新的di作用域，据我所知，只有在每次都创建使用者的情况下才有可能。 更新 我使用this library来注
浏览 5提问于2019-01-26得票数 1
回答已采纳
我正在尝试为我的应用程序设置MassTransit和RabbitMQ。container.AddMassTransit(x => x.AddBus(context => Bus.Factory.CreateUsingRabbitMq我想要实现的是两件不
浏览 2提问于2020-02-06得票数 1
回答已采纳
我使用MassTransit作为我的消息传递框架，运行在Azure Service Bus之上。我从WebJob内部运行MassTransit (尽管我认为这无关紧要)我也尝试将PrefetchCount设置为5等，但它不会改变任何东西。
我做错了什么？非常感谢您的任何
浏览 0提问于2016-09-30得票数 0
首先，请原谅我的英语，这很糟糕。我使用MassTransit与Azure服务总线进行微服务之间的异步通信。我对压缩服务总线的默认配置有一些疑问，但我无法在文档中对它们进行澄清。这些疑问如下：
是否有方法为所有队列和主题设置默认的TTL？队列和主题的大小？文档指定在连接/创建接收器时可以调整TTL和队列的大小，但另一方面，对于主题，如果使用者连接到特定主题，则指定如何调整TTL，但是在这种情况下，我们<e
浏览 4提问于2021-02-15得票数 0
1回答
我试图通过Azure服务总线队列使用MassTransit进行请求/响应通信。发件人是一台Azure WebApp，而消费者是安装在上位机上的windows服务.
当它涉及到少量的消息时，一切都很好。但是，一旦我开始发送超过20 msg/秒的消息，我就会看到来自使用者的响应出现严重的延迟(1-2秒)。我的遥测告诉我，当消费者需要从队列中获取信息时，延迟就会发生。我试着和UseConcurrency
浏览 2提问于2019-07-01得票数 1
我有一个企业服务总线( Enterprise )，它使用Masstransit / RabbitMq在web项目中使用。我在MQ上使用模式进行RPC。我正在一个总线中创建多个ReceiveEndpoint，它处理不同类型的消息。ESB还使用自定义配置文件来创建多个总线，因此我可以以某种方式在逻辑上实现Qos，甚至可以在独立服务器上通过网络不信任使用者，以或多或少地提高性能。MassT
浏览 5提问于2017-04-26得票数 0
回答已采纳
最近对RabbitMQ服务器的升级中，管理面板中的使用者报告的预取计数发生了变化。
我们正在运行一个设置，其中有多个线程消耗掉单个使用者/通道。我们允许动态调整线程计数和预取计数。我们应该使用什么参数组合到Model.BasicQos(prefetchLength, prefetchCount, global);客户端上的c#
浏览 2提问于2017-05-04得票数 19
我可以创建一个workerservices来创建和配置n个RabbitMQ消费者，每个消费者都是自己的线程，用于应用内负载平衡。 我是Masstransit的新手，我不知道如何配置我想要的方式。我在configureservices中找到了使用消息类型队列的代码： // MassTransit-RabbitMQ Configuration
services.AddMassTransit//
浏览 31提问于2021-09-02得票数 1
回答已采纳
我使用NServiceBus 4.x和RabbitMQ 3.2.x作为传输。我假设，通过使用RabbitMQ作为我的传输，我将被给予竞争的消费者模型作为一种选择。但是，是否有一种方法可以配置NServiceBus以通过RabbitMQ提供的交换和通道利用间接的级别。
我有几个消费者，我想竞争来自给定队列的消息。我观察到的是订阅者阻止访问队列中的进一步消息检索，直到消息被消耗为止。因
浏览 6提问于2013-11-06得票数 2
回答已采纳
假设我有一个队列'Q1‘，并且有多个生产者发布到这个队列，并且有多个消费者从这个队列中读取。
现在，每个消费者将处理来自“Q1”的消息，并再次将其放入其他队列中，例如“q2”/“q3”。我已经创建了一个生产者通道，它将发布到任何队列(Q1和Q2/Q3)和多个消费者通道。是否可以使用单个生产者通道，否则会出现一些同步问题？
浏览 0提问于2016-04-07得票数 0
我使用的是MassTransit 7.3.0和Autofac和RabbitMq。builder.AddMassTransit(massTransit => mt.AddConsumers(consumerAssembly);
massTransit.UsingRabbit
浏览 9提问于2022-05-14得票数 0
我想要一个场景，有许多消费者监听新消息并处理它们。当消息不为空时，消费者应该始终在监听和处理消息。queueMessage = queue.getQueue("myQueue"); while (t
浏览 110提问于2017-08-08得票数 0
当在多个ServiceBus竞争的消费者中使用Azure主题描述时，只有当SubscriptionClient的PrefetchCount没有设置时，才能让消费者循环使用。当指定任何PrefetchCount > 1时，在低负载下，碰巧接收消息的第一个使用者似乎被赋予了与消息的亲缘关系，这样所有消息都只由该使用者接收。使用队列(和QueueClient)，消息与任何PrefetchCount都
浏览 2提问于2020-01-09得票数 0
如果我的问题很愚蠢，很抱歉，我是新来MassTransit的。 我的系统由一个服务器和多个客户端设备组成。我想从服务器向特定的客户端或一组客户端发送消息。据我所知，IBusControl.Publish将消息发送给所有订阅者，而IBusControl.Send将消息发送给唯一的订阅者。 如何使用MassTransit实现这一点？我的传输是RabbitMQ / Azure服务总线。 谢谢!
浏览 39提问于2019-03-13得票数 1
回答已采纳
我在通过MassTransit和SignalR向客户发送消息时遇到了问题。conf.ReceiveEndpoint(Configuration["Rabbit:ReceiveEndpoint"], e => {{});pub
浏览 7提问于2020-04-29得票数 0
回答已采纳
1回答
所以我一直在尝试MassTransit和Azure Service Bus Premium，这是我的一个消费者的示例。假设一个发布者的初始负载大约是每秒1000条消息。然而，每当我尝试配置一个消费者时，它似乎通常平均每个循环大约有20-40条消息。cfg.ReceiveEndpoint("ReceivePoint", e =>{ e.MaxConcurrentCal
浏览 16提问于2020-03-30得票数 0
标准库只有多个生产者、单个消费者(MPSC)通道。
也就是说，如果有10个消费者，每个消费者如何才能接收到一个生产者发送的信息？
浏览 0提问于2018-06-17得票数 9
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
