PROSAGA码农传奇-rabbitmq-MassTransit为prefetchcount> 1的每条消息的新消费者（和范围）

MassTransit为prefetchcount> 1的每条消息的新消费者（和范围）

作者: 日耀九洲
发布时间: 2024-03-07 11:11:01 (1月前)
转自：

<div class =“post-text”itemprop =“text”>
  <P>
    我建议使用
     <code>
      MassTransit.AspNetCore
    </code>
     使用的包
  </p>
  <P>
    请仔细阅读
    <a href="http://masstransit-project.com/MassTransit/usage/configuration.html#masstransit-and-aspnet-core" rel="nofollow noreferrer">
      文件
    </A>
    ，包括样品。
  </p>
   <pre>
    <code>
      public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        // Add framework services
        services.AddHealthChecks();

services.AddMvc();

// Register your consumers if the need dependencies
        services.AddScoped<SomeDependency>()
        services.AddScoped<OrderConsumer>();

// Register MassTransit
        services.AddMassTransit(
            provider => Bus.Factory.CreateUsingRabbitMq(cfg =>
            {
                var host = cfg.Host("localhost", host => 
                { 
                    host.Username("guest");
                    host.Password("guest");
                });

cfg.ReceiveEndpoint(host, "submit-order", ep =>
                {
                    ep.PrefetchCount = 16;
                    ep.UseMessageRetry(x => x.Interval(2, 100));

ep.Consumer<OrderConsumer>(provider);
                });
            }),
            x => x.AddConsumer<OrderConsumer>());
    }

// everything else
}

</code>
  </pre>
</DIV>