在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
今天我们来学 socket 发送结构体 1. 先看要发送的结构体 using System;
using System.Collections.Generic; using System.Text; using System.Runtime.InteropServices; namespace Lin.p2p.Mo { /// <summary> /// 通信消息格式 /// </summary> [Serializable] [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CP2PMessage { public sbyte nMessageTypes; public int Value; } } 2. 请看服务端 using System;
using System.Collections.Generic; using System.Text; using System.Net.Sockets; using System.Net; using Lin.p2p; using Lin.p2p.Mo; namespace ConsoleApplication1 { class Program { static void Main(string[] args) { // 1.创建套节字 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); // 2.填充IP IPEndPoint ipe = new IPEndPoint(IPAddress.Any, 4321); // 3.绑定 socket.Bind(ipe); // 等待客户机连接 Console.WriteLine("This is a Server, host name is {0}", Dns.GetHostName()); Console.WriteLine("Waiting for a client..."); // 4.得客户机IP IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0); EndPoint remote = (EndPoint)sender; // 5.接收客户机数据 byte[] buffer = new byte[1024]; socket.ReceiveFrom(buffer, ref remote); CP2PMessage msg = new CP2PMessage(); msg = (CP2PMessage)Tool.BytesToStruct(buffer, msg.GetType()); Console.WriteLine("接收的值为:{0}", msg.Value); Console.ReadKey(); } } } 2.其中重要的一段就是把 结构体转为 byte数组 using System;
using System.Collections.Generic; using System.IO; using System.Runtime.InteropServices; namespace Lin.p2p.Mo { public class Tool { public static byte[] StructToBytes(object obj) { int size = Marshal.SizeOf(obj); byte[] bytes = new byte[size]; IntPtr structPtr = Marshal.AllocHGlobal(size); //分配结构体大小的内存空间 Marshal.StructureToPtr(obj, structPtr, false); //将结构体拷到分配好的内存空间 Marshal.Copy(structPtr, bytes, 0, size); //从内存空间拷到byte数组 Marshal.FreeHGlobal(structPtr); //释放内存空间 return bytes; } public static object BytesToStruct(byte[] bytes, Type type) { int size = Marshal.SizeOf(type); if (size > bytes.Length) return null; IntPtr structPtr = Marshal.AllocHGlobal(size); //分配结构大小的内存空间 Marshal.Copy(bytes, 0, structPtr, size); //将byte数组拷到分配好的内存空间 object obj = Marshal.PtrToStructure(structPtr, type); Marshal.FreeHGlobal(structPtr); return obj; } } } 3. 最后看客户端 // 1.创建套节字
m_s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); // 2.填写服务器IP IPAddress ip = IPAddress.Parse("127.0.0.1"); IPEndPoint ipe = new IPEndPoint(ip, 4321); //向服务器发送本用户信息 CP2PMessage msg = new CP2PMessage(); msg.nMessageTypes = (sbyte)Cmd.UserLogin; msg.Value = 10; var buffer = Fun.StructToBytes(msg); m_s.SendTo(buffer, buffer.Length, SocketFlags.None, ipe); Console.ReadKey(); 4. 哈哈,当然, 效果来也~~ 今天我们来学 socket 发送结构体 1. 先看要发送的结构体 using System;
using System.Collections.Generic; using System.Text; using System.Runtime.InteropServices; namespace Lin.p2p.Mo { /// <summary> /// 通信消息格式 /// </summary> [Serializable] [StructLayout(LayoutKind.Sequential, Pack = 1)] public struct CP2PMessage { public sbyte nMessageTypes; public int Value; } } 2. 请看服务端 using System;
using System.Collections.Generic; using System.Text; using System.Net.Sockets; using System.Net; using Lin.p2p; using Lin.p2p.Mo; namespace ConsoleApplication1 { class Program { static void Main(string[] args) { // 1.创建套节字 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); // 2.填充IP IPEndPoint ipe = new IPEndPoint(IPAddress.Any, 4321); // 3.绑定 socket.Bind(ipe); // 等待客户机连接 Console.WriteLine("This is a Server, host name is {0}", Dns.GetHostName()); Console.WriteLine("Waiting for a client..."); // 4.得客户机IP IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0); EndPoint remote = (EndPoint)sender; // 5.接收客户机数据 byte[] buffer = new byte[1024]; socket.ReceiveFrom(buffer, ref remote); CP2PMessage msg = new CP2PMessage(); msg = (CP2PMessage)Tool.BytesToStruct(buffer, msg.GetType()); Console.WriteLine("接收的值为:{0}", msg.Value); Console.ReadKey(); } } } 2.其中重要的一段就是把 结构体转为 byte数组 using System;
using System.Collections.Generic; using System.IO; using System.Runtime.InteropServices; namespace Lin.p2p.Mo { public class Tool { public static byte[] StructToBytes(object obj) { int size = Marshal.SizeOf(obj); byte[] bytes = new byte[size]; IntPtr structPtr = Marshal.AllocHGlobal(size); //分配结构体大小的内存空间 Marshal.StructureToPtr(obj, structPtr, false); //将结构体拷到分配好的内存空间 Marshal.Copy(structPtr, bytes, 0, size); //从内存空间拷到byte数组 Marshal.FreeHGlobal(structPtr); //释放内存空间 return bytes; } public static object BytesToStruct(byte[] bytes, Type type) { int size = Marshal.SizeOf(type); if (size > bytes.Length) return null; IntPtr structPtr = Marshal.AllocHGlobal(size); //分配结构大小的内存空间 Marshal.Copy(bytes, 0, structPtr, size); //将byte数组拷到分配好的内存空间 object obj = Marshal.PtrToStructure(structPtr, type); Marshal.FreeHGlobal(structPtr); return obj; } } } 3. 最后看客户端 // 1.创建套节字
m_s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); // 2.填写服务器IP IPAddress ip = IPAddress.Parse("127.0.0.1"); IPEndPoint ipe = new IPEndPoint(ip, 4321); //向服务器发送本用户信息 CP2PMessage msg = new CP2PMessage(); msg.nMessageTypes = (sbyte)Cmd.UserLogin; msg.Value = 10; var buffer = Fun.StructToBytes(msg); m_s.SendTo(buffer, buffer.Length, SocketFlags.None, ipe); Console.ReadKey(); 4. 哈哈,当然, 效果来也~~ |
2023-10-27
2022-08-15
2022-08-17
2022-09-23
2022-08-13
请发表评论