如何在WCF应用中正确关闭仅发送型NServiceBus端点

1. 仅发送型端点是否需要关闭？ #

需要。即便端点只负责发送消息，它内部依然维护着队列连接池、内存资源、消息分发上下文等关键资源。如果不主动关闭，这些资源无法被正确释放，长期运行会导致内存泄漏、连接耗尽，甚至影响整个WCF服务的稳定性。尤其是在IIS托管场景下，应用程序池回收时若端点未优雅关闭，还可能出现未处理的消息丢失或队列异常。

2. 如何在WCF服务中实现关闭？ #

WCF本身没有直接的全局服务生命周期钩子，但可以通过以下几种方式实现端点的优雅关闭：

方式一：利用IIS应用程序生命周期（IIS托管场景） #

如果你的WCF服务托管在IIS中，可以在Global.asax里重写应用启动和停止的方法：

public class Global : HttpApplication
{
    private static IEndpointInstance _senderEndpoint;

    protected async void Application_Start(object sender, EventArgs e)
    {
        // 初始化仅发送型端点
        var endpointConfiguration = new EndpointConfiguration("YourSenderEndpoint");
        endpointConfiguration.SendOnly();
        // 补充传输、序列化等必要配置
        _senderEndpoint = await Endpoint.Start(endpointConfiguration);
    }

    protected async void Application_End(object sender, EventArgs e)
    {
        // 优雅关闭端点
        if (_senderEndpoint != null)
        {
            await _senderEndpoint.StopAsync();
        }
    }
}

方式二：自定义服务行为（通用场景） #

通过实现IServiceBehavior和IInstanceContextInitializer，在服务实例的生命周期中管理端点：

public class SenderEndpointBehavior : IServiceBehavior, IInstanceContextInitializer
{
    private static IEndpointInstance _sharedEndpoint;
    private static readonly object _lockObj = new object();

    public void ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
    {
        foreach (ChannelDispatcher cd in serviceHostBase.ChannelDispatchers)
        {
            cd.Endpoints[0].Dispatcher.InstanceContextInitializers.Add(this);
        }
    }

    public void Initialize(InstanceContext instanceContext, Message message)
    {
        // 确保端点仅初始化一次
        if (_sharedEndpoint == null)
        {
            lock (_lockObj)
            {
                if (_sharedEndpoint == null)
                {
                    var config = new EndpointConfiguration("YourSenderEndpoint");
                    config.SendOnly();
                    _sharedEndpoint = Endpoint.Start(config).GetAwaiter().GetResult();
                }
            }
        }

        // 将端点注入WCF服务实例
        var serviceInstance = instanceContext.GetServiceInstance(message) as YourWcfService;
        serviceInstance.SenderEndpoint = _sharedEndpoint;
    }

    // 实现IServiceBehavior的空方法
    public void AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection<ServiceEndpoint> endpoints, BindingParameterCollection bindingParameters) {}
    public void Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase) {}

    // 提供端点关闭方法，在服务停止时调用
    public static async Task ShutdownEndpoint()
    {
        if (_sharedEndpoint != null)
        {
            await _sharedEndpoint.StopAsync();
            _sharedEndpoint = null;
        }
    }
}

之后在WCF服务的配置或代码中注册该行为，并在服务宿主关闭时调用SenderEndpointBehavior.ShutdownEndpoint()。

方式三：自托管WCF场景 #

如果是自托管的WCF服务，可以通过ServiceHost的事件触发端点关闭：

var serviceHost = new ServiceHost(typeof(YourWcfService));
serviceHost.Closing += async (sender, e) =>
{
    if (_senderEndpoint != null)
    {
        await _senderEndpoint.StopAsync();
    }
};
serviceHost.Open();

内容的提问来源于stack exchange，提问作者JAD