使用约定非干扰模式找不到NServiceBus通用消息处理程序

问题描述

我正在将dotnetcore2.1应用程序与aspnetcore 2.1.1一起使用。 另外，我正在按照文档中的建议使用Community.NServiceBus.WebHost托管该版本。

我试图拥有一个干净的体系结构，使其不直接依赖于NServiceBus，因此我在命令中使用了适配器和非干扰模式。我收到以下异常，并立即尝试重试。

system.invalidOperationException: No handlers Could be found for message type: WebApi.Models.Commands.ProcessBlob

这是我使用此自定义扩展名注册NServiceBus的方式

public static IServiceCollection AddNServiceBus(this IServiceCollection services,IConfiguration configuration)
{
    var endpointName = configuration.GetValue<string>("NServiceBus:EndpointName");
    var connectionString = configuration.GetValue<string>("NServiceBus:ConnectionString");

    var endpointConfiguration = new EndpointConfiguration(endpointName);
    endpointConfiguration.SendFailedMessagesTo("error");
    endpointConfiguration.EnableInstallers();
    var conventions = endpointConfiguration.Conventions();
    conventions.DefiningMessagesAs(type => type.Namespace != null && type.Namespace.Contains(".Commands"));

    //var transport = endpointConfiguration.UseTransport<AzureServiceBusTransport>();
    //transport.ConnectionString(connectionString);
    endpointConfiguration.UseTransport<LearningTransport>();
    services.AddNServiceBus(endpointConfiguration);
    
    services.AddTransient<ICommandBus,CommandBusAdapter>();

    services.AddTransient<ICommandHandler<ProcessBlob>,ProcessBlobHandler>();
    
    return services;
}

然后在Startup.cs

public void ConfigureServices(IServiceCollection services)
{
    services
        .AddNServiceBus(Configuration)
        .AddMvc()
        .SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
}

我有以下用于发送命令的适配器

public class CommandBusAdapter
    : ICommandBus
{
    private readonly IMessageSession _messageSession;

    public CommandBusAdapter(IMessageSession messageSession)
    {
        _messageSession = messageSession;
    }

    public Task Send<TCommand>(TCommand command) 
        where TCommand : class
    {
        return _messageSession.SendLocal(command);
    }
}

这是我的通用消息处理程序适配器，用于处理ANY命令并使用服务定位器确定要委派的特定命令处理程序。

public class CommandHandlerAdapter<TCommand>
    : IHandleMessages<TCommand> 
    where TCommand : class
{
    private readonly IServiceProvider _serviceProvider;

    public CommandHandlerAdapter(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public Task Handle(TCommand message,IMessageHandlerContext context)
    {
        var commandHandlerType = typeof(ICommandHandler<TCommand>);
        var commandHandler = (ICommandHandler<TCommand>)_serviceProvider.GetService(commandHandlerType);
        return commandHandler.Handle(message);
    }
}

如您所见，命令处理程序适配器未注册（我希望NServiceBus能够检测到它并自动注册它，即使它是通用的）。 我使用约定，命令消息是包含.Commands

的命名空间下的任何DTO。

我是否正在尝试一些不可能的事情，或者有什么变通办法可以让我继续使用这种通用的命令处理程序适配器方法？

---

更新1 ：换句话说，以下处理程序可以正常运行而无需任何其他注册。

public class CommandHandlerAdapter
    : IHandleMessages<ProcessBlob>
{
    private readonly ICommandHandler<ProcessBlob> _processBlobHandler;

    public CommandHandlerAdapter(ICommandHandler<ProcessBlob> processBlobHandler)
    {
        _processBlobHandler = processBlobHandler;
    }

    public Task Handle(ProcessBlob processBlob,IMessageHandlerContext context)
    {
        return _processBlobHandler.Handle(processBlob);
    }
}

但是我想要一种通用的命令处理程序适配器，因为它对每个命令都执行相同的操作（获取特定命令处理程序的实例并委托它来处理消息）

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）