无法从 ASP.NET Core 6.0 API NServiceBus 端点订阅事件

Question

我想让我的 API 既发布事件（在任何传入消息处理程序之外，例如来自操作方法）又订阅事件。发布活动有效。我使用旧版本的Program 和Startup 进行集成，使用GenericHost 和IMessageSession 成功注入到构造函数中。

但是，当激活注释掉的代码让API订阅和处理事件时，在初始化主机和运行应用程序时突然抛出了注入IMessageSession的异常。

TestController.cs

namespace TestContext
{
    [Route("api/[controller]")]
    [ApiController]
    public class TestController : ControllerBase/*, IHandleMessages<ReceivedEvent>*/
    {
        private IMessageSession _session;

        public TestController(IMessageSession session)
        {
            _session = session;
        }
        /*
        [NonAction]
        public Task Handle(ReceivedEvent message, IMessageHandlerContext context)
        {
            throw new NotImplementedException();
        }*/

        [HttpPost]
        public async Task<ActionResult> Test()
        {
            await _session.Publish(new PublishedEvent());
            return Ok();
        }
    }
}

Program.cs

public class Program
{
    public static void Main(string[] args)
    {
        CreateHostBuilder(args).Build().Run();
    }
    public static IHostBuilder CreateHostBuilder(string[] args) =>
        Host.CreateDefaultBuilder(args)
            .UseNServiceBus(context =>
            {
                var endpointConfiguration = new EndpointConfiguration("Test");
                var transport = endpointConfiguration.UseTransport<LearningTransport>();
                
                return endpointConfiguration;
            })
            .ConfigureWebHostDefaults(webBuilder =>
            {
                webBuilder.UseStartup<Startup>();
            });
}

例外

为什么会抛出异常以及如何让 API 订阅和处理事件？

编辑

从单独的服务类处理事件时，不会抛出异常。

public class HandlerService : IHandleMessages<ReceivedEvent>
{
    public Task Handle(ReceivedEvent message, IMessageHandlerContext context)
    {
        Console.WriteLine(message);
        return Task.CompletedTask;
    }
}

Answer 1

这里的异常信息其实还不错。大多数 NServiceBus 异常消息都是。

不应从容器解析接口 IMessageSession 或 IEndpointInstance 以启用从 saga 或消息处理程序中发送或发布消息。而是使用 TestController.Handle 方法上的 context 参数来发送或发布消息。

首先，不要在控制器中混合处理程序。它需要是一个单独的类。

然后，不要注入 IMessageSession。该接口明确用于控制器操作等您没有现有的“正在处理消息”并且您想要发送消息的事情。

相反，如果您想在处理程序中发送或发布，请使用上下文：

不要这样做

public class MyHandler : IHandleMessages<ReceivedEvent>
{
    private IMessageSession session;

    public MyHandler(IMessageSession session)
    {
        // Won't work! Don't inject IMessageSession!
        this.session = session;
    }

    public async Task Handle(ReceivedEvent message, IMessageHandlerContext context)
    {
        // NOPE!
        session
    }
}

改为这样做

public class MyHandler : IHandleMessages<ReceivedEvent>
{
    public async Task Handle(ReceivedEvent message, IMessageHandlerContext context)
    {
        context.Send(new CommandToSend());
        context.Publish(new EventToPublish());
    }
}