|
示例程序是同步套接字程序功能很简单只是客户端发给服务器一条信息服务器向客户端返回一条信息这里只是一个简单的示例是一个最基本的socket编程流程在接下来的文章中会依次记录套接字的同步和异步以及它们的区别 下面是示例程序的简单步骤说明 服务器端 第一步用指定的端口号和服务器的ip建立一个EndPoint对像 第二步建立一个Socket对像 第三步用socket对像的Bind()方法绑定EndPoint 第四步用socket对像的Listen()方法开始监听 第五步接受到客户端的连接用socket对像的Accept()方法创建新的socket对像用于和请求的客户端进行通信; 第六步通信结束后一定记得关闭socket; 代码 using System; using SystemCollectionsGeneric; using SystemText; using SystemNet; using SystemNetSockets; namespace server { class Program { static void Main(string[] args) { int port = ; string host = ; /**////创建终结点（EndPoint） IPAddress ip = IPAddressParse(host);//把ip地址字符串转换为IPAddress类型的实例 IPEndPoint ipe = new IPEndPoint(ip port);//用指定的端口和ip初始化IPEndPoint类的新实例 /**////创建socket并开始监听 Socket s=new Socket(AddressFamilyInterNetwork SocketTypeStream ProtocolTypeTcp);//创建一个socket对像如果用udp协议则要用SocketTypeDgram类型的套接字 sBind(ipe);//绑定EndPoint对像（端口和ip地址） sListen();//开始监听 ConsoleWriteLine(等待客户端连接); /**////接受到client连接为此连接建立新的socket并接受信息 Socket temp = sAccept();//为新建连接创建新的socket ConsoleWriteLine(建立连接); string recvStr = ; byte[] recvBytes = new byte[]; int bytes; bytes = tempReceive(recvBytes recvBytesLength );//从客户端接受信息 recvStr += EncodingASCIIGetString(recvBytes bytes); /**////给client端返回信息 ConsoleWriteLine(server get message:{} recvStr);//把客户端传来的信息显示出来 string sendStr = ok!Client send message successful!; byte[] bs = EncodingASCIIGetBytes(sendStr); tempSend(bs bsLength );//返回信息给客户端 tempClose(); sClose(); ConsoleReadLine(); } } } server结果 客户端 第一步用指定的端口号和服务器的ip建立一个EndPoint对像 第二步建立一个Socket对像 第三步用socket对像的Connect()方法以上面建立的EndPoint对像做为参数向服务器发出连接请求 第四步如果连接成功就用socket对像的Send()方法向服务器发送信息 第五步用socket对像的Receive()方法接受服务器发来的信息 ; 第六步通信结束后一定记得关闭socket 代码 using System; using SystemCollectionsGeneric; using SystemText; using SystemNet; using SystemNetSockets; namespace Client { class Program { static void Main(string[] args) { try { int port = ; string host = ; /**////创建终结点EndPoint IPAddress ip = IPAddressParse(host); //IPAddress ipp = new IPAddress(); IPEndPoint ipe = new IPEndPoint(ip port);//把ip和端口转化为IPEndpoint实例 /**////创建socket并连接到服务器 Socket c = new Socket(AddressFamilyInterNetwork SocketTypeStream ProtocolTypeTcp);//创建Socket ConsoleWriteLine(Conneting…); cConnect(ipe);//连接到服务器 /**////向服务器发送信息 string sendStr = hello!This is a socket test; byte[] bs = EncodingASCIIGetBytes(sendStr);//把字符串编码为字节 ConsoleWriteLine(Send Message); cSend(bs bsLength );//发送信息 /**////接受从服务器返回的信息 string recvStr = ; byte[] recvBytes = new byte[]; int bytes; bytes = cReceive(recvBytes recvBytesLength );//从服务器端接受返回信息 recvStr += EncodingASCIIGetString(recvBytes bytes); ConsoleWriteLine(client get message:{} recvStr);//显示服务器返回信息 /**////一定记着用完socket后要关闭 cClose(); } catch (ArgumentNullException e) { ConsoleWriteLine(argumentNullException: {} e); } catch (SocketException e) { ConsoleWriteLine(SocketException:{} e); } ConsoleWriteLine(Press Enter to Exit); } } } Client端结果 |
