好久没有写过博客了,最近因项目需求,需要用到Socket来进行通信,简单写了几个例子,记录一下,代码很简单,无非就是接收与发送,以及接收到数据后返回一个自定义信息,也可以定义为发送。
接收端因为需求要监听某个端口,则在一开始判断一下,要使用的端口是否被占用,定义一个处理方法,以下为处理代码:
1 public static bool PortIsUse(int port) 2 { 3 bool isUse = false; 5 IPGlobalProperties ipProperties = IPGlobalProperties.GetIPGlobalProperties(); 6 IPEndPoint[] ipEndPoints = ipProperties.GetActiveTcpListeners();//找到已用端口 8 foreach (IPEndPoint endPoint in ipEndPoints) 9 { 10 if (endPoint.Port == port)//判断是否存在 11 { 12 isUse= true; 13 break; 14 } 15 } 16 return isUse; 17 }
定义接收端:
1 TcpListener tcpl = new TcpListener(new IPAddress(new byte[] { 127, 0, 0, 1 }), 1111);//定义一个TcpListener对象监听本地的1111端口 2 tcpl.Start();//监听开始 3 while (true) 4 { 6 Socket s = tcpl.AcceptSocket();//挂起一个Socket对象 7 string remote = s.RemoteEndPoint.ToString();//获取发送端的IP及端口转为String备用 8 Byte[] stream = new Byte[1024]; 9 s.Receive(stream);//接收发送端发过来的数据,写入字节数组 10 //BGW_Handle.ReportProgress(1, "接收来自[" + remote + "]信息"); 11 string _data = Encoding.UTF8.GetString(stream);//将字节数据数组转为String 12 s.Send(stream);//将接收到的内容,直接返回接收端 13 s.Shutdown(SocketShutdown.Both); 14 } 15 tcpl.Stop();//停止监听
定义发送端代码:
IPAddress ip = IPAddress.Parse("127.0.0.1");//接收端所在IP 3 IPEndPoint ipEnd = new IPEndPoint(ip, 1111);//接收端所监听的接口 4 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化一个Socket对象 5 try 6 { 7 socket.Connect(ipEnd);//连接指定IP&端口 8 } 9 catch (SocketException e) 10 { 11 Console.WriteLine("连接失败"); 12 Console.WriteLine(e.ToString());
14 return; 15 } 16 socket.Send(Encoding.UTF8.GetBytes("1234567890"));//发送数据 17 while (true)//定义一个循环接收返回数据 18 { 19 byte[] data = new byte[1024]; 20 socket.Receive(data);//接收返回数据 21 string stringData = Encoding.UTF8.GetString(data); 22 if (!string.IsNullOrWhiteSpace(stringData)) 23 { 24 Console.Write(stringData); 25 break; 26 } 27 }29 socket.Shutdown(SocketShutdown.Both); 30 socket.Close();//关闭Socket
从上面代码来看,还是很简单的,这也要归功于微软所做的工作,以上代码若有错误之处可在评论里提出来。