• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

C#Socket入门4UPD发送结构体(转)

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

今天我们来学 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. 哈哈,当然, 效果来也~~


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
解决configure:error:C++compilercannotcreateexecutables问题发布时间:2022-07-13
下一篇:
C/S权限系统(一)发布时间:2022-07-13
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap