MassTransit -针对单个消费者的PrefetchCount和多个通道的说明
MassTransit是一个开源的分布式应用消息传递框架，用于构建基于消息驱动的应用程序。它是一个强大而灵活的工具，可帮助开发人员实现可扩展和可靠的应用程序。
在MassTransit中，PrefetchCount是一个设置，用于指定单个消费者在处理消息之前从消息队列中预取的消息数量。通过设置适当的PrefetchCount值，可以优化消息的处理效率和性能。如果PrefetchCount的值过大，可能会导致消息堆积和处理延迟。反之，如果PrefetchCount的值过小，可能会导致消费者在处理完一条消息后需要等待新消息的到达。
当涉及到多个通道时，MassTransit支持并行处理多个通道中的消息。多通道可以将消息处理的负载均衡到多个消费者上，提高处理效率。每个通道都可以配置自己的PrefetchCount值，以满足不同通道的需求。
下面是一些示例场景，展示了如何使用MassTransit以及适用于这些场景的腾讯云产品和相关链接：
- 场景：构建高可靠性的订单处理系统
- MassTransit可以用于将订单消息发送到一个消息队列，然后由多个消费者并行处理这些消息。
- 腾讯云产品推荐：使用消息队列Tencent MQ来存储和传递订单消息。链接：https://cloud.tencent.com/product/tmq
- 场景：实现实时监控和告警系统
- MassTransit可以作为一个事件消息的中间件，将监控数据发送到消息队列，并由消费者实时处理这些消息。
- 腾讯云产品推荐：使用云原生数据库TencentDB for MySQL来存储监控数据，并使用消息队列Tencent MQ来传递事件消息。链接：https://cloud.tencent.com/product/tcm
请注意，以上只是示例场景，具体的实现方式和腾讯云产品选择应根据具体需求和技术架构来确定。
相关·内容
我一直在尝试使用PreFetch，并试图弄清楚为什么队列的管理接口上的PreFetch总是设置为0。在RabbitMQ管理界面中，我可以看到通道上已配置的预取，但看不到队列本身。我还注意到它们被注册为“全局”而不是“每个消费者”，但是对于我的生活，我似乎找不到在MassTransit中改变这一点的设置，尽管我猜我对它的工作原理有一个误解，文档也没有帮助给我一个ELI5。 这是一个示例配置： var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(
new Uri(b
浏览 63提问于2020-04-29得票数 3
我使用MassTransit作为我的消息传递框架，运行在Azure Service Bus之上。我从WebJob内部运行MassTransit (尽管我认为这无关紧要)
现在，我正在尝试让MassTransit同时处理多个消息，因为我现在正在处理单独需要一段时间才能处理的消息。因此，为了提高性能，我不希望逐条处理每条消息。
例如，我尝试将MaxConcurrentCalls设置为30，但似乎没有成功。消息仍然被我的消费者一个接一个地接收。
我也尝试将PrefetchCount设置为5等，但它不会改变任何东西。
我做错了什么？非常感谢您的任何帮助。
浏览 0提问于2016-09-30得票数 0
我使用带有.NET的.NET (v7.1.6)通过RabbitMQ发布和使用消息
为了将使用者绑定到特定的队列，我以这种方式配置端点：
configurator.ReceiveEndpoint(
"QueueName",
cfg =>
{
cfg.ConfigureConsumer<MyConsumer>(context);
cfg.ExchangeType =
浏览 22提问于2021-05-31得票数 0
回答已采纳
在RabbitMq中使用CircuitBreaker时，如下所示：
sbc.ReceiveEndpoint(host, "IDocumentImported_Warehouses.Nls", ep => {
ep.Consumer(() => _container.Resolve<DocumentConsumer>());
ep.PrefetchCount = 1;
ep.UseCircuitBreaker(cb => {
cb.ResetInterval = TimeSpan.Fr
浏览 1提问于2017-06-14得票数 2
首先，请原谅我的英语，这很糟糕。我使用MassTransit与Azure服务总线进行微服务之间的异步通信。我对压缩服务总线的默认配置有一些疑问，但我无法在文档中对它们进行澄清。这些疑问如下：
是否有方法为所有队列和主题设置默认的TTL？队列和主题的大小？文档指定在连接/创建接收器时可以调整TTL和队列的大小，但另一方面，对于主题，如果使用者连接到特定主题，则指定如何调整TTL，但是在这种情况下，我们的使用者不订阅特定的主题，而只是订阅一个messageType，其余(创建主题、订阅者并将消息从订阅方转发到用户队列)。
另一方面，PrefetchCount和MaxConcurre
浏览 4提问于2021-02-15得票数 0
在MassTransit中，如何通过设置prefetchCount>1来消费事件的IList？，DataSynchronizationConsumer正在消费busconrol.Publish发布的事件(新的DataSynchronizationMessage) public class DataSynchronizationConsumer : IConsumer<IList<DataSynchronizationMessage>>
{
public Task Consume(ConsumeContext
浏览 11提问于2019-12-13得票数 0
回答已采纳
默认情况下，MassTransit将PrefetchCount设置为16。我想更改此设置。我可以在配置MassTransit时执行此操作。但在使用ConnectReceiveEndpoint时，我无法设置PrefetchCount。如果我设置PrefetchCount进行配置，那么MassTransit将创建一些随机队列，这些随机队列正确地具有我定义的PrefetchCount，但是使用ConnectReceiveEndpoint创建的队列仍然具有默认值16。 是否可以为使用ConnectReceiveEndpoint创建的队列设置PrefetchCount public async
浏览 28提问于2021-01-12得票数 0
回答已采纳
如果我的问题很愚蠢，很抱歉，我是新来MassTransit的。 我的系统由一个服务器和多个客户端设备组成。我想从服务器向特定的客户端或一组客户端发送消息。据我所知，IBusControl.Publish将消息发送给所有订阅者，而IBusControl.Send将消息发送给唯一的订阅者。 如何使用MassTransit实现这一点？我的传输是RabbitMQ / Azure服务总线。 谢谢!
浏览 39提问于2019-03-13得票数 1
回答已采纳
我在通过MassTransit和SignalR向客户发送消息时遇到了问题。
启动：
//SignalR
services.AddSignalR().AddMassTransitBackplane();
#region MassTransit RabbitMq
services.AddScoped<SendCosistListToScaleConsumer>();
services.AddScoped<CreateConsistListConsumer>();
s
浏览 7提问于2020-04-29得票数 0
回答已采纳
最近对RabbitMQ服务器的升级中，管理面板中的使用者报告的预取计数发生了变化。
通道预取计数和使用者预取计数之间有什么区别，如下所示？
我们正在运行一个设置，其中有多个线程消耗掉单个使用者/通道。我们允许动态调整线程计数和预取计数。我们应该使用什么参数组合到Model.BasicQos(prefetchLength, prefetchCount, global);客户端上的c#调用？
浏览 2提问于2017-05-04得票数 19
1回答
我正在尝试建立一个消息传递系统，并在多个应用程序上运行。我有一个运行RabbitMQ的实例，这似乎很好。我可以将多个订阅者/发布服务器连接到RabbitMQ实例，它们看起来很好。然后，我可以从一个发布服务器发布一条消息，但只有一个订阅服务器正在接收该消息。
我相信这与我排队的方式有关。我看过关于兔子，的教程，但我不知道这是否能转化为Masstransit库。
为了我的生命，我很难弄清楚我做错了什么。
NuGets：
MassTransit.Extensions.DependencyInjection 5.3.2
MassTransit.RabbitMQ 5.3.2
有人能帮忙吗
浏览 0提问于2019-03-12得票数 2
回答已采纳
在RabbitMQ教程中，有这样的代码：
channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
我明白prefetchCount和global是什么，但不理解prefetchSize。
有人知道吗？
浏览 2提问于2019-12-26得票数 9
与直接在上构建相比，在上构建有什么好处
我相信MassTransit提供的一个好处是“类型”交换(按接口/类型发布/订阅)，因此消息的内容是结构化的，而普通的RabbitMQ交换的消息内容是非结构化的文本/ blob。
MassTransit还提供了哪些其他好处？
浏览 0提问于2012-09-06得票数 44
回答已采纳
我目前为两个总线控件注册了Masstransit。我想为SecondBus注入ISendEndPointProvider作为DI (我不想在调用者中调用GetSendEndPoint() )。我怎么能做到这一点。当ISendEndPointProvider总是返回第一辆公交车时。
Program.cs
services.AddMassTransit(x =>
{
x.AddConsumer<FirstConsumer>();
x.Ad
浏览 0提问于2021-07-07得票数 0
1回答
我使用MassTransit.Kafka批量生产和消费消息。当我尝试一个接一个地消费消息时，一切正常，但当我尝试批量消费消息时，我得到了一个错误： Confluent.Kafka.ConsumeException: Local: Value deserialization error
---> System.InvalidOperationException: Exception creating proxy (GreenPipes.DynamicInternal.MassTransit.Batch<Aiforfit.WSW.DataStructures.Events.User
浏览 50提问于2021-04-11得票数 0
回答已采纳
我可以创建一个workerservices来创建和配置n个RabbitMQ消费者，每个消费者都是自己的线程，用于应用内负载平衡。 我是Masstransit的新手，我不知道如何配置我想要的方式。我在configureservices中找到了使用消息类型队列的代码： // MassTransit-RabbitMQ Configuration
services.AddMassTransit(config => {
config.AddConsumer<BasketCheckoutConsumer>();
浏览 31提问于2021-09-02得票数 1
回答已采纳
新手的问题-我错过了什么？是否有任何dotnetcore 2.2 Saga的例子可用？
我有一个基本的端到端系统工作正常，消息在码头-撰写中跨容器流动，但添加一个佐贺似乎是一个挑战-
问:我缺少调度程序依赖吗？在MassTransit 5.5.5中，cfg.UseInMemoryMessageScheduler()；不编译。
有些奇怪的事情发生了，我不得不明确地将我的状态机标记为ISaga。
MassTransit.ConfigurationException:未能为Model.WorkflowExecutionStateMachine ->MassTransit.Configurati
浏览 9提问于2019-09-21得票数 0
回答已采纳
1回答
我正在使用下面的代码来设置MassTransit以使用ServiceBus private static ServiceProvider SetupServiceCollection()
{
var connectionString = ConfigurationManager.AppSettings["AzureServiceBusConnectionString"];
var services = new ServiceCollection()
.AddMassTransit(x =>
{
x.
浏览 23提问于2020-10-07得票数 0
回答已采纳
1回答
我用RabbitMq总线创建了服务。现在，我正在尝试在公共汽车上添加活动(我尝试了我找到的每一个注册选项)
private void ConfigureBus(IServiceCollectionConfigurator configurator)
{
configurator.AddActivity(typeof(StepAcitivity));
configurator.AddActivitiesFromNamespaceContaining<StepAcitivity>();
configurator.AddAc
浏览 1提问于2020-07-06得票数 0
当在多个ServiceBus竞争的消费者中使用Azure主题描述时，只有当SubscriptionClient的PrefetchCount没有设置时，才能让消费者循环使用。
当指定任何PrefetchCount > 1时，在低负载下，碰巧接收消息的第一个使用者似乎被赋予了与消息的亲缘关系，这样所有消息都只由该使用者接收。
如果我添加load (即在订阅时并发抛出更多消息)，那么其他使用者确实会得到一些消息，但是load的分布并不均匀。
使用队列(和QueueClient)，消息与任何PrefetchCount都或多或少地均匀地分布在客户端上。
注意：
MaxConcurrentCalls
浏览 2提问于2020-01-09得票数 0
我有一个只有一个应用服务器的环境。我有一些需要一段时间才能服务的消息(比如10秒左右)，我希望通过配置多个运行代码的使用者应用程序实例来处理这些消息来提高吞吐量。我读过关于“竞争消费者”模式的文章，并认为在使用MassTransit时应该避免这种情况。根据MassTransit docs ，每个接收端点应该有一个唯一的队列名。我很难理解如何将这个建议映射到我的环境中。是否有可能让消费者的N个实例运行，每个实例都接收相同的消息，但只有其中一个实例实际上会对其起作用?换句话说，我们可以在多个队列而不是一个队列中实现“竞争消费者”模式吗？
还是我看错了？我真的需要研究一下“发送”方法而不是“发布”方
浏览 3提问于2016-08-03得票数 2
回答已采纳
我正在尝试为我的应用程序设置MassTransit和RabbitMQ。
我使用的是CastleWindsor DI和.Net Framework4.7。
我在Program.cs中注册我的消费者和公共汽车的方式是：
container.AddMassTransit(x =>
{
x.AddBus(context => Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(configurationProvider.RabbitHostName);
x.AddC
浏览 2提问于2020-02-06得票数 1
回答已采纳
警告确实建议阅读文档，但当前文档建议在配置需要DI支持的使用者时使用LoadFrom。目前使用的是.net核心依赖注入。找不到允许DI的Consumer方法。 这将继续起作用。只会让我在未来感到紧张。 cfg.ReceiveEndpoint(host, "adjudication-api", e =>
{
e.PrefetchCount = 16;
e.UseMessageRetry(x => x.Interval(2, 100));
e.LoadFrom(provider);
}); 如能得到指导，将不胜感激。
浏览 45提问于2019-01-09得票数 4
我需要在多个消费者上实现顺序消息处理，但每次在队列上只有一条消息。我有很多队列，但它们都是连续的，我需要多个使用者支持负载平衡和冗余。任何人都能判断将未确认消息的数量限制为每个队列1是真实还是不真实的？
浏览 0提问于2016-05-04得票数 0
我在ASP.NET核心web应用程序中有一个接收器方法：
public void ReceiveMessage()
{
using (var connection = CreateConnection())
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "QueueName",durable: false,exclusive: false,autoDelete: false,argum
浏览 57提问于2018-12-10得票数 1
1回答
为了限制打开到数据库的连接的数量，我需要限制同步函数调用的数量。
MassTransit的UseConcurrentMessageLimit显然限制了每个主机实例同时处理的消息数量，这与来自host.json的maxConcurrentCalls相同吗？
Azure门户有App -> Maximum Scale Out ，这限制了将要创建的主机数量。
要将同步函数调用的次数限制为n，是否应该设置最大扩展量限制* UseConcurrentMessageLimit or maxCurrentCalls =n
我可以通过MassTransit或Azure函数配置中的一个参数来实现这一点吗？
浏览 6提问于2022-05-31得票数 1
回答已采纳
2回答
我将MassTransit与RabbitMQ结合使用。
这是对发生的事情的总结。
ORDER SERVER是一个获取订单并发布(与MassTransit一起) Order消息的应用程序。
OrderProcessed.处理单元，它是一个应用程序，它使用订单消息并对其进行一些处理，然后发布。
因此，在这里，处理单元是消费和发布。
在博客、文档和论坛中，我看到每个应用程序都必须有一个队列，我这样做了，但是仍然有很多消息(大约%30)会进入错误队列，而--当在处理单元上使用两个队列时--它工作得很好。(意味着处理单元有一个具有不同队列的IServiceBus，仅用于消费，另一个仅用于
浏览 4提问于2013-07-02得票数 1
回答已采纳
1回答
这些都是Masstransit的新成员，目前正在为一个更大的项目进行评估，并想知道是否有人能帮助更好地理解以下挑战：
“负载平衡环境中事件的单个使用者”
在生产中，我们的服务将运行多个实例以实现可伸缩性和故障转移，并成为更大的微服务生态系统的一部分。总体架构基于参考实现，其中不同的微服务通过“集成事件”相互通信。当将IntegrationEvent发布到其他服务(我认为应该像Masstransit / 中所描述的那样)时，我如何确保在特定的微服务中只有一个实例正在处理该事件，但当然，事件到达了所有依赖于事件的微系统？当我们基于Azure函数完成类似的解决方案时，这个需求已经通过使用"S
浏览 1提问于2021-03-01得票数 1
我正在尝试使用MassTransit.ExtensionsDependencyInjectionIntegration和PrefetchCount进行实验。我注意到，对于多个消息，有时会使用相同的消费者。 有没有办法强制masstransit为每条消息创建消费者？ 我的服务逻辑需要为每条消息创建新的di作用域，据我所知，只有在每次都创建使用者的情况下才有可能。 更新 我使用this library来注册消费者和发布者。 Here you can see，它向TryAddTrancient()注册消费者。这会是一个问题吗？我仍然认为di容器应该为每个请求生成消费者。 看起来这不是故意的行为，我
浏览 5提问于2019-01-26得票数 1
回答已采纳
我已经用MassTransit实现了一个简单的发布者/消费者集合，我想让消费者从同一队列中读取消息。但是，当我运行它时，我看到很大一部分消息被发送到错误队列，而不是被使用。根据我所看到的讨论(，)，使用RabbitMQ应该非常非常简单(只需指向相同的队列)，但它不起作用。是否需要设置其他配置？
这是我的出版商
public class YourMessage { public string Text { get; set; } }
public class Program
{
public static void Main()
{
Console.WriteLi
浏览 0提问于2012-05-09得票数 7
回答已采纳
我使用的是Masstransit
以下代码返回null，而Context.RespondAsync不能返回null
当City未找到时，我希望返回Null，在Controller中，我检查响应是否为null，然后返回未找到
主计长：
var request = _mediator.CreateRequestClient<TGetQuery>();
GetCityQuery getQuery = _mapper.Map<GetCityQuery>(id);
var result = await request.GetResponse<CityViewMod
浏览 10提问于2022-05-16得票数 0
回答已采纳
我看不出有什么可以说这是正常的行为，所以如果我是瞎子，请原谅。在使用带有请求响应的MassTransit时，我看到了一些奇怪的东西。
因此，我在一个服务上有多个使用者，它侦听不同的请求来执行简单的任务，比如从数据库抓取数据。
为了测试每个使用者，我创建了一个控制台应用程序，它为每个使用者执行一个请求并检查响应。
我注意到的是，第一个请求-响应工作正常，但是当代码运行时，下一个检查会收到响应，但是消息会被移动到跳过的队列中并删除。
这是第二次请求的杂凑日志。
发送
rabbitmq://192.168.0.25/Ksrs.Requests:ConceptByConceptNoRequest d9
浏览 3提问于2021-05-14得票数 0
回答已采纳
1回答
我希望以循环方式在多个服务器之间分配任务，每个服务器一次最多只能处理多个CPU核心任务。
在Java中，可以像这样控制要预取的任务数：
int prefetchCount = 4; // would be number of cores in actual app
channel.basicQos(prefetchCount);
但现在假设我有两个服务器A和B，每个服务器都有相同的设置来预取4个任务。假设我在队列中放了5个任务。这是否意味着服务器A将消耗队列中的4个任务，而服务器B将消耗1个任务？或者，任务仍然是分布式轮询的？
浏览 4提问于2016-11-28得票数 0
4回答
我正在编写一个简单的类，我的应用程序将使用它通过RabbitMQ发送和接收消息。我已经阅读了尽可能多的关于RabbitMQ的操作指南、博客文章、白皮书和类似的东西。大多数示例都将连接和通道包装在using块中，并指出您可能应该将它们实现为单例，这与之相矛盾。具体地说，关于通道，我看到有评论说，不应该有超过一个线程同时使用一个通道。
我正在用C#编写我的库。它是一个单例，在第一次实例化时连接了一个静态连接。
我考虑过对通道执行相同的操作，但我打算使用相同的库来允许发布/订阅多个交换/队列。发布和订阅都可以从多个线程完成。
最后是我的问题:我应该如何实现通道创建？每条消息？是否每个消费者都有一个唯
浏览 2提问于2011-04-16得票数 16
我们最近经历了由RabbitMQ驱动的应用程序的意外行为。RabbitMQ版本为3.6.12，我们使用的是.NET客户端5.0.1
应用程序订阅两个队列，一个用于命令，另一个用于事件--我们还使用手动确认。我们的应用程序被配置为有7个使用者。每个通道都有自己的通道(IModel)，每个通道都有自己的EventingBasicConsumer，当EventingBasicConsumer.Received被触发时，我们最终会处理消息。
当消息被路由到队列时，我们的应用程序必须处理尽可能接近的消息，到目前为止，我们还没有遇到问题。然而，最近我们已经看到，当我们正在处理的一条消息需要很长时间才能完成
浏览 1提问于2019-05-30得票数 1
回答已采纳
在以前的项目中，下面的代码正在工作。但是现在我需要在当前项目中使用MultiBus：- EventsConsumer。-支付的消费者位于外部项目。为什么这种方法不再起作用？
===================错误：
内部异常1: InvalidOperationException:验证服务描述符'ServiceType: Publisher.Services.Abstract.IBusPublisher生命周期: Singleton ImplementationType: Publisher.Services.Concrete.BusPublisher‘时出错:在试图激活'
浏览 13提问于2021-12-23得票数 0
我有两个系统，一个用于发布消息，另一个用于使用它们。两者都使用Masstransit (与RabbitMQ一起使用)，并使用ASP.Net web 2和OWIN (以及Autofac作为IoC容器)实现。如果我的使用者没有依赖项，，一切都很好，但是当我向使用者注入依赖关系时，消费方法永远不会被执行(初始化期间没有抛出错误)。
这是相关的Publisher代码：
//Startup.cs
public class Startup
{
public void Configuration(IAppBuilder app)
{
HttpConfiguration con
浏览 8提问于2017-10-13得票数 1
回答已采纳
三个生产者，每个生产者都有一个队列。两个消费者消费来自特定队列和公共队列的msg。如何将它们与pthread_cond同步？
浏览 0提问于2018-04-03得票数 0
我正在学习如何使用SimpleMessageListenerContainer来接收rabbitmq消息。我的侦听器容器的prefetchCount = 1000。但是，我的侦听器worker实现了MessageListener接口，该接口一次只接收一条消息。是否有接收消息列表的接口？如果没有，我该如何接收消息列表？我不想一次处理一条消息，而是处理一系列消息，这样我就可以批量插入/更新。我还想为所有传递给我的消息致谢一次。
谢谢,
Sean Nguyen
浏览 2提问于2015-01-12得票数 0
我用皮卡为蟒蛇与RabbitMQ沟通。我有6个线程，它们使用和确认来自同一个队列的消息。对于每个线程，我使用不同的连接(和通道)。因此，我有几个问题非常接近对方：
如果连接到兔子将关闭在一个线程，我将进行重新连接，传递标签值将重置和重新连接后，它将从0开始？
在重新连接之后，我将以相同的顺序接收相同的未确认消息，或者它将开始在所有线程之间重新分发它们，还是从重新连接点开始？
这在我的应用程序中很重要，因为在消息接收和确认之间存在延迟，我希望在接下来的过程中避免重复。
浏览 3提问于2015-09-16得票数 3
回答已采纳
如何将发布到Redis通道的消息仅发送到订阅的服务器(连接到订阅者)，而不发送到我的其他服务器(其中所需的订阅者未连接)。
我使用的是Socket.IO和Redis服务器。
浏览 3提问于2017-06-27得票数 0
1回答
我试图通过Azure服务总线队列使用MassTransit进行请求/响应通信。发件人是一台Azure WebApp，而消费者是安装在上位机上的windows服务.
当它涉及到少量的消息时，一切都很好。但是，一旦我开始发送超过20 msg/秒的消息，我就会看到来自使用者的响应出现严重的延迟(1-2秒)。我的遥测告诉我，当消费者需要从队列中获取信息时，延迟就会发生。
一个奇怪的，但我认为行为的重要部分:我可以看到，在当前负载的队列中未读消息数量是在avg常量和它的25。如果我发送的消息比队列中的avg 50多出2倍。由于消耗方面的延迟，我希望队列会增长，但它是恒定的，所以肯定是代码内部的某种东西控
浏览 2提问于2019-07-01得票数 1
1回答
当我在默认的MassTransit核心DI中使用ASP.NET v5.1.5时，我遇到了问题。我有以下代码：
var consumers = typeof(CompanyApplicationService).Assembly
.GetTypes()
.Where(t => typeof(IConsumer).IsAssignableFrom(t))
.ToList();
consumers.ForEach(
c => services.AddSingleton(typ
浏览 1提问于2018-10-09得票数 1
我在一个大型代码库中使用MassTransit (5.5.5)和StructureMap (4.7)，使用注册表类来组织我的依赖关系，遵循here概述的内容 class BusRegistry : Registry
{
public BusRegistry()
{
For<IBusControl>(new SingletonLifecycle())
.Use(context => Bus.Factory.CreateUsingInMemory(x =>
{
浏览 30提问于2019-09-03得票数 0
回答已采纳
究竟什么是消费者传奇，它与自动代名词有什么不同？我知道自动化是一个独立的库，由MassTransit使用。
浏览 1提问于2021-01-14得票数 3
回答已采纳
我已经在我的StructureMap配置中使用ContainerScope配置了一个类X，但是由于某些原因，当应用程序最初启动并且MassTransit使用者使用初始消息时，它会创建实例，但是在为该使用者接收的后续消息中，使用者会被重新创建，而不是对象X(我希望每个接收到的消息都会创建一个新的实例)。我知道如果我用瞬态来配置它，它会起作用，但我只需要为整个消息处理过程创建该类的一个实例。
在这方面的任何帮助都将非常感谢。
浏览 7提问于2020-03-06得票数 0
在MSMQ上使用MassTransit可以自动支持精确的一次传递(例如，当事件存储发布两次事件时)和顺序传递(例如，当两个节点同时写入/发布事件时，节点A存储事件#2，然后节点B读取事件#2，节点B存储事件#3，节点B发布事件#3，节点A发布事件#2 -典型的竞赛条件)？
如果MassTransit不支持开箱即用(我目前假设的)，那么使用MassTransit实现这两种需求的最佳/通用方法是什么。
浏览 2提问于2013-06-20得票数 0
回答已采纳
我正尝试在2个总线实例的单元测试中使用InMemoryBus传输(相同的过程)。其中一个总线实例应该发布一个事件，而另一个则使用它。 我认为，我需要的是http://masstransit-project.com/MassTransit/usage/transports.html中记录的共享传输功能，但它似乎在5.2.1版中不再可用。有没有其他方法可以达到同样的效果？
浏览 13提问于2019-01-18得票数 0
回答已采纳
我已经成功地设置、配置和运行了MassTransit (v8.0.3) JobConsumers示例，现在正在尝试定制到我的项目。修改后，在提交工作时遇到反序列化问题：
Newtonsoft.Json.JsonSerializationException: Cannot deserialize the current JSON array (e.g. [1,2,3]) into type 'MyNamespace.Foo' because the type requires a JSON object (e.g. {"name":"value"}
浏览 13提问于2022-06-10得票数 0
回答已采纳
我有这个设计选择的问题，不知何故，但徒劳无功。它只在特定的情况下起作用。
我试图在MassTransit中发布和使用一条消息。例：(Publisher -一个简单的控制台应用程序)
IShape message = GetShape(/**Business Logic will return some concrete object (Circle or square) based on some business inputs**/);
bus.Publish(message);
(消费者- CircleConsumer和SquareConsumer)
class CircleCons
浏览 5提问于2020-03-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
