在Asp.net核心5中配置NServicebus

Install-Package NServiceBus

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        // 添加NServicebus终结点
        services.AddNServiceBus(options =>
        {
            options.EndpointConfiguration = endpointConfiguration;
        });
    }

    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        // 配置NServicebus消息处理器
        app.UseNServiceBus(endpoint =>
        {
            endpointConfiguration = endpoint;
            endpointConfiguration.UseTransport<TransportType>().ConnectionString("connectionString");
            // 其他配置项
        });

        // 其他中间件和配置
    }
}

public class MyMessageHandler : IHandleMessages<MyMessage>
{
    public Task Handle(MyMessage message, IMessageHandlerContext context)
    {
        // 处理接收到的消息
        return Task.CompletedTask;
    }
}

public class EndpointConfig : IConfigureThisEndpoint
{
    public void Customize(EndpointConfiguration endpointConfiguration)
    {
        var routing = endpointConfiguration.UseTransport<TransportType>().Routing();
        routing.RouteToEndpoint(typeof(MyMessage), "TargetEndpoint");
    }
}

public static class Program
{
    public static async Task Main(string[] args)
    {
        var builder = WebApplication.CreateBuilder(args);
        // 构建WebHost

        var app = builder.Build();
        var endpoint = app.ApplicationServices.GetRequiredService<IMessageSession>();

        await endpoint.Start();
        await app.RunAsync();
        await endpoint.Stop();
    }
}