c# - 关于 ResetEvents 和 Threading，此 tcp 监听器代码是否正确实现？

Question

我觉得这段代码没有发挥应有的作用。我把它拼凑在一起并且可以工作，但我不完全理解异步线程和 ResetEvents。

当我使用发送 100 个连接的多线程客户端测试此监听器时，响应时间从前 10 次左右的 300 毫秒增加到最后 50 次的 2-3 秒。

1.) 线程和重置事件处理程序是否按设计实现？

2.) 有什么方法可以加快高流量突发的响应时间吗？

3.) 在另一个线程上运行 tcpConnectionLogic 是否有意义？

我有一个全局范围内的手动和自动重置事件:

   private AutoResetEvent connectionWaitHandle = new AutoResetEvent(false);
   private ManualResetEvent _shutdownEvent = new ManualResetEvent(false);

我有一个在新线程上启动 tcp 监听器的 Windows 服务

protected override void OnStart(string[] args)
{
    _mainThread = new Thread(ThreadListener_Begin);

    _mainThread.Name = "EMServiceThread";
    _mainThread.IsBackground = false;
    _mainThread.Start();
}

我的线程运行一个循环，等待手动重发事件发出关闭信号。

private void ThreadListener_Begin()
{
    TcpListener listener = null;
    listener = new TcpListener(IPAddress.Parse("172.16.30.248"), 10010);

    listener.ExclusiveAddressUse = false;
    listener.Start();

        while (!_shutdownEvent.WaitOne(0))
        {
            IAsyncResult result = listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
            connectionWaitHandle.WaitOne();
        }
}

最后，当一个连接进来时，我接受它并将它传递给处理请求的一种逻辑层。

private void HandleAsyncConnection(IAsyncResult result)
{ 
  TcpListener listener = (TcpListener)result.AsyncState;

  connectionWaitHandle.Set();

  TcpClient c = listener.EndAcceptTcpClient(result);

  var _tcpConnectedLogic = new TcpConnectionLogic(c);

  _tcpConnectedLogic.BadRequestAlert += _serviceLogic_BadRequestAlert;
  _tcpConnectedLogic.RequestDecodedAlert += _tcpConnectedLogic_RequestDecodedAlert;
  _tcpConnectedLogic.Start();

    }

编辑当我停止服务时，我的线程并没有像我预期的那样关闭。相反，它最终会中止。为什么？我怎样才能让它优雅地关闭？

protected override void OnStop()
{
    WriteToEventLog("Stop Command Received" + CurrentTimeStamp, entryType: EventLogEntryType.Information);
    WriteToLogFile("Stop Command Received @ " + CurrentTimeStamp);
    _shutdownEvent.Set();

    if (!_mainThread.Join(4000))
    {
        WriteToEventLog("OnStop: Aborting thread, Join did not work.  This is not preferred.", entryType: EventLogEntryType.Warning);
        _mainThread.Abort();
    }
}

Answer 1

在这个区 block 中

while (!_shutdownEvent.WaitOne(0))
{
    IAsyncResult result = listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
    connectionWaitHandle.WaitOne();
}

您基本上是在循环中接受客户端，因为您通过等待 connectionWaitHandle 来阻塞线程。你也可以忘记异步的东西，只做:

while (!_shutdownEvent.WaitOne(0))
{                
     var client = listener.AcceptTcpClient();
     // start your logic in separate thread                
}

我并不是说您应该这样做，只是请注意，您当前的“异步”实现与同步实现相比没有任何好处。

然后，由于 connectionWaitHandle 上的相同阻塞，您遇到了中止线程的问题。假设例如你刚刚启动你的监听器并且没有客户端连接过。然后客户端在 connectionWaitHandle 上被阻塞，而您设置 _shutdownEvent 的事实也无济于事 - 主线程将永远没有机会检查它。

修复它的最佳选择是使用基于任务的方法:

class Listener {
    // we don't use cancellation tokens because AcceptTcpClientAsync does not support them anyway
    private volatile bool _shutdown;
    private TcpListener _listener;

    public async Task Start() {
        _listener = new TcpListener(IPAddress.Parse("127.0.0.1"), 10010);
        _listener.ExclusiveAddressUse = false;
        _listener.Start();
        while (!_shutdown) {
            TcpClient client = null;
            try {
                client = await _listener.AcceptTcpClientAsync();
            }
            catch (ObjectDisposedException) {
                // will be thrown when you stop listener   
            }
            if (client != null) {
                var tcpConnectedLogic = new TcpConnectionLogic(client);
                // start processing on thread pool thread if necessary
                // don't wait for it to finish - you need to accept more connections
                tcpConnectedLogic.StartAsync();
            }
        }
    }

    public void Stop() {
        _shutdown = true;
        _listener.Stop();
    }
}