Внедрение зависимостей в реализацию IErrorHandler
Я реализую IErrorHandler
для того, чтобы централизовать всю обработку ошибок для моей службы WCF в одном месте. Это работает довольно хорошо:
public class ServiceErrorHandler : IErrorHandler
{
public bool HandleError(Exception error)
{
// ..Log..
}
public void ProvideFault(Exception error, MessageVersion version, ref Message fault)
{
// ..Provide fault..
}
}
Теперь мы используем Ninject для внедрения зависимостей в оставшуюся часть службы, и я хотел бы сделать то же самое здесь. Так как WCF создает объекты на основе моей конфигурации, и я не думаю, что у меня есть какие-либо зацепки в этом процессе, мне нужно использовать внедрение свойства:
[Inject]
public ILoggingService Logger { get; set; }
Тем не менее, это, кажется, никогда не вводится. Я пытался использовать расширения MVC Ninject, чтобы установить ServiceErrorHandler
чтобы впрыскивать как фильтр, но это, похоже, не сработало. Есть ли способ сделать это?
1 ответ
Поздний ответ, но вы можете ввести зависимости в IErrorHandler
создав свой собственный ServiceHost
скажем TestServiceHost
,
В вашем TestServiceHost
вам нужно сделать:
- Реализуйте конструктор с
IErrorHandler
параметр. - Внутри создайте частный вложенный класс с именем
ErrorHandlerBehaviour
*, который должен реализовывать обаIServiceBehavior
а такжеIErrorHandler
, Он также должен иметь конструктор сIErrorHandler
параметр. - Override
OnStarting()
метод, куда вы добавитеErrorHandlerBehaviour
обслуживать поведение. Все поведения должны быть добавлены доbase.OnStarting()
,
* идея пришла из примера Ювала Лоуи в книге "Программирование служб WCF". Более подробную информацию о неисправностях и расширениях ошибок вы можете найти там.
Вот рабочее консольное приложение хоста. Там я не использую IoC, просто Pure DI, но вы можете легко разрешить регистратор с любым IoC:
using System;
using System.Collections.ObjectModel;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
namespace ConsoleHost
{
class Program
{
static void Main(string[] args)
{
var logger = new DummyLogger();
var errorHandler = new TestErrorHandler(logger);
ServiceHost host = new TestServiceHost(errorHandler, typeof(TestService), new Uri("net.tcp://localhost:8002"));
host.Open();
Console.WriteLine("Press enter to exit");
Console.ReadKey();
}
}
[ServiceContract]
public interface ITestService
{
[OperationContract]
string Test(int input);
}
public class TestService : ITestService
{
public string Test(int input)
{
throw new Exception("Test exception!");
}
}
public class TestErrorHandler : IErrorHandler
{
private ILogger Logger { get; }
public TestErrorHandler(ILogger logger)
{
Logger = logger;
}
public bool HandleError(Exception error)
{
Logger.Log(error.Message);
return true;
}
public void ProvideFault(Exception error, MessageVersion version, ref Message fault)
{
FaultException fe = new FaultException();
MessageFault message = fe.CreateMessageFault();
fault = Message.CreateMessage(version, message, null);
}
}
public class TestServiceHost : ServiceHost
{
private readonly IErrorHandler errorHandler;
public TestServiceHost(IErrorHandler errorHandler, Type serviceType, params Uri[] baseAddresses)
: base(serviceType, baseAddresses)
{
this.errorHandler = errorHandler;
}
protected override void OnOpening()
{
Description.Behaviors.Add(new ErrorHandlerBehaviour(errorHandler));
base.OnOpening();
}
class ErrorHandlerBehaviour : IServiceBehavior, IErrorHandler
{
private readonly IErrorHandler errorHandler;
public ErrorHandlerBehaviour(IErrorHandler errorHandler)
{
this.errorHandler = errorHandler;
}
bool IErrorHandler.HandleError(Exception error)
{
return errorHandler.HandleError(error);
}
void IErrorHandler.ProvideFault(Exception error, MessageVersion version, ref Message fault)
{
errorHandler.ProvideFault(error, version, ref fault);
}
void IServiceBehavior.ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
{
foreach (ChannelDispatcher channelDispatcher in serviceHostBase.ChannelDispatchers)
{
channelDispatcher.ErrorHandlers.Add(this);
}
}
void IServiceBehavior.AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection<ServiceEndpoint> endpoints, BindingParameterCollection bindingParameters)
{
}
void IServiceBehavior.Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
{
}
}
}
// Dummy logger
public interface ILogger
{
void Log(string input);
}
public class DummyLogger : ILogger
{
public void Log(string input) => Console.WriteLine(input);
}
}
И конфигурация:
<system.serviceModel>
<services>
<service name="ConsoleHost.TestService">
<endpoint address="net.tcp://localhost:8002/TestService"
binding="netTcpBinding"
contract="ConsoleHost.ITestService" />
</service>
</services>
</system.serviceModel>
Btw. Убедитесь, что вы добавили System.Runtime.Serialization
к вашим ссылкам