Разрешение общего интерфейса с помощью 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