C#中的Udp
// TCP 面向长连接 面向流 // UDP 面向无连接 面向数据报 :UDP如何确定当前网络中的其客户端 广播Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);socket.Bind(new IPEndPoint(IPAddress.Any, 9009));// 一个UDP客户端Task.Run(() =>{byte[] buffer = new byte[1024];EndPoint iPEndPoint = new IPEndPoint(IPAddress.Any, 0);socket.ReceiveFrom(buffer, ref iPEndPoint);Console.WriteLine(Encoding.UTF8.GetString(buffer));// iPEndPoint 指的是哪个客户端发过来的// 启动后,发送一个广播,接收到广播后 给发广播的人一个回应});// 无连接 这个消息会往这个局域网里丢// 前面不需要连接动作//socket.SendTo(new byte[] { 0x01, 0x02 }, new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6666));Socket socket1 = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);// Socket对象的配置属性socket1.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, true);socket1.SendTo(new byte[] { 0x01, 0x02 }, new IPEndPoint(IPAddress.Parse("255.255.255.255"), 6666));
TCP 客户端发送/接收
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6666));// 同步处理
{//byte[] buffer, int offset, int size, SocketFlags socketFlagsstring msg = "Hello";byte[] data = Encoding.UTF8.GetBytes(msg);//for (int i = 0; i < 10; i++){socket.Send(data, 0, data.Length, SocketFlags.None);}Console.ReadLine();发送 上位机(客户端)主动请求设备(服务器)通信过程,一问一答 请求-》响应 开始接收响应byte[] buffer = new byte[1024 * 1024];// 如果没有应用层协议规定长度 ModbusTCP 请求多少个寄存器 返回的特定的长度TCP : 面向数据流,没有明显边界 数据包中记录有效字节数 S7Console.WriteLine("开始接收");socket.Receive(buffer);// 1、有数据进来 不会就卡住 2、确保字节的长度Console.WriteLine("接收完成");//Send有没有时间间隔// 异步-》对应哪个发送的请求// 返回接收报文
}AutoResetEvent autoResetEvent = new AutoResetEvent(false);// 异步读写
{string msg = "Hello";byte[] data = Encoding.UTF8.GetBytes(msg);var result = socket.BeginSend(data, 0, data.Length, SocketFlags.None, new AsyncCallback(ret =>{// 异步方法,同步的处理try{socket.EndSend(ret);// 发送未完成,就开始接收响应byte[] buffer = new byte[1024];Console.WriteLine("开始接收");//socket.Receive(buffer);//while (true)// 需要必须拿到数据才往下走{var result = socket.BeginReceive(buffer, 0, 1024, SocketFlags.None, new AsyncCallback(DoAsync), socket);bool s = result.AsyncWaitHandle.WaitOne(500);// 等待500毫秒 以内完成接收动作 if (!s)Console.WriteLine("接收超时");//else// break;autoResetEvent.Set();}// 耗时// 等待一个通知autoResetEvent.WaitOne();// 处理Console.WriteLine(Encoding.UTF8.GetString(buffer));}catch (Exception ex){Console.WriteLine(ex.Message);}}), socket);//result.AsyncWaitHandle.WaitOne();Console.WriteLine("开始发送");
}