学步园

下面的示例程序创建一个接收来自客户端的连接请求的服务器。该服务器是用同步套接字生成的，因此在等待来自客户端的连接时挂起服务器应用程序的执行。该应用程序接收来自客户端的字符串，在控制台显示该字符串，然后将该字符串回显到客户端。来自客户端的字符串必须包含字符串“<EOF>”，以发出表示消息结尾的信号。

 using System;<br /> using System.Net;<br /> using System.Net.Sockets;<br /> using System.Text;</p> <p>public class SynchronousSocketListener {</p> <p> // Incoming data from the client.<br /> public static string data = null;</p> <p> public static void StartListening() {<br /> // Data buffer for incoming data.<br /> byte[] bytes = new Byte[1024];</p> <p> // Establish the local endpoint for the socket.<br /> // Dns.GetHostName returns the name of the<br /> // host running the application.<br /> IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());<br /> IPAddress ipAddress = ipHostInfo.AddressList[0];<br /> IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);</p> <p> // Create a TCP/IP socket.<br /> Socket listener = new Socket(AddressFamily.InterNetwork,<br /> SocketType.Stream, ProtocolType.Tcp );</p> <p> // Bind the socket to the local endpoint and<br /> // listen for incoming connections.<br /> try {<br /> listener.Bind(localEndPoint);<br /> listener.Listen(10);</p> <p> // Start listening for connections.<br /> while (true) {<br /> Console.WriteLine("Waiting for a connection...");<br /> // Program is suspended while waiting for an incoming connection.<br /> Socket handler = listener.Accept();<br /> data = null;</p> <p> // An incoming connection needs to be processed.<br /> while (true) {<br /> bytes = new byte[1024];<br /> int bytesRec = handler.Receive(bytes);<br /> data += Encoding.ASCII.GetString(bytes,0,bytesRec);<br /> if (data.IndexOf("<EOF>") > -1) {<br /> break;<br /> }<br /> }</p> <p> // Show the data on the console.<br /> Console.WriteLine( "Text received : {0}", data);</p> <p> // Echo the data back to the client.<br /> byte[] msg = Encoding.ASCII.GetBytes(data);</p> <p> handler.Send(msg);<br /> handler.Shutdown(SocketShutdown.Both);<br /> handler.Close();<br /> }</p> <p> } catch (Exception e) {<br /> Console.WriteLine(e.ToString());<br /> }</p> <p> Console.WriteLine("/nPress ENTER to continue...");<br /> Console.Read();</p> <p> }</p> <p> public static int Main(String[] args) {<br /> StartListening();<br /> return 0;<br /> }<br /> }