Как распределить входящие соединения tcplistener по потокам в .NET?

Я бы использовал пул потоков, так вам не придется каждый раз запускать новый поток (поскольку это довольно дорого). Я бы также не стал бесконечно ждать дальнейших подключений, поскольку клиенты могут не закрывать свои подключения. Как вы планируете направлять клиента каждый раз в один и тот же поток?

К сожалению, нет образца.

В книге O'Reilly C# 3.0 есть отличный пример. Вы можете скачать сопутствующий исходный код с сайта http://examples.oreilly.com/9780596516109/CSharp3_0CookbookCodeRTM.zip.

Я считаю, что вы делаете это так же, как и любую другую асинхронную операцию в .NET: вы вызываете версию метода BeginXxx, в данном случае BeginAcceptSocket. Ваш обратный вызов будет выполняться в пуле потоков.

Объединенные потоки обычно масштабируются намного лучше, чем поток на соединение: после того, как вы преодолеете несколько десятков соединений, система будет работать намного сложнее при переключении между потоками, чем при выполнении реальной работы. Кроме того, каждый поток имеет свой собственный стек размером обычно 1 МБ (хотя он зависит от флагов ссылок), который должен находиться в виртуальном адресном пространстве 2 ГБ (в 32-разрядных системах); на практике это ограничивает вас менее чем 1000 потоками.

Я не уверен, использует ли его пул потоков .NET в настоящее время, но в Windows есть объект ядра, называемый портом завершения ввода-вывода, который помогает в масштабируемом вводе-выводе. Вы можете связать потоки с этим объектом, и запросы ввода-вывода (включая прием входящих соединений) могут быть связаны с ним. Когда ввод-вывод завершается (например, приходит соединение), Windows освобождает ожидающий поток, но только если количество выполняемых в данный момент потоков (не заблокированных по какой-либо другой причине) меньше настроенного предела масштабируемости для порта завершения. Обычно вы устанавливаете это значение, кратное количеству ядер.

Я хотел бы предложить другой подход: Мое предложение использует только два потока. * один поток проверяет входящие соединения. * Когда открывается новое соединение, эта информация записывается в общую структуру данных, которая содержит все текущие открытые соединения. * Второй поток перечисляет эту структуру данных и для каждого открытого соединения получает отправленные данные и отправляет ответы.

Это решение является более масштабируемым по потокам, и, если оно реализовано правильно, должно иметь лучшую производительность, чем открытие нового потока для каждого открытого соединения.

Код, который я использовал, выглядит так:

class Server
{
  private AutoResetEvent connectionWaitHandle = new AutoResetEvent(false);

  public void Start()
  {
    TcpListener listener = new TcpListener(IPAddress.Any, 5555);
    listener.Start();

    while(true)
    {
      IAsyncResult result =  listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
      connectionWaitHandle.WaitOne(); // Wait until a client has begun handling an event
      connectionWaitHandle.Reset(); // Reset wait handle or the loop goes as fast as it can (after first request)
    }
  }


  private void HandleAsyncConnection(IAsyncResult result)
  {
    TcpListener listener = (TcpListener)result.AsyncState;
    TcpClient client = listener.EndAcceptTcpClient(result);
    connectionWaitHandle.Set(); //Inform the main thread this connection is now handled

    //... Use your TcpClient here

    client.Close();
  }
}