调用 BeginAcceptTcpClient 后停止 TcpListener

我有这个代码...

internal static void Start()
{
    TcpListener listenerSocket = new TcpListener(IPAddress.Any, 32599);
    listenerSocket.Start();
    listenerSocket.BeginAcceptTcpClient(new AsyncCallback(AcceptClient), null);
}

然后我的回调函数看起来像这样......

private static void AcceptClient(IAsyncResult asyncResult)
{
    MessageHandler handler = new MessageHandler(listenerSocket.EndAcceptTcpClient(asyncResult));
    ThreadPool.QueueUserWorkItem((object state) => handler.Process());
    listenerSocket.BeginAcceptTcpClient(new AsyncCallback(AcceptClient), null);
}

现在，我调用 BeginAcceptTcpClient，然后一段时间后我想停止服务器。为此，我一直在调用 TcpListener.Stop() 或 TcpListener.Server.Close()。然而，这两个都执行我的 AcceptClient 函数。当我调用 EndAcceptTcpClient 时，这会引发异常。解决这个问题的最佳实践方法是什么？我可以在调用 stop 后放置一个标志来停止 AcceptClient 的执行，但我想知道我是否遗漏了一些东西。

Update 1

目前我已经通过将代码更改为如下所示来修补它。

private static void AcceptClient(IAsyncResult asyncResult)
{
     if (!shutdown)
     {
          MessageHandler handler = new MessageHandler(listenerSocket.EndAcceptTcpClient(asyncResult));
          ThreadPool.QueueUserWorkItem((object state) => handler.Process());
          listenerSocket.BeginAcceptTcpClient(new AsyncCallback(AcceptClient), null);
     }
}

private static bool shutdown = false;
internal static void Stop()
{
     shutdown = true;
     listenerSocket.Stop();
}

Update 2

我更改了它以实现 Spencer Ruport 的答案。

private static void AcceptClient(IAsyncResult asyncResult)
{
    if (listenerSocket.Server.IsBound)
    {
            MessageHandler handler = new MessageHandler(listenerSocket.EndAcceptTcpClient(asyncResult));
            ThreadPool.QueueUserWorkItem((object state) => handler.Process());
            listenerSocket.BeginAcceptTcpClient(new AsyncCallback(AcceptClient), null);
    }
}

我自己刚刚遇到这个问题，我相信您当前的解决方案不完整/不正确。不保证检查之间的原子性IsBound以及随后的调用EndAcceptTcpClient()。如果侦听器是，您仍然可以获得异常Stop()介于这两个陈述之间。你没有说你得到了什么例外，但我认为这和我得到的例外是一样的，ObjectDisposedException（抱怨底层套接字已被释放）。

您应该能够通过模拟线程调度来检查这一点：

• 在后面的行上设置断点IsBound检查你的回调
• 冻结遇到断点的线程（“线程”窗口 -> 右键单击​​“冻结”）
• 运行/触发调用的代码TcpListener.Stop()
• 闯入并逐步通过EndAcceptTcpClient()称呼。你应该看到ObjectDisposedException.

IMO 理想的解决方案是微软抛出一个不同的异常EndAcceptTcpClient在这种情况下，例如ListenCanceledException或类似的东西。

事实上，我们必须从以下内容推断发生了什么ObjectDisposedException。只需捕获异常并采取相应的行为即可。在我的代码中，我默默地吃掉了异常，因为我在其他地方有代码正在执行真正的关闭工作（即调用的代码）TcpListener.Stop()首先）。无论如何，您应该已经在该区域进行了异常处理，因为您可以获得各种SocketExceptions。这只是将另一个 catch 处理程序添加到该 try 块上。

我承认我对这种方法感到不舒服，因为原则上捕获可能是误报，其中存在真正的“坏”对象访问。但另一方面，没有太多的对象访问EndAcceptTcpClient()否则可能会触发此异常的调用。我希望。

这是我的代码。这是早期/原型的东西，忽略控制台调用。

    private void OnAccept(IAsyncResult iar)
    {
        TcpListener l = (TcpListener) iar.AsyncState;
        TcpClient c;
        try
        {
            c = l.EndAcceptTcpClient(iar);
            // keep listening
            l.BeginAcceptTcpClient(new AsyncCallback(OnAccept), l);
        }
        catch (SocketException ex)
        {
            Console.WriteLine("Error accepting TCP connection: {0}", ex.Message);

            // unrecoverable
            _doneEvent.Set();
            return;
        }
        catch (ObjectDisposedException)
        {
            // The listener was Stop()'d, disposing the underlying socket and
            // triggering the completion of the callback. We're already exiting,
            // so just return.
            Console.WriteLine("Listen canceled.");
            return;
        }

        // meanwhile...
        SslStream s = new SslStream(c.GetStream());
        Console.WriteLine("Authenticating...");
        s.BeginAuthenticateAsServer(_cert, new AsyncCallback(OnAuthenticate), s);
    }