UDP服务端与客户端之间相互通信

using System; using System.Text; using System.Net.Sockets; using System.Net; using System.Threading; namespace UDPnetwork { public class UDPServer { IPEndPoint ipEndpoint;//终结点 IPAddress ipAdress = IPAddress.Parse("127.0.0.1");//本机地址 int port = 5566;//本机开放端口 public Socket Socket; public EndPoint clientIP; UDPServer() { Socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram,ProtocolType.Udp);//设置套接字为udp服务 ipEndpoint = new IPEndPoint(ipAdress, port); Socket.Bind(ipEndpoint);//绑定开放端口 new Thread(ReceiveMessage) { IsBackground = true }.Start(); } void ReceiveMessage() { while (true) { EndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0); byte[] data = new byte[1024]; int length = 0; try { length = Socket.ReceiveFrom(data, ref remoteEndPoint);//这个方法会把数据的来源(ip:port)放到第二个参数上 }catch(Exception e) { Console.WriteLine(e.Message); } string message = Encoding.UTF8.GetString(data, 0, length); clientIP = remoteEndPoint;//保存客户端对应的端口，可以通过这个端口和客户端进行通信 Console.WriteLine("从ip：" + (remoteEndPoint as IPEndPoint).Address.ToString() + "：" + (remoteEndPoint as IPEndPoint).Port + "收到了数据：" + message); } } static void Main() { UDPServer udp = new UDPServer(); while (true) { string message=Console.ReadLine(); byte[] buff=Encoding.UTF8.GetBytes(message); int port = (udp.clientIP as IPEndPoint).Port;//客户端的端口 IPAddress address = (udp.clientIP as IPEndPoint).Address;//客户端的地址 EndPoint ep = new IPEndPoint(address, port); udp.Socket.SendTo(buff, ep);//发送信息 } } } }