詳解C# Socket簡(jiǎn)單例子（服務(wù)器與客戶端通信）

更新時(shí)間：2016年12月03日 16:20:33 作者：Andrew_wx

這篇文章主要介紹了詳解C# Socket簡(jiǎn)單例子（服務(wù)器與客戶端通信），具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下。

這個(gè)例子只是簡(jiǎn)單實(shí)現(xiàn)了如何使用 Socket 類實(shí)現(xiàn)面向連接的通信。

注意：此例子的目的只是為了說(shuō)明用套接字寫程序的大概思路，而不是實(shí)際項(xiàng)目中的使用程序。在這個(gè)例子中，實(shí)際上還有很多問(wèn)題沒(méi)有解決，如消息邊界問(wèn)題、端口號(hào)是否被占用、消息命令的解析問(wèn)題等。。

下面是兩個(gè)程序的代碼，（兩個(gè)程序均為控制臺(tái)程序）

先發(fā)服務(wù)端的（Server)完整代碼如下：

引入命名空間：

using System.Net.Sockets; 
using SystemNet; 
using SystemThreading;

完整代碼如下：

namespace SocketServer 
{ 
  class Program 
  { 
    private static byte[] result = new byte[1024]; 
    private static int myProt = 8885;  //端口 
    static Socket serverSocket; 
    static void Main(string[] args) 
    { 
      //服務(wù)器IP地址 
      IPAddress ip = IPAddressParse("1"); 
      serverSocket = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp); 
      serverSocketBind(new IPEndPoint(ip, myProt)); //綁定IP地址：端口 
      serverSocketListen(10);  //設(shè)定最多10個(gè)排隊(duì)連接請(qǐng)求 
      ConsoleWriteLine("啟動(dòng)監(jiān)聽(tīng){0}成功", serverSocketLocalEndPointToString()); 
      //通過(guò)Clientsoket發(fā)送數(shù)據(jù) 
      Thread myThread = new Thread(ListenClientConnect); 
      myThreadStart(); 
      ConsoleReadLine(); 
    } 
 
    /// <summary> 
    /// 監(jiān)聽(tīng)客戶端連接 
    /// </summary> 
    private static void ListenClientConnect() 
    { 
      while (true) 
      { 
        Socket clientSocket = serverSocketAccept(); 
        clientSocketSend(EncodingASCIIGetBytes("Server Say Hello")); 
        Thread receiveThread = new Thread(ReceiveMessage); 
        receiveThreadStart(clientSocket); 
      } 
    } 
 
    /// <summary> 
    /// 接收消息 
    /// </summary> 
    /// <param name="clientSocket"></param> 
    private static void ReceiveMessage(object clientSocket) 
    { 
      Socket myClientSocket = (Socket)clientSocket; 
      while (true) 
      { 
        try 
        { 
          //通過(guò)clientSocket接收數(shù)據(jù) 
          int receiveNumber = myClientSocketReceive(result); 
          ConsoleWriteLine("接收客戶端{(lán)0}消息{1}", myClientSocketRemoteEndPointToString(), EncodingASCIIGetString(result, 0, receiveNumber)); 
        } 
        catch(Exception ex) 
        { 
          ConsoleWriteLine(exMessage); 
          myClientSocketShutdown(SocketShutdownBoth); 
          myClientSocketClose(); 
          break; 
        } 
      } 
    } 
  } 
}

以上是服務(wù)端（server）的完整代碼。

客戶端（Client）的完整代碼如下：

引入命名空間：

using SystemNet; 
using SystemNetSockets; 
using SystemThreading;

完整代碼：

namespace SocketClient 
{ 
  class Program 
  { 
    private static byte[] result = new byte[1024]; 
    static void Main(string[] args) 
    { 
      //設(shè)定服務(wù)器IP地址 
      IPAddress ip = IPAddressParse("1"); 
      Socket clientSocket = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp); 
      try 
      { 
        clientSocketConnect(new IPEndPoint(ip, 8885)); //配置服務(wù)器IP與端口 
        ConsoleWriteLine("連接服務(wù)器成功"); 
      } 
      catch 
      { 
        ConsoleWriteLine("連接服務(wù)器失敗，請(qǐng)按回車鍵退出！"); 
        return; 
      } 
      //通過(guò)clientSocket接收數(shù)據(jù) 
      int receiveLength = clientSocketReceive(result); 
      ConsoleWriteLine("接收服務(wù)器消息：{0}",EncodingASCIIGetString(result,0,receiveLength)); 
      //通過(guò) clientSocket 發(fā)送數(shù)據(jù) 
      for (int i = 0; i < 10; i++) 
      { 
        try 
        { 
          ThreadSleep(1000);  //等待1秒鐘 
          string sendMessage = "client send Message Hellp" + DateTimeNow; 
          clientSocketSend(EncodingASCIIGetBytes(sendMessage)); 
          ConsoleWriteLine("向服務(wù)器發(fā)送消息：{0}" + sendMessage); 
        } 
        catch 
        { 
          clientSocketShutdown(SocketShutdownBoth); 
          clientSocketClose(); 
          break; 
        } 
      } 
      ConsoleWriteLine("發(fā)送完畢，按回車鍵退出"); 
      ConsoleReadLine(); 
    } 
  } 
}

編譯成功后，先運(yùn)行服務(wù)端（server），再運(yùn)行客戶端（client）即可達(dá)到通信效果。

效果如下圖：