.NET 3.5、VS2008、使用 BasicHttpBinding 的 WCF 服务

我在 Windows 服务中托管了一个 WCF 服务。当 Windows 服务关闭时，由于升级、定期维护等，我需要优雅地关闭我的 WCF 服务。 WCF 服务的方法最多可能需要几秒钟才能完成，典型的数量是每秒 2-5 次方法调用。我需要以允许任何先前调用方法完成的方式关闭 WCF 服务，同时拒绝任何新调用。通过这种方式，我可以在大约 5-10 秒内达到安静状态，然后完成 Windows 服务的关闭周期。

调用 ServiceHost.Close似乎是正确的方法，但它会立即关闭客户端连接，而无需等待任何正在进行的方法完成。我的 WCF 服务完成了它的方法，但是没有人可以向其发送响应，因为客户端已经断开连接。这是this question建议的解决方案.

这是事件的顺序:

1. 客户端调用服务方法，使用 VS 生成的代理类
2. 服务开始执行服务方法
3. 服务收到关闭请求
4. 服务调用 ServiceHost.Close(或 BeginClose)
5. 客户端断开连接，并收到 System.ServiceModel.CommunicationException
6. 服务完成服务方法。
7. 最终服务检测到它没有更多工作要做(通过应用程序逻辑)并终止。

我需要的是让客户端连接保持打开状态，以便客户端知道他们的服务方法已成功完成。现在他们只是得到一个关闭的连接，不知道服务方法是否成功完成。在使用 WCF 之前，我使用的是套接字，并且能够通过直接控制套接字来实现。 (即停止接受循环，同时仍在进行接收和发送)

关闭主机 HTTP 端口很重要，这样上游防火墙可以将流量定向到另一个主机系统，但现有连接保持打开状态以允许完成现有方法调用。

有没有办法在 WCF 中完成此操作？

我尝试过的事情:

1. ServiceHost.Close() - 立即关闭客户端
2. ServiceHost.ChannelDispatchers - 对每个调用 Listener.Close() - 似乎没有做任何事情
3. ServiceHost.ChannelDispatchers - 调用 CloseInput() - 立即关闭客户端
4. 覆盖 ServiceHost.OnClosing() - 让我延迟关闭，直到我决定可以关闭，但在此期间允许新连接
5. 使用 technique described here 删除端点.这会抹去一切。
6. 运行网络嗅探器以观察 ServiceHost.Close()。主机只是关闭连接，没有发送响应。

谢谢

编辑:不幸的是，我无法实现系统正在关闭的应用程序级咨询响应，因为该领域的客户端已经部署。 (我只控制服务，不控制客户端)

编辑:我使用 Redgate Reflector 查看 Microsoft 的 ServiceHost.Close 实现。不幸的是，它调用了一些我的代码无法访问的内部帮助器类。

编辑:我还没有找到我正在寻找的完整解决方案，但本杰明关于在进入服务方法之前使用 IMessageDispatchInspector 拒绝请求的建议最接近。

最佳答案

猜测:

您是否尝试过在运行时(从端点)获取绑定(bind)，将其转换为 BasicHttpBinding 并在那里(重新)定义属性？

我的最佳猜测:

• 打开超时
• 最大接收消息大小
• 读者配额

这些可以根据文档在运行时设置，并且似乎允许所需的行为(阻止新客户端)。不过，这对“上游防火墙/负载平衡器需要重新路由”部分没有帮助。

最后的猜测:你能(文档说是的，但我不确定后果是什么)根据需要将端点的地址重新定义为本地主机地址吗？ 这也可以作为防火墙主机的“端口关闭”，如果它无论如何都不会杀死所有客户端..

编辑:在考虑上述建议和有限测试的同时，我开始使用目前看起来很有希望的消息检查器/行为组合:

public class WCFFilter : IServiceBehavior, IDispatchMessageInspector {
    private readonly object blockLock = new object();
    private bool blockCalls = false;

    public bool BlockRequests {
        get {
            lock (blockLock) {
                return blockCalls;
            }
        }
        set {
            lock (blockLock) {
                blockCalls = !blockCalls;
            }   
        }

    }

    public void Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase) {          
    }

    public void AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection<ServiceEndpoint> endpoints, BindingParameterCollection bindingParameters) {         
    }

    public void ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase) {
        foreach (ChannelDispatcher channelDispatcher in serviceHostBase.ChannelDispatchers) {
            foreach (EndpointDispatcher endpointDispatcher in channelDispatcher.Endpoints) {
                endpointDispatcher.DispatchRuntime.MessageInspectors.Add(this);
            }
        } 
    }

    public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext) {
        lock (blockLock) {
            if (blockCalls)
                request.Close();
        }
        return null;
    }

    public void BeforeSendReply(ref Message reply, object correlationState) {           
    }
}

忘掉蹩脚的锁用法等，而是将其与非常简单的 WCF 测试(返回一个带有 Thread.Sleep 的随机数)一起使用，如下所示:

var sh = new ServiceHost(new WCFTestService(), baseAdresses);

var filter = new WCFFilter();
sh.Description.Behaviors.Add(filter);

然后翻转 BlockRequests 属性，我得到以下行为(同样:这当然是一个非常非常简化的示例，但我希望它无论如何对您有用):

//我产生了 3 个线程 求一个号码..
求一个号码..
求一个号码..
//一个传入请求的服务器端日志
收到号码请求。
//主循环翻转“阻止一切”bool
从这里开始阻止访问。
//之后还有 3 个客户端，以备不时之需
求一个号码..
求一个号码..
求一个号码..
//第一个请求(带有服务器端日志，见上文)成功完成
已收1569129641
//所有其他消息还没有到达服务器并因错误而死
block 后生成的客户端请求出错。
block 后生成的客户端请求出错。
block 后生成的客户端请求出错。
block 前客户端请求错误。
block 前客户端请求错误。

关于c# - WCF，BasicHttpBinding : Stop new connections but allow existing connections to continue，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/1922551/