TCP C＃ソケットサーバーで複数のアクティブな接続を処理する方法は？

Question

マイソケットサーバは、これまでのところ非常に単純です：

 public static void listen() 
    { 
     TcpListener server = null; 
     IPAddress address = IPAddress.Parse("127.0.0.1"); 
     try 
     { 
      server = TcpListener.Create(5683); 
      server.Start(); 

     } 
     catch (Exception e) 
     { 
      Console.WriteLine(e.StackTrace); 
     } 


     while (true) 
     { 
      Thread.Sleep(10); 
      TcpClient client = server.AcceptTcpClient(); 
      Console.WriteLine("Accepted Client"); 

      Thread thread = new Thread (new ParameterizedThreadStart(SwordsServer.ClientHandler)); 
      thread.IsBackground = true; 
      thread.Start(client); 
     } 
    } 

    public static void ClientHandler(object c) 
    { 
     TcpClient client = (TcpClient)c; 
     NetworkStream netstream = client.GetStream(); 
     bool connected = true; 
     while (connected) 
     { 
      Thread.Sleep(10); 
      try 
      { 
       byte[] bytes = new byte[client.ReceiveBufferSize];     
       netstream.Read(bytes, 0, bytes.Length); 
       Console.WriteLine("got data"); 
       netstream.Write(bytes, 0, bytes.Length); 

      } 
      catch (Exception e) 
      { 
       connected = false; 
       Console.WriteLine(e); 
       Console.WriteLine(e.StackTrace); 
      } 
     } 
    } 

私の質問は、概念レベルで、どのようにそれぞれの固有clientのタブを続けるだろうし、特定のクライアントに他のスレッドから更新を送信されますか？例えば

、私はそれを放送するのではなく、そのクライアントに手を差し伸べるんどのように特定のクライアントのためのデータを、持っている場合は？または、クライアントがもはや接続されていない場合、どのように伝えることができますか？

ありがとうございました！

Answer 1

複数の接続を受け入れるための実装では匿名のクライアントが作成されます。つまり、1つを超える接続の後で正しいクライアントを識別できないことを意味します。識別が問題の場合は、クライアントが "Client1"のような識別子をサーバーに送信するようにすることができます。辞書を作成し、あなたの方法ClientHandlerの（）には、クライアントからの識別子を読み、辞書にれるtcpClientのオブジェクトを追加します。

ので、変更されたコードは、このようなものになるだろう：

Dictionary<string, TCPClient> dictionary = new Dictionary<string, TCPClient>(); 


public static void ClientHandler(object c) 
    { 
     TcpClient client = (TcpClient)c; 
     NetworkStream netstream = client.GetStream(); 
     bool connected = true; 
     while (connected) 
     { 
      Thread.Sleep(10); 
      try 
      { 
       byte[] bytes = new byte[client.ReceiveBufferSize]; 

       //read the identifier from client 
       netstream.Read(bytes, 0, bytes.Length); 

       String id = System.Text.Encoding.UTF8.GetString(bytes); 

       //add the entry in the dictionary 
       dictionary.Add(id, client); 
       Console.WriteLine("got data"); 
       netstream.Write(bytes, 0, bytes.Length); 

      } 
      catch (Exception e) 
      { 
       connected = false; 
       Console.WriteLine(e); 
       Console.WriteLine(e.StackTrace); 
      } 
     } 
    } 

ノートを実行してください：あなたのアプリケーションが動的に更新が送信されるべきクライアントに決定するのに十分なインテリジェントでなければなりません。