multithread NamePipeServer in C#

Question

Hi
voglio usare NamedPipeServerStream che è nuovo da .NET 3.5 per la comunicazione NamedPipe. Voglio scrivere server pipe multi-thread. è gestito di default o dovrei scrivere il codice per quello. il mio server pipe dovrebbe gestire più richieste alla volta

qualsiasi soluzione o codice?

Answer 1

Ogni istanza NamedPipeServerStream è un'implementazione Stream che include un handle per un'istanza di una named pipe. È possibile (e un server pipe multithreading avrà) più istanze di NamedPipeServerStream per la stessa named pipe: ognuna avvolge un handle in un'istanza diversa della named pipe, servendo un client diverso. Le istanze di named pipe (anche per la stessa pipe) sono tenute separate dal sistema operativo, quindi non è necessario alcun codice esplicito per mantenere separate le comunicazioni di ciascun client con il server.

Quello che è necessario codificare esplicitamente è il modello di threading per il server. L'approccio più semplice al multithreading del server è spiegato in this SO answer, che include un modello di pseudo-codice. Implementazioni più scalabili, se è necessario supportare un numero elevato di chiamanti concorrenti, utilizza il pooling di thread e i metodi asincroni invece di creare un thread dedicato per ciascuna connessione.

Answer 2

NamedPipeServerStream è una connessione point-to-point. È necessario sincronizzare personalmente le chiamate, ad esempio le chiamate scritte in coda e il server che legge dalla coda sincronizzata e effettua le chiamate.

Answer 3

È possibile scrivere un server pipe multi thread creando ripetutamente un NamedPipeServerStream e attendendo una connessione, quindi creando un thread per quell'istanza di NamedPipeServerStream.

È possibile avere solo 254 client simultanei secondo la documentazione MSDN .NET collegata di seguito. Per le API Win32, tuttavia, è possibile passare un valore speciale per ottenere un numero illimitato in base alle risorse di sistema. Sembra che la documentazione MSDN sia errata come indicato di seguito.

Il codice qui sotto non è testato quindi per favore non semplicemente copiare e incollare per l'uso in produzione, senza prove:

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 
      } 
     }