Разрешение общего интерфейса с помощью Autofac

Это мои занятия:

   public interface ICommandDtc{
        string Command { get; set; }
        string Xml { get; set; }
    }
    public interface ICommandHandler<in TCommand>
        where TCommand : ICommandDtc
    {
        CommandResult Execute(TCommand command);
        Task<CommandResult> ExecuteAsync(TCommand command);
    }

    public class CommandResult
    {
        public string Description { get; set; }
        public int Code { get; set; }
    }

    public interface ICommandBus{
    Task<CommandResult> SubmitAsync<TCommand>(TCommand command) where TCommand : ICommandDtc;
    CommandResult Submit<TCommand>(TCommand command) where TCommand : ICommandDtc;
    }

    public class CommandBus : ICommandBus{
        private readonly ILifetimeScope _container;
        public CommandBus(ILifetimeScope scope){
            _container = scope;
        }
        public async Task<CommandResult> SubmitAsync<TCommand>(TCommand command)
            where TCommand : ICommandDtc{
            var commandHandler = _container.Resolve<ICommandHandler<TCommand>>();
            return await commandHandler.ExecuteAsync(command);
        }
        public CommandResult Submit<TCommand>(TCommand command)
            where TCommand : ICommandDtc
        {
        **//its worked**
            var commandHandler = _container.Resolve<ICommandHandler<IntegerationCommand>>();
        **//exception**
            var commandHandler2 = _container.Resolve<ICommandHandler<TCommand>>();
            return commandHandler2.Execute(command);
        }
    }

    public abstract class CommandBase<TCommand> : ICommandHandler<TCommand>
        where TCommand : ICommandDtc{
        public async Task<CommandResult> ExecuteAsync(TCommand command){
            var commandResult = new CommandResult();
            try{
                commandResult = await InternalExecuteAsync(command);
            }

            catch (Exception exp){

            }
            return commandResult;
        }
        public CommandResult Execute(TCommand command)
        {
            var commandResult = new CommandResult();
            try
            {
                commandResult =  InternalExecute(command);
            }
            catch (Exception exp)
            {
            }
            return commandResult;
        }

        protected abstract Task<CommandResult> InternalExecuteAsync(TCommand command);
        protected abstract CommandResult InternalExecute(TCommand command);
    }//sample class 1
    public class IntegerationCommandHandler : CommandBase<IntegerationCommand>
    {
        protected override Task<CommandResult> InternalExecuteAsync(IntegerationCommand command){
            throw new System.NotImplementedException();
        }
        protected override CommandResult InternalExecute(IntegerationCommand command){
            switch (command.Command) {
                case "SendDocument":
                    return SendDocument(command.Xml);
            }
            return new CommandResult {Code = 5,Description = ""};
        }
        private CommandResult SendDocument(string xml){
            throw new System.NotImplementedException();
        }
    }//sample class 2
 public class SocialOperationCommandHandler : CommandBase<SocialOperationCommand>
    {
        protected override Task<CommandResult> InternalExecuteAsync(SocialOperationCommand command){
            throw new System.NotImplementedException();
        }
        protected override CommandResult InternalExecute(SocialOperationCommand command){
            throw new System.NotImplementedException();
        }
    }

и мой автофак:

public static IContainer InitializeBusiness()
{
    if (_lifetimeScope != null)
    {
        _lifetimeScope.Dispose();
        _lifetimeScope = null;
    }
    ConfigureAutoMapper();
    var builder = new ContainerBuilder();
    builder.RegisterType<Bootstrapper>().AsSelf();
    var assemblies = Assemblies.GetBusinessAssemblies.ToArray();
    builder.RegisterAssemblyTypes(assemblies).AsImplementedInterfaces();
    builder.RegisterAssemblyTypes(Assembly.GetAssembly(typeof(ICommandDtc))).Named<ICommandDtc>(x => x.Name);

    builder.RegisterType<AutoFacValidatorFactory>().As<IValidatorFactory>();

    _container = builder.Build();
    return _container;
}

Я пытался использовать:

try
{
    var addFormDtc=new AddFormDtc {CommandName = "SendDocument",SiteCollectionName = "IntegerationCommand",Xml = "1"};
    var obj = _scope.ResolveNamed<ICommandDtc>(addFormDtc.SiteCollectionName);
    obj.Command = addFormDtc.CommandName;
    obj.Xml = addFormDtc.Xml;
    var commandBus = _scope.Resolve<ICommandBus>();
    return commandBus.Submit(obj);
}
catch (Exception ex){
    comandResult.Code = 0;
    comandResult.Description = ex.Message;
    return comandResult;
}

Но я получаю исключение в этой строке:

var commandHandler2 = _container.Resolve<ICommandHandler<TCommand>>();

когда я попробовал вручную, это сработало:

var commandHandler = _container.Resolve<ICommandHandler<IntegerationCommand>>();

исключение:

Запрошенная служба 'JahadServices.Business.Services.Command.ICommandHandler`1[[JahadServices.Business.Dtos.Command.ICommandDtc, JahadServices.Business.Dtos, Версия =1.0.0.0, Культура = нейтральная, PublicKeyToken=null]]' имеет не был зарегистрирован. Чтобы избежать этого исключения, либо зарегистрируйте компонент для предоставления услуги, проверьте регистрацию службы с помощью IsRegistered(), либо используйте метод ResolveOptional() для разрешения необязательной зависимости.

1 ответ

Решение

Вы пытаетесь решить ICommandHandler<ICommandDtc>, но вы только зарегистрированы ICommandHandler<IntegerationCommand> из этого

 IntegerationCommandHandler : CommandBase<IntegerationCommand>

но ICommandHandler<ICommandDtc> а также ICommandHandler<IntegerationCommand> это разные типы.

Обновить:

Я взял ваше оригинальное решение и сделал следующее: замените это commandBus.Submit(obj); этим

commandBus.GetType().GetMethod(nameof(ICommandBus.Submit))
    .MakeGenericMethod(obj.GetType())
    .Invoke(commandBus, BindingFlags.Public, null, new[] { obj},
     CultureInfo.CurrentCulture);

И это сработало:) Дополнительная информация здесь Вызов универсального метода с аргументом типа, известным только во время выполнения

Небольшое объяснение.

Когда вы вызываете универсальный метод (Submit), тип внутри этого метода зависит от типа указателя переменной. В вашем случае вы сохранили экземпляр IntegerationCommand внутри переменной с типом ICommandDtc. Так, когда вы звоните Submit(ibj), это было похоже на Submit(ibj). Итак, это была первоначальная проблема, что вы вызвали метод с неправильным универсальным параметром. Я просто использовал отражение, чтобы вызвать Submit с правильным универсальным параметром (Submit).

commandBus.GetType()
.GetMethod(nameof(ICommandBus.Submit)) //<- getting Submit<> method
    .MakeGenericMethod(obj.GetType()) //<- set generic parameter, 
                                      // so now it Submit<IntegerationCommand> 
    .Invoke(commandBus, BindingFlags.Public, null, new[] { obj}, //<- invoke method
Другие вопросы по тегам