socket小实例

服务端

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net; using System.Net.Sockets; using System.Threading;

namespace SocketDemo {

    class Program     {         static Socket serverSocket;         static Socket clientSocket;         static Thread thread;         static void Main(string[] args)         {             //将网络端点表示为IP地址和端口 用于socket侦听时绑定             IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 3001);             //使用指定的地址族、套接字类型和协议初始化socket类的新实例             serverSocket = new Socket(ipep.AddressFamily, SocketType.Stream, ProtocolType.Tcp);             //将所创建的Socket与IPEndPoint绑定             serverSocket.Bind(ipep);             //设置套接字为收听模式 定队列中最多可容纳的等待接受的传入链接数为10             serverSocket.Listen(10);             //在Socket上接收接入的连接             while (true)             {                 //serverSocket.Accept()接收客户端Socket的连接请求 当程序运行到serverSocket.Accept()时会等待直到有客户端Socket发起连接请求时 获取客户端Socket

                clientSocket = serverSocket.Accept();                 thread = new Thread(new ThreadStart(Program.doWork));                 thread.Start();             }             Console.Read();         }         private static void doWork()         {

            Socket clinet = clientSocket;             //客户端信息             IPEndPoint ipEndPoint = (IPEndPoint)clinet.RemoteEndPoint;             String address = ipEndPoint.Address.ToString();             String port = ipEndPoint.Port.ToString();             Console.WriteLine(address + ":" + port + " 连接过来了");             while (true)             {                 Byte[] inBuffer = new Byte[clinet.ReceiveBufferSize];                 Byte[] outBuffer=new Byte[1024];                 String inBufferStr;                 String outBufferStr;                 try                 {                     //如果接收的消息为空 阻塞 当前循环                     clinet.Receive(inBuffer, clinet.ReceiveBufferSize, SocketFlags.None);                 }                 catch(SocketException)                 {                     clinet.Close();                     return;                 }                 inBufferStr = Encoding.ASCII.GetString(inBuffer);                 Console.WriteLine(address + ":" + port + "说:");                 Console.WriteLine(inBufferStr.Trim());

                outBufferStr = Console.ReadLine().Trim();

                outBuffer = Encoding.ASCII.GetBytes(outBufferStr);                 clinet.Send(outBuffer, outBuffer.Length, SocketFlags.None);                             }

                  }     } }

客户端

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; using System.Net;

namespace clientSocket {     class Program     {         static Socket clientSocket;         static void Main(string[] args)         {             try             {                 //将网络端点表示为IP地址和端口，用于socket侦听时绑定                 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 3001);                 clientSocket = new Socket(ipep.AddressFamily, SocketType.Stream, ProtocolType.Tcp);                 //将socket连接到服务器                 clientSocket.Connect(ipep);                 String outBufferStr;                 Byte[] outBuffer = new Byte[1024];                 Byte[] inBuffer = new Byte[1024];                 //发送消息                 outBufferStr = Console.ReadLine().Trim();                 outBuffer = Encoding.ASCII.GetBytes(outBufferStr);                 clientSocket.Send(outBuffer, outBuffer.Length, SocketFlags.None);                 Console.WriteLine("服务器响应：");                 //接收服务器端信息                 clientSocket.Receive(inBuffer, 1024, SocketFlags.None);                 Console.WriteLine(Encoding.ASCII.GetString(inBuffer));                 Console.ReadLine();             }             catch(Exception exp)             {                 Console.WriteLine(exp.Message);                 Console.ReadLine();             }         }     } }