一步一步教你使用.net进行Socket通信5

1public Connection StartClient(IPAddress ip,int port)
2
3{
4
5     return Client.StartClient(ip,port);
6
7}
8

public static System.Text.Encoding DefaultEncoding = 

System.Text.Encoding.GetEncoding("GB2312");

public static void SendMessage(string message,Connection connection) {

     byte[] buffer = DefaultEncoding.GetBytes(message);

     connection.NetworkStream.Write(buffer,0,buffer.Length);

}

public void Listenning() {

     while(true) {

         System.Threading.Thread.Sleep(200);

         foreach(Connection connection in this._connections) {

              if(connection.NetworkStream.CanRead && connection.NetworkStream.DataAvailable) {

                   byte[] buffer = new byte[1024];

                   int count = connection.NetworkStream.Read(buffer,0,buffer.Length);

                   Console.Write(SocketFactory.DefaultEncoding.GetString(buffer,0,count));

              }

         }

     }

}

 

 1public void StartListen() {
 2
 3     _listenningthread = new System.Threading.Thread(new System.Threading.ThreadStart(Listenning));
 4
 5     _listenningthread.Start();
 6
 7}
 8
 9private System.Threading.Thread _listenningthread;