Многопоточность NamePipeServer в C#

Question

Привет
Я хочу использовать NamedPipeServerStream, который является новичком в .NET 3.5 для обмена сообщениями с именами. Я хочу написать многопоточный сервер трубопроводов. это обрабатывается по умолчанию, или я должен написать для этого код. мой сервер труб должен обрабатывать несколько запросов за раз

любое решение или код?

Answer 1

Каждый экземпляр NamedPipeServerStream представляет собой реализацию Stream, переносящую дескриптор в экземпляр именованного канала. Вы можете (и сервер с многопоточным каналом) иметь несколько экземпляров NamedPipeServerStream для одного и того же именованного канала: каждый переносит дескриптор в другой экземпляр именованного канала, обслуживая другого клиента. Именованные экземпляры pipe (даже для одного и того же канала) хранятся отдельно операционной системой, поэтому нет необходимости в каком-либо явном кодировании, чтобы поддерживать связь каждого клиента с сервером отдельно.

То, что вам нужно явно указать, это модель потоковой передачи для сервера. Самый простой подход к многопоточности сервера объясняется в this SO answer, который включает в себя шаблон псевдокода. Более масштабируемые реализации, если необходимо поддерживать большое количество одновременных вызывающих абонентов, будут использовать пул потоков и асинхронные методы вместо создания выделенного потока для каждого соединения.

Answer 2

NamedPipeServerStream - это точка-точка. Вы сами должны сами синхронизировать вызовы - например, вызовы, написанные в очередь, и ваш сервер читает из синхронизированной очереди и выполняет вызовы.

Answer 3

Вы можете написать многопоточный сервер труб, повторно создавая NamedPipeServerStream и ожидая одного соединения, а затем создавая поток для этого экземпляра NamedPipeServerStream.

У вас может быть только 254 одновременных клиентов, хотя в соответствии с документацией .NET MSDN, приведенной ниже. Для Win32 API, хотя вы можете передать специальное значение, чтобы получить неограниченное количество на основе системных ресурсов. Похоже, что документация MSDN неверна, как указано ниже.

Ниже код не проверяется поэтому, пожалуйста, не просто скопировать и вставить для использования в производстве без тестирования:

public class PipeServer 
    { 
     bool running; 
     Thread runningThread; 
     EventWaitHandle terminateHandle = new EventWaitHandle(false, EventResetMode.AutoReset); 
     public string PipeName { get; set; } 

     void ServerLoop() 
     { 
      while (running) 
      { 
       ProcessNextClient(); 
      } 

      terminateHandle.Set(); 
     } 

     public void Run() 
     { 
      running = true; 
      runningThread = new Thread(ServerLoop); 
      runningThread.Start(); 
     } 

     public void Stop() 
     { 
      running = false; 
      terminateHandle.WaitOne(); 
     } 

     public virtual string ProcessRequest(string message) 
     { 
      return ""; 
     } 

     public void ProcessClientThread(object o) 
     { 
      NamedPipeServerStream pipeStream = (NamedPipeServerStream)o; 

      //TODO FOR YOU: Write code for handling pipe client here 

      pipeStream.Close(); 
      pipeStream.Dispose(); 
     } 

     public void ProcessNextClient() 
     { 
      try 
      { 
       NamedPipeServerStream pipeStream = new NamedPipeServerStream(PipeName, PipeDirection.InOut, 254); 
       pipeStream.WaitForConnection(); 

       //Spawn a new thread for each request and continue waiting 
       Thread t = new Thread(ProcessClientThread); 
       t.Start(pipeStream); 
      } 
      catch (Exception e) 
      {//If there are no more avail connections (254 is in use already) then just keep looping until one is avail 
      } 
     }