C＃TCP聊天應用程序線程

Question

我急需幫助。我基本上已經創建了一個程序（將使用）加密來來回發送消息。加密部分工作正常，但是我對線程相當新穎，而且我不能在我的生活中使我的客戶機/服務器應用程序的部分排隊。聊天程序是使用TCP的直接IP連接，因此每個主機都是客戶端和服務器。我在調試時遇到的問題是，當客戶端嘗試連接到服務器線程時服務器線程未準備好，或者它已準備好，它不會放棄線程以便客戶端連接！我一直在爲此工作數小時，這是非常令人沮喪的..我希望有人可以幫助！我已經在下面包含了我的代碼。 這是我的代碼片段從我的MainForm，它構造了客戶端和服務器方面：

private void InitializeComponent() { 

     server = new ServerSide("127.0.0.1",7865); 
     servThread = new Thread(new ThreadStart(server.begin)); 
     client = new ClientSide("127.0.0.1",7865); 
     clientThread = new Thread(new ThreadStart(client.begin)); 
     servThread.Start(); 
     clientThread.Start(); 


     //servThread.Join(); 
     //clientThread.Join(); 

}

這是我的服務器端代碼：

public class ServerSide 
{ 
    String IpString; 
    int tcpPort; 
    bool goodToGo = false; 
    System.Net.IPAddress ipAddress = null; 
    public ServerSide(String ip, int tcpPort) 
    { 
     IpString = ip; 
     bool isValidIp = System.Net.IPAddress.TryParse(IpString, out ipAddress); 
     if (isValidIp == true) // check if the IP is valid, set the bool to true if so 
     { 
      goodToGo = true; 
     } 
     else 
     { 
      goodToGo = false; 
     } 
    } 

    public void begin() 
    { 
     try 
     { 
      IPAddress ipAd = IPAddress.Parse(IpString); 

      /* Initializes the Listener */ 
      TcpListener myList = new TcpListener(ipAd, tcpPort); 
      Socket s = null; 
      /* Start Listening at the specified port */ 
      while (true) 
      { 
       myList.Start(); 

       if (myList.Pending()) 
       { 
         s = myList.AcceptSocket(); 
         break; 
       } 

      } 

      String toReceive = ""; 
        while (true) 
        { 
         byte[] b = new byte[4096]; 
         int k = s.Receive(b); 
         for (int i = 0; i < k; i++) 
          toReceive += Convert.ToString((Convert.ToChar(b[i]))); 

         // ASCIIEncoding asen = new ASCIIEncoding(); 

         var form = MainForm.ActiveForm as MainForm; 
         if (form != null) 
         { 
          form.messageReceived(toReceive); 
         } 
         toReceive = ""; 
        } 
       } 
     catch (Exception e) 
     { 
      Console.WriteLine("Error..... " + e.StackTrace); 
     } 
    } 
} 

}

客戶方代碼：

public class ClientSide 
{ 
    private String IpString; 
    private int tcpPort; 
    private TcpClient tcpInt; 
    private static Stream stm; 
    private System.Net.IPAddress ipAddress = null; 
    private bool goodToGo = false; 

    public ClientSide(String ip, int tcpPort) 
    { 

     IpString = ip; 
     this.tcpPort = tcpPort; 

     bool isValidIp = System.Net.IPAddress.TryParse(IpString, out ipAddress); 
     if (isValidIp == true) 
     { 
      goodToGo = true; 
     } 
     else 
     { 
      goodToGo = false; 
     } 
    } 

    public void begin() 
    { 
     try 
     { 
      tcpInt = new TcpClient(); 
      // Console.WriteLine("Connecting....."); 



      tcpInt.Connect(IpString, tcpPort); 
      // use the ipaddress as in the server program 

      // Console.WriteLine("Connected"); 

      // String str = Console.ReadLine(); 
      stm = tcpInt.GetStream(); 
     } 

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


    public void sendMessage(String str) 
    { 
     // stm = tcpInt.GetStream(); 

     ASCIIEncoding asen = new ASCIIEncoding(); 
     byte[] ba = asen.GetBytes(str); 

     stm.Write(ba, 0, ba.Length); 

     /** byte[] bb = new byte[100]; 
     int k = stm.Read(bb, 0, 100); 

     for (int i = 0; i < k; i++) 
      Console.Write(Convert.ToChar(bb[i]));*/ 

    } 
} 

}

再次..通常發生的是我的客戶端收到一個錯誤，主機主動拒絕連接..但我不知道如何計時。我正在尋找如何讓我的服務器偵聽TCP連接，但仍然設法去我的另一個線程創建TCP連接發送服務器（我目前正在測試本地主機上）。 謝謝。

Answer 1

在ServerSide類的構造函數中，您忘記初始化tcpPort成員。由於您忘記了，服務器將嘗試偵聽端口0，客戶端將嘗試連接到端口7865，並且會失敗。

嘗試將此代碼添加到ServerSide類的構造函數中。

this.tcpPort = tcpPort; 

至於線程，如果客戶端線程在服務器線程開始偵聽之前嘗試連接，則可能有問題。如果你沒有成功，你可以使用一個循環嘗試連接多次（比如說10），如果超時（比如說1秒）。這樣，你會重試10次，然後放棄。