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個排隊連接請求 
      ConsoleWriteLine("啟動監(jiān)聽{0}成功", serverSocketLocalEndPointToString()); 
      //通過Clientsoket發(fā)送數(shù)據(jù) 
      Thread myThread = new Thread(ListenClientConnect); 
      myThreadStart(); 
      ConsoleReadLine(); 
    } 
 
    /// <summary> 
    /// 監(jiān)聽客戶端連接 
    /// </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 
        { 
          //通過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; 
        } 
      } 
    } 
  } 
} 

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ù)器失敗，請按回車鍵退出！"); 
        return; 
      } 
      //通過clientSocket接收數(shù)據(jù) 
      int receiveLength = clientSocketReceive(result); 
      ConsoleWriteLine("接收服務(wù)器消息：{0}",EncodingASCIIGetString(result,0,receiveLength)); 
      //通過 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(); 
    } 
  } 
}