2

我正在使用 IoC 容器SimpleInjector。我知道不应该重新创建单例,因为这不是他们的目的,但我的问题在于 WCF,当它进入故障状态时,根据多次读数,它无法恢复,需要创建一个新实例。

我有一个名为的类CoreServiceService,它使用两个 WCF 服务。

  1. CoreService
  2. ECLService

我希望这些服务是单例的,因为我将进行大量调用CoreServiceSession并创建这些 WCF 服务太昂贵并且需要很多时间,在创建之后,它们要快得多。

我正在像这样注册它们:

container.Register(() => new SessionAwareEclServiceClient(binding, eclServiceRemoteAddress), Lifestyle.Singleton);

container.Register(() => new SessionAwareCoreServiceClient(binding, coreServiceRemoteAddress), Lifestyle.Singleton);

container.Register(typeof(ICoreServiceSession), typeof(CoreServiceSession), Lifestyle.Scoped);

我的问题是,ECLService如果无法检索某些内容,则会进入故障连接,在这种情况下,我会调用.Abort()并关闭连接。但是下次我调用我的服务时,ECLServiceWCF 服务一直处于该Faulted状态(因为它是单例),所以我需要一种方法来重新创建连接。

我尝试过类似的东西:

coreServiceSession.EclServiceClient = (SessionAwareEclServiceClient)container.GetInstance(typeof(SessionAwareEclServiceClient));

但是,当然,它给了我同样的例子。

我也尝试使用这个初始化程序:

container.RegisterInitializer<ICoreServiceSession>(coreServiceSession =>
{
    if (coreServiceSession.EclServiceClient.State == CommunicationState.Faulted)
    {
        coreServiceSession.EclServiceClient.Abort();
        coreServiceSession.EclServiceClient = null;
        coreServiceSession.EclServiceClient = (SessionAwareEclServiceClient)container.GetInstance(typeof(SessionAwareEclServiceClient));
    }
}

同样的事情,我尝试使用而不是 container.GetInstance,这个:

coreServiceSession.EclServiceClient = new SessionAwareEclServiceClient(binding, eclServiceRemoteAddress);

一样的东西。有什么想法/选择吗?

在这种情况下有什么方法可以强制获取一个新实例?

更新

这是课程的一部分CoreServiceSession

public class CoreServiceSession : ICoreServiceSession
{
    public CoreServiceSession(ISessionAwareCoreService sessionAwareEclServiceClient, SessionAwareCoreServiceClient sessionAwareCoreServiceClient)
    {
        EclServiceClient = sessionAwareEclServiceClient;
        CoreServiceClient = sessionAwareCoreServiceClient;
    }

    public ISessionAwareCoreService EclServiceClient { get; set; }

    public SessionAwareCoreServiceClient CoreServiceClient { get; set; }

    public string CreateOrGetStubUris(string eclItemUri)
    {
        var stubInfo = EclServiceClient.CreateOrGetStubUris(new List<string> { eclItemUri }).FirstOrDefault();
    }
}

提前致谢。吉列尔莫

4

1 回答 1

1

@ScottHannen 已经在他的评论中给出了答案:不要将频道注册为单例:创建它们并不昂贵,只有频道工厂才是。

事实上,您根本不应该将 WCF 客户端对象注入到构造函数中。将它们注入构造函数意味着它们是一个有用的抽象,可用于拦截、模拟或替换,而使用此类客户端的类通常与 WCF 强耦合。

因此,与其将它们注入构造函数,不如让消费者在内部使用ChannelFactory. 即使这样ChannelFactory通常也不必注入,您可以在私有静态字段中对其进行新的注入。

这就是你的CoreServiceSession样子:

public class CoreServiceSession : ICoreServiceSession
{
    private static readonly ChannelFactory factory =
        new ChannelFactory<ISessionAwareCoreService>(myBinding, myEndpoint);

    public string CreateOrGetStubUris(string eclItemUri)
    {
        var client = factory.CreateChannel();

        try
        {
            return EclServiceClient.CreateOrGetStubUris(
                new List<string> { eclItemUri }).FirstOrDefault();
        }
        finally
        {
            try
            {
                ((IDisposable)client).Dispose();
            }
            catch
            {
                // We need to swallow exceptions thrown by Dispose. 
                // See: https://marcgravell.blogspot.com/2008/11/dontdontuse-using.html
            }
        }
    }
}
于 2017-10-10T07:45:56.823 回答