byte func optimize

NetLib/HaoYueNet.ClientNetwork/NetworkHelperP2PCore.cs

@@ -8,13 +8,6 @@ namespace HaoYueNet.ClientNetwork
     {
         private Socket client;
 
-
-        ////响应倒计时计数最大值
-        //private static int MaxRevIndexNum = 6;
-
-        ////发送倒计时计数最大值
-        //private static int MaxSendIndexNum = 3;
-
         //响应倒计时计数最大值
         private static int MaxRevIndexNum = 50;
 
@@ -132,25 +125,25 @@ namespace HaoYueNet.ClientNetwork
             client.Send(data);
         }
 
-        //拼接头长度
+        ////拼接头长度
-        private byte[] SendDataWithHead(byte[] message)
+        //private byte[] SendDataWithHead(byte[] message)
-        {
+        //{
 
-            MemoryStream memoryStream = new MemoryStream();//创建一个内存流
+        //    MemoryStream memoryStream = new MemoryStream();//创建一个内存流
 
-            byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
+        //    byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
 
-            memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
+        //    memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
 
-            memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
+        //    memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
 
-            byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
+        //    byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
 
-            memoryStream.Close();//关闭内存
+        //    memoryStream.Close();//关闭内存
-            memoryStream.Dispose();//释放资源
+        //    memoryStream.Dispose();//释放资源
 
-            return HeadAndBody;
+        //    return HeadAndBody;
-        }
+        //}
 
         /// <summary>
         /// 供外部调用 发送消息

NetLib/HaoYueNet.ClientNetworkNet4x/BaseData.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Net.Sockets;
 using System.Text;
 using System.Threading.Tasks;
 
@@ -8,41 +9,201 @@ namespace HaoYueNet.ClientNetworkNet4x
 {
     public static class BaseData
     {
+        /// <summary>
+        /// 心跳包数据
+        /// </summary>
+        public static byte[] HeartbeatData = new byte[5] { 0x05, 0x00, 0x00, 0x00, 0x00 };
+
+        public static void writeInt(byte[] buf, int offset, int value)
+        {
+            buf[offset++] = (byte)(255 & value);
+            buf[offset++] = (byte)(255 & value >> 8);
+            buf[offset++] = (byte)(255 & value >> 16);
+            buf[offset++] = (byte)(255 & value >> 24);
+        }
+
+        public static void writeUInt16(byte[] buf, int offset, int value)
+        {
+            buf[offset++] = (byte)(255 & value);
+            buf[offset++] = (byte)(255 & value >> 8);
+        }
+
+        public static class HunterNet_Heartbeat
+        {
+            public static void SetDataToSocketAsyncEventArgs(SocketAsyncEventArgs myreadEventArgs)
+            {
+                myreadEventArgs.SetBuffer(HeartbeatData, 0, HeartbeatData.Length);
+            }
+        }
+
         public static class HunterNet_S2C
         {
-            public static byte[] CreatePkgData(UInt16 CmdID, UInt16 Error, byte[] data)
+            public static void SetDataToSocketAsyncEventArgs(SocketAsyncEventArgs myreadEventArgs, UInt16 CmdID, UInt16 Error, byte[] AddonBytes_Data)
             {
-                byte[] newdata = new byte[2 + 2 + data.Length];
+                byte[] data = CreatePkgData(CmdID, Error, AddonBytes_Data);
-                BitConverter.GetBytes(CmdID).CopyTo(newdata, 0);
+                myreadEventArgs.SetBuffer(data,0, data.Length);
-                BitConverter.GetBytes(Error).CopyTo(newdata, 2);
-                Array.Copy(data, 0, newdata, 4, data.Length);
-                return newdata;
             }
 
-            public static void AnalysisPkgData(byte[] srcdata,out UInt16 CmdID,out UInt16 Error,out byte[] data)
+            public static byte[] CreatePkgData(UInt16 CmdID, UInt16 Error, byte[] AddonBytes_Data)
             {
-                data = new byte[srcdata.Length - 2 - 2];
+                //byte[] AddonBytes_CmdID = BitConverter.GetBytes(CmdID);
-                CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //byte[] AddonBytes_Error = BitConverter.GetBytes(Error);
-                Error = BitConverter.ToUInt16(srcdata, 2);
+                //int AllLenght = AddonBytes_CmdID.Length + AddonBytes_Error.Length + AddonBytes_Data.Length + 4;
-                Array.Copy(srcdata, 4, data, 0, data.Length);
+                //int LastIndex = 0;
+                ////包长度
+                //byte[] AddonBytes_Lenght = BitConverter.GetBytes(AllLenght);
+
+                //byte[] BufferData = new byte[AllLenght];
+                ////包长度
+                //AddonBytes_Lenght.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_Lenght.Length;
+
+                ////CMDID
+                //AddonBytes_CmdID.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_CmdID.Length;
+
+                ////Error
+                //AddonBytes_Error.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_Error.Length;
+
+                ////DATA
+                //AddonBytes_Data.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_Data.Length;
+                //return BufferData;
+
+                ////用Buffer.BlockCopy拷贝
+                //byte[] AddonBytes_CmdID = BitConverter.GetBytes(CmdID);
+                //byte[] AddonBytes_Error = BitConverter.GetBytes(Error);
+                //int AllLenght = AddonBytes_CmdID.Length + AddonBytes_Error.Length + AddonBytes_Data.Length + 4;
+                //int LastIndex = 0;
+                ////包长度
+                //byte[] AddonBytes_Lenght = BitConverter.GetBytes(AllLenght);
+
+                //byte[] BufferData = new byte[AllLenght];
+                ////包长度
+                //Buffer.BlockCopy(AddonBytes_Lenght, 0, BufferData, LastIndex, AddonBytes_Lenght.Length);
+                //LastIndex += AddonBytes_Lenght.Length;
+
+                ////CMDID
+                //Buffer.BlockCopy(AddonBytes_CmdID, 0, BufferData, LastIndex, AddonBytes_CmdID.Length);
+                //LastIndex += AddonBytes_CmdID.Length;
+
+                ////Error
+                //Buffer.BlockCopy(AddonBytes_Error, 0, BufferData, LastIndex, AddonBytes_Error.Length);
+                //LastIndex += AddonBytes_Error.Length;
+
+                ////DATA
+                //Buffer.BlockCopy(AddonBytes_Data, 0, BufferData, LastIndex, AddonBytes_Data.Length);
+                //LastIndex += AddonBytes_Data.Length;
+
+
+
+                //用Buffer.BlockCopy拷贝
+                //包长度
+                int AllLenght = 4 + 2 + 2 + AddonBytes_Data.Length;
+                byte[] BufferData = new byte[AllLenght];
+
+                //包长度
+                writeInt(BufferData, 0, AllLenght);
+
+                //CMDID
+                writeUInt16(BufferData, 4, CmdID);
+
+                //Error
+                writeUInt16(BufferData, 4 + 2, CmdID);
+
+                //DATA
+                Buffer.BlockCopy(AddonBytes_Data, 0, BufferData, 4 + 2 + 2, AddonBytes_Data.Length);
+
+                return BufferData;
+            }
+
+            public static void AnalysisPkgData(Span<byte> srcdata, out UInt16 CmdID, out UInt16 Error, out byte[] data)
+            {
+                //CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //Error = BitConverter.ToUInt16(srcdata, 2);
+                //data = new byte[srcdata.Length - 2 - 2];
+                //Array.Copy(srcdata, 4, data, 0, data.Length);
+
+                //CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //Error = BitConverter.ToUInt16(srcdata, 2);
+                //Span<byte> span_srcdata = srcdata;
+                //data = span_srcdata.Slice(2 + 2).ToArray();
+
+                CmdID = BitConverter.ToUInt16(srcdata.Slice(0, 2).ToArray(), 0);
+                Error = BitConverter.ToUInt16(srcdata.Slice(2, 2).ToArray(), 2);
+                data = srcdata.Slice(2 + 2).ToArray();
             }
         }
 
         public static class HunterNet_C2S
         {
-            public static byte[] CreatePkgData(UInt16 CmdID, byte[] data)
+            public static void SetDataToSocketAsyncEventArgs(SocketAsyncEventArgs myreadEventArgs, UInt16 CmdID, byte[] AddonBytes_Data)
             {
-                byte[] newdata = new byte[2 + data.Length];
+                byte[] data = CreatePkgData(CmdID, AddonBytes_Data);
-                BitConverter.GetBytes(CmdID).CopyTo(newdata, 0);
+                myreadEventArgs.SetBuffer(data, 0, data.Length);
-                Array.Copy(data, 0, newdata, 2, data.Length);
-                return newdata;
             }
 
-            public static void AnalysisPkgData(byte[] srcdata, out UInt16 CmdID, out byte[] data)
+            public static byte[] CreatePkgData(UInt16 CmdID, byte[] AddonBytes_Data)
             {
-                data = new byte[srcdata.Length - 2];
+                //byte[] AddonBytes_CmdID = BitConverter.GetBytes(CmdID);
-                CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //int AllLenght = AddonBytes_CmdID.Length + AddonBytes_Data.Length + 4;
-                Array.Copy(srcdata, 2, data, 0, data.Length);
+                //int LastIndex = 0;
+                ////包长度
+                //byte[] AddonBytes_Lenght = BitConverter.GetBytes(AllLenght);
+
+                //byte[] BufferData = new byte[AllLenght];
+
+                ////包长度
+                //AddonBytes_Lenght.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_Lenght.Length;
+
+                ////CMDID
+                //AddonBytes_CmdID.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_CmdID.Length;
+
+                ////DATA
+                //AddonBytes_Data.CopyTo(BufferData, LastIndex);
+                //LastIndex += AddonBytes_Data.Length;
+
+                //myreadEventArgs.SetBuffer(BufferData, 0, BufferData.Length);
+                //return BufferData;
+
+                //用Buffer.BlockCopy拷贝
+
+                byte[] AddonBytes_CmdID = BitConverter.GetBytes(CmdID);
+                int AllLenght = AddonBytes_CmdID.Length + AddonBytes_Data.Length + 4;
+                int LastIndex = 0;
+                //包长度
+                byte[] AddonBytes_Lenght = BitConverter.GetBytes(AllLenght);
+
+                byte[] BufferData = new byte[AllLenght];
+                //包长度
+                Buffer.BlockCopy(AddonBytes_Lenght, 0, BufferData, LastIndex, AddonBytes_Lenght.Length);
+                LastIndex += AddonBytes_Lenght.Length;
+
+                //CMDID
+                Buffer.BlockCopy(AddonBytes_CmdID, 0, BufferData, LastIndex, AddonBytes_CmdID.Length);
+                LastIndex += AddonBytes_CmdID.Length;
+
+                //DATA
+                Buffer.BlockCopy(AddonBytes_Data, 0, BufferData, LastIndex, AddonBytes_Data.Length);
+                LastIndex += AddonBytes_Data.Length;
+                return BufferData;
+            }
+
+            public static void AnalysisPkgData(Span<byte> srcdata, out UInt16 CmdID, out byte[] data)
+            {
+                //data = new byte[srcdata.Length - 2];
+                //CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //Array.Copy(srcdata, 2, data, 0, data.Length);
+
+                //CmdID = BitConverter.ToUInt16(srcdata, 0);
+                //Span<byte> span_srcdata = srcdata;
+                //data = span_srcdata.Slice(2).ToArray();
+
+                CmdID = BitConverter.ToUInt16(srcdata.Slice(0, 2).ToArray(),0);
+                data = srcdata.Slice(2).ToArray();
             }
         }
     }

NetLib/HaoYueNet.ClientNetworkNet4x/NetworkHelperCore.cs

@@ -11,17 +11,6 @@ namespace HaoYueNet.ClientNetworkNet4x
     {
         private Socket client;
 
-        /// <summary>
-        /// 心跳包数据
-        /// </summary>
-        static byte[] HeartbeatData = new byte[5] { 0x05, 0x00, 0x00, 0x00, 0x00 };
-
-        ////响应倒计时计数最大值
-        //private static int MaxRevIndexNum = 6;
-
-        ////发送倒计时计数最大值
-        //private static int MaxSendIndexNum = 3;
-
         //响应倒计时计数最大值
         private static int MaxRevIndexNum = 50;
 
@@ -117,7 +106,8 @@ namespace HaoYueNet.ClientNetworkNet4x
 
         private void SendToSocket(byte[] data)
         {
-            data = SendDataWithHead(data);
+            //已拼接包长度，这里不再需要拼接长度
+            //data = SendDataWithHead(data);
             try
             {
                 SendWithIndex(data);
@@ -158,25 +148,25 @@ namespace HaoYueNet.ClientNetworkNet4x
             client.Send(data);
         }
 
-        //拼接头长度
+        ////拼接头长度
-        private byte[] SendDataWithHead(byte[] message)
+        //private byte[] SendDataWithHead(byte[] message)
-        {
+        //{
 
-            MemoryStream memoryStream = new MemoryStream();//创建一个内存流
+        //    MemoryStream memoryStream = new MemoryStream();//创建一个内存流
 
-            byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
+        //    byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
 
-            memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
+        //    memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
 
-            memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
+        //    memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
 
-            byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
+        //    byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
 
-            memoryStream.Close();//关闭内存
+        //    memoryStream.Close();//关闭内存
-            memoryStream.Dispose();//释放资源
+        //    memoryStream.Dispose();//释放资源
 
-            return HeadAndBody;
+        //    return HeadAndBody;
-        }
+        //}
 
         /// <summary>
         /// 供外部调用 发送消息
@@ -345,11 +335,18 @@ namespace HaoYueNet.ClientNetworkNet4x
                             //把头去掉，就可以吃了，蛋白质是牛肉的六倍
                             //DataCallBackReady(getData.Skip(StartIndex+4).Take(HeadLength-4).ToArray());
 
-                            //改为Array.Copy 提升效率
                             int CoreLenght = HeadLength - 4;
-                            byte[] retData = new byte[CoreLenght];
+
-                            Array.Copy(getData, StartIndex + 4, retData, 0, CoreLenght);
+                            //改为Array.Copy 提升效率
-                            DataCallBackReady(retData);
+                            //byte[] retData = new byte[CoreLenght];
+                            //Array.Copy(getData, StartIndex + 4, retData, 0, CoreLenght);
+                            //DataCallBackReady(retData);
+
+                            //用Span
+                            Span<byte> getData_span = getData;
+                            getData_span = getData_span.Slice(StartIndex + 4, CoreLenght);
+                            DataCallBackReady(getData_span.ToArray());
+
                             StartIndex += HeadLength;//当读取一条完整的数据后，读取数据的起始下标应为当前接受到的消息体的长度（当前数据的尾部或下一条消息的首部）
                         }
                     }

NetLib/HaoYueNet.ClientNetworkNet4x/NetworkHelperP2PCore.cs

@@ -7,372 +7,365 @@ using static HaoYueNet.ClientNetworkNet4x.BaseData;
 
 namespace HaoYueNet.ClientNetworkNet4x
 {
-    namespace HaoYueNet.ClientNetwork
+    public class NetworkHelperP2PCore
     {
-        public class NetworkHelperP2PCore
+        private Socket client;
+
+        //响应倒计时计数最大值
+        private static int MaxRevIndexNum = 50;
+
+        //发送倒计时计数最大值
+        private static int MaxSendIndexNum = 3;
+
+        //响应倒计时计数
+        private static int RevIndex = 0;
+        //发送倒计时计数
+        private static int SendIndex = 0;
+
+        //计时器间隔
+        private static int TimerInterval = 3000;
+
+        private System.Timers.Timer _heartTimer;
+
+        public void Init(string IP, int port, bool bBindReuseAddress = false, int bBindport = 0)
         {
-            private Socket client;
 
-            /// <summary>
+            LogOut("==>初始化网络核心");
-            /// 心跳包数据
-            /// </summary>
-            private byte[] HeartbeatData = new byte[5] { 0x05, 0x00, 0x00, 0x00, 0x00 };
 
-            ////响应倒计时计数最大值
+            RevIndex = MaxRevIndexNum;
-            //private static int MaxRevIndexNum = 6;
+            SendIndex = MaxSendIndexNum;
 
-            ////发送倒计时计数最大值
+            client = new Socket(SocketType.Stream, ProtocolType.Tcp);
-            //private static int MaxSendIndexNum = 3;
+            if (bBindReuseAddress)
-
-            //响应倒计时计数最大值
-            private static int MaxRevIndexNum = 50;
-
-            //发送倒计时计数最大值
-            private static int MaxSendIndexNum = 3;
-
-            //响应倒计时计数
-            private static int RevIndex = 0;
-            //发送倒计时计数
-            private static int SendIndex = 0;
-
-            //计时器间隔
-            private static int TimerInterval = 3000;
-
-            private System.Timers.Timer _heartTimer;
-
-            public void Init(string IP, int port, bool bBindReuseAddress = false, int bBindport = 0)
             {
+                client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
+                IPEndPoint ipe = new IPEndPoint(IPAddress.Any, Convert.ToInt32(bBindport));
+                client.Bind(ipe);
+            }
+            Connect(IP, port);
+        }
 
-                LogOut("==>初始化网络核心");
+        public bool Connect(string IP, int port)
+        {
+            //带回调的
+            try
+            {
+                LogOut("连接到远程IP " + IP + ":" + port);
+                client.Connect(IP, port);
+                Thread thread = new Thread(Recive);
+                thread.IsBackground = true;
+                thread.Start(client);
+                int localport = ((IPEndPoint)client.LocalEndPoint).Port;
+                LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
 
-                RevIndex = MaxRevIndexNum;
+                if (_heartTimer == null)
-                SendIndex = MaxSendIndexNum;
-
-                client = new Socket(SocketType.Stream, ProtocolType.Tcp);
-                if (bBindReuseAddress)
                 {
-                    client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
+                    _heartTimer = new System.Timers.Timer();
-                    IPEndPoint ipe = new IPEndPoint(IPAddress.Any, Convert.ToInt32(bBindport));
-                    client.Bind(ipe);
                 }
-                Connect(IP, port);
+                _heartTimer.Interval = TimerInterval;
+                _heartTimer.Elapsed += CheckUpdatetimer_Elapsed;
+                _heartTimer.AutoReset = true;
+                _heartTimer.Enabled = true;
+                LogOut("开启心跳包检测");
+
+                OnConnected(true);
+                return true;
             }
-
+            catch (Exception ex)
-            public bool Connect(string IP, int port)
             {
-                //带回调的
+                LogOut("连接失败：" + ex.ToString());
-                try
+                OnConnected(false);
-                {
+                return false;
-                    LogOut("连接到远程IP " + IP + ":" + port);
-                    client.Connect(IP, port);
-                    Thread thread = new Thread(Recive);
-                    thread.IsBackground = true;
-                    thread.Start(client);
-                    int localport = ((IPEndPoint)client.LocalEndPoint).Port;
-                    LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
-
-                    if (_heartTimer == null)
-                    {
-                        _heartTimer = new System.Timers.Timer();
-                    }
-                    _heartTimer.Interval = TimerInterval;
-                    _heartTimer.Elapsed += CheckUpdatetimer_Elapsed;
-                    _heartTimer.AutoReset = true;
-                    _heartTimer.Enabled = true;
-                    LogOut("开启心跳包检测");
-
-                    OnConnected(true);
-                    return true;
-                }
-                catch (Exception ex)
-                {
-                    LogOut("连接失败：" + ex.ToString());
-                    OnConnected(false);
-                    return false;
-                }
             }
+        }
 
-            ~NetworkHelperP2PCore()
+        ~NetworkHelperP2PCore()
+        {
+            client.Close();
+        }
+
+        private void SendToSocket(byte[] data)
+        {
+            //已拼接包长度，这里不再需要拼接长度
+            //data = SendDataWithHead(data);
+            try
             {
-                client.Close();
+                SendWithIndex(data);
             }
-
+            catch (Exception ex)
-            private void SendToSocket(byte[] data)
-            {
-                data = SendDataWithHead(data);
-                try
-                {
-                    SendWithIndex(data);
-                }
-                catch (Exception ex)
-                {
-                    //连接断开
-                    OnCloseReady();
-                    return;
-                }
-                //LogOut("发送消息，消息长度=> "+data.Length);
-            }
-
-            private void SendHeartbeat()
-            {
-                try
-                {
-                    SendWithIndex(HeartbeatData);
-                }
-                catch (Exception ex)
-                {
-                    //连接断开
-                    OnCloseReady();
-                    return;
-                }
-                //LogOut("发送心跳包");
-            }
-
-            /// <summary>
-            /// 发送数据并计数
-            /// </summary>
-            /// <param name="data"></param>
-            private void SendWithIndex(byte[] data)
-            {
-                //增加发送计数
-                SendIndex = MaxSendIndexNum;
-                //发送数据
-                client.Send(data);
-            }
-
-            //拼接头长度
-            private byte[] SendDataWithHead(byte[] message)
-            {
-
-                MemoryStream memoryStream = new MemoryStream();//创建一个内存流
-
-                byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
-
-                memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
-
-                memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
-
-                byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
-
-                memoryStream.Close();//关闭内存
-                memoryStream.Dispose();//释放资源
-
-                return HeadAndBody;
-            }
-
-            /// <summary>
-            /// 供外部调用 发送消息
-            /// </summary>
-            /// <param name="CMDID"></param>
-            /// <param name="ERRCODE"></param>
-            /// <param name="data"></param>
-            public void SendToSocket(int CMDID, int ERRCODE, byte[] data)
-            {
-                //LogOut("准备数据 CMDID=> "+CMDID);
-                /*HunterNet_S2C _s2sdata = new HunterNet_S2C();
-                _s2sdata.HunterNetCoreCmdID = CMDID;
-                _s2sdata.HunterNetCoreERRORCode = ERRCODE;
-                _s2sdata.HunterNetCoreData = ByteString.CopyFrom(data);
-                byte[] _finaldata = Serizlize(_s2sdata);*/
-
-                byte[] _finaldata = HunterNet_S2C.CreatePkgData((ushort)CMDID, (ushort)ERRCODE, data);
-                SendToSocket(_finaldata);
-            }
-
-            public delegate void OnDataCallBack_Data(int CMDID, int ERRCODE, byte[] data);
-
-            public event OnDataCallBack_Data OnDataCallBack;
-
-            public delegate void delegate_NoData();
-
-            public delegate void delegate_Bool(bool IsConnected);
-
-            public event delegate_NoData OnClose;
-
-            public event delegate_Bool OnConnected;
-
-            public delegate void delegate_str(string Msg);
-
-            /// <summary>
-            /// 网络库调试日志输出
-            /// </summary>
-            public event delegate_str OnLogOut;
-
-            ///// <summary>
-            ///// 用于调用者回调的虚函数
-            ///// </summary>
-            ///// <param name="data"></param>
-            //public virtual void DataCallBack(int CMDID,int ERRCODE,byte[] data)
-            //{
-
-            //}
-
-            ///// <summary>
-            ///// 断开连接
-            ///// </summary>
-            ///// <param name="sk"></param>
-            //public virtual void OnClose()
-            //{
-
-            //}
-
-            /// <summary>
-            /// 做好处理的连接管理
-            /// </summary>
-            private void OnCloseReady()
-            {
-                LogOut("关闭心跳包计数");
-                _heartTimer.Enabled = false;
-                _heartTimer.Elapsed -= CheckUpdatetimer_Elapsed;
-                LogOut("关闭连接");
-                //关闭Socket连接
-                client.Close();
-                OnClose();
-            }
-
-
-            /// <summary>
-            /// 主动关闭连接
-            /// </summary>
-            public void CloseConntect()
             {
+                //连接断开
                 OnCloseReady();
+                return;
+            }
+            //LogOut("发送消息，消息长度=> "+data.Length);
+        }
+
+        private void SendHeartbeat()
+        {
+            try
+            {
+                SendWithIndex(BaseData.HeartbeatData);
+            }
+            catch (Exception ex)
+            {
+                //连接断开
+                OnCloseReady();
+                return;
+            }
+            //LogOut("发送心跳包");
+        }
+
+        /// <summary>
+        /// 发送数据并计数
+        /// </summary>
+        /// <param name="data"></param>
+        private void SendWithIndex(byte[] data)
+        {
+            //增加发送计数
+            SendIndex = MaxSendIndexNum;
+            //发送数据
+            client.Send(data);
+        }
+
+        //拼接头长度
+        private byte[] SendDataWithHead(byte[] message)
+        {
+
+            MemoryStream memoryStream = new MemoryStream();//创建一个内存流
+
+            byte[] BagHead = BitConverter.GetBytes(message.Length + 4);//往字节数组中写入包头（包头自身的长度和消息体的长度）的长度
+
+            memoryStream.Write(BagHead, 0, BagHead.Length);//将包头写入内存流
+
+            memoryStream.Write(message, 0, message.Length);//将消息体写入内存流
+
+            byte[] HeadAndBody = memoryStream.ToArray();//将内存流中的数据写入字节数组
+
+            memoryStream.Close();//关闭内存
+            memoryStream.Dispose();//释放资源
+
+            return HeadAndBody;
+        }
+
+        /// <summary>
+        /// 供外部调用 发送消息
+        /// </summary>
+        /// <param name="CMDID"></param>
+        /// <param name="ERRCODE"></param>
+        /// <param name="data"></param>
+        public void SendToSocket(int CMDID, int ERRCODE, byte[] data)
+        {
+            //LogOut("准备数据 CMDID=> "+CMDID);
+            /*HunterNet_S2C _s2sdata = new HunterNet_S2C();
+            _s2sdata.HunterNetCoreCmdID = CMDID;
+            _s2sdata.HunterNetCoreERRORCode = ERRCODE;
+            _s2sdata.HunterNetCoreData = ByteString.CopyFrom(data);
+            byte[] _finaldata = Serizlize(_s2sdata);*/
+
+            byte[] _finaldata = HunterNet_S2C.CreatePkgData((ushort)CMDID, (ushort)ERRCODE, data);
+            SendToSocket(_finaldata);
+        }
+
+        public delegate void OnDataCallBack_Data(int CMDID, int ERRCODE, byte[] data);
+
+        public event OnDataCallBack_Data OnDataCallBack;
+
+        public delegate void delegate_NoData();
+
+        public delegate void delegate_Bool(bool IsConnected);
+
+        public event delegate_NoData OnClose;
+
+        public event delegate_Bool OnConnected;
+
+        public delegate void delegate_str(string Msg);
+
+        /// <summary>
+        /// 网络库调试日志输出
+        /// </summary>
+        public event delegate_str OnLogOut;
+
+        ///// <summary>
+        ///// 用于调用者回调的虚函数
+        ///// </summary>
+        ///// <param name="data"></param>
+        //public virtual void DataCallBack(int CMDID,int ERRCODE,byte[] data)
+        //{
+
+        //}
+
+        ///// <summary>
+        ///// 断开连接
+        ///// </summary>
+        ///// <param name="sk"></param>
+        //public virtual void OnClose()
+        //{
+
+        //}
+
+        /// <summary>
+        /// 做好处理的连接管理
+        /// </summary>
+        private void OnCloseReady()
+        {
+            LogOut("关闭心跳包计数");
+            _heartTimer.Enabled = false;
+            _heartTimer.Elapsed -= CheckUpdatetimer_Elapsed;
+            LogOut("关闭连接");
+            //关闭Socket连接
+            client.Close();
+            OnClose();
+        }
+
+
+        /// <summary>
+        /// 主动关闭连接
+        /// </summary>
+        public void CloseConntect()
+        {
+            OnCloseReady();
+        }
+
+        private void DataCallBackReady(byte[] data)
+        {
+
+            //增加接收计数
+            RevIndex = MaxRevIndexNum;
+
+            //不处理心跳包
+            if (data.Length == 1 && data[0] == 0x00)
+            {
+                //LogOut("收到心跳包");
+                return;
             }
 
-            private void DataCallBackReady(byte[] data)
+            /*
+            HunterNet_S2C _c2s = DeSerizlize<HunterNet_S2C>(data);
+            OnDataCallBack(_c2s.HunterNetCoreCmdID, _c2s.HunterNetCoreERRORCode, _c2s.HunterNetCoreData.ToArray());
+            */
+            HunterNet_S2C.AnalysisPkgData(data, out ushort CmdID, out ushort Error, out byte[] resultdata);
+            OnDataCallBack(CmdID, Error, resultdata);
+        }
+
+        MemoryStream memoryStream = new MemoryStream();//开辟一个内存流
+        private void Recive(object o)
+        {
+            var client = o as Socket;
+            //MemoryStream memoryStream = new MemoryStream();//开辟一个内存流
+
+            while (true)
             {
-
+                byte[] buffer = new byte[1024 * 1024 * 2];
-                //增加接收计数
+                int effective = 0;
-                RevIndex = MaxRevIndexNum;
+                try
-
-                //不处理心跳包
-                if (data.Length == 1 && data[0] == 0x00)
                 {
-                    //LogOut("收到心跳包");
+                    effective = client.Receive(buffer);
+                    if (effective == 0)
+                    {
+                        continue;
+                    }
+                }
+                catch (Exception ex)
+                {
+                    //远程主机强迫关闭了一个现有的连接
+                    OnCloseReady();
                     return;
+                    //断开连接
                 }
 
-                /*
-                HunterNet_S2C _c2s = DeSerizlize<HunterNet_S2C>(data);
-                OnDataCallBack(_c2s.HunterNetCoreCmdID, _c2s.HunterNetCoreERRORCode, _c2s.HunterNetCoreData.ToArray());
-                */
-                HunterNet_S2C.AnalysisPkgData(data, out ushort CmdID, out ushort Error, out byte[] resultdata);
-                OnDataCallBack(CmdID, Error, resultdata);
-            }
 
-            MemoryStream memoryStream = new MemoryStream();//开辟一个内存流
+                memoryStream.Write(buffer, 0, effective);//将接受到的数据写入内存流中
-            private void Recive(object o)
+                byte[] getData = memoryStream.ToArray();//将内存流中的消息体写入字节数组
-            {
+                int StartIndex = 0;//设置一个读取数据的起始下标
-                var client = o as Socket;
-                //MemoryStream memoryStream = new MemoryStream();//开辟一个内存流
 
                 while (true)
                 {
-                    byte[] buffer = new byte[1024 * 1024 * 2];
+
-                    int effective = 0;
+
-                    try
+                    if (effective > 0)//如果接受到的消息不为0（不为空）
                     {
-                        effective = client.Receive(buffer);
+                        int HeadLength = 0;//包头长度（包头+包体）
-                        if (effective == 0)
+                        if (getData.Length - StartIndex < 4)//包头接受不完整
                         {
-                            continue;
+                            HeadLength = -1;
                         }
-                    }
+                        else
-                    catch (Exception ex)
-                    {
-                        //远程主机强迫关闭了一个现有的连接
-                        OnCloseReady();
-                        return;
-                        //断开连接
-                    }
-
-
-                    memoryStream.Write(buffer, 0, effective);//将接受到的数据写入内存流中
-                    byte[] getData = memoryStream.ToArray();//将内存流中的消息体写入字节数组
-                    int StartIndex = 0;//设置一个读取数据的起始下标
-
-                    while (true)
-                    {
-
-
-                        if (effective > 0)//如果接受到的消息不为0（不为空）
                         {
-                            int HeadLength = 0;//包头长度（包头+包体）
+                            //如果包头接受完整  转换成int类型的数值
-                            if (getData.Length - StartIndex < 4)//包头接受不完整
+                            HeadLength = BitConverter.ToInt32(getData, StartIndex);
-                            {
+                        }
-                                HeadLength = -1;
+                        //包头接受完整但是消息体不完整              //包头接受不完整
-                            }
+                        //↓↓↓↓↓↓↓↓                            ↓↓↓
-                            else
+                        if (getData.Length - StartIndex < HeadLength || HeadLength == -1)
-                            {
+                        {
-                                //如果包头接受完整  转换成int类型的数值
+                            /* 一种清空流的方式
-                                HeadLength = BitConverter.ToInt32(getData, StartIndex);
+                            memoryStream.Close();//关闭内存流
-                            }
+                            memoryStream.Dispose();//释放内存资源
-                            //包头接受完整但是消息体不完整              //包头接受不完整
+                            memoryStream = new MemoryStream();//创建新的内存流
-                            //↓↓↓↓↓↓↓↓                            ↓↓↓
+                            */
-                            if (getData.Length - StartIndex < HeadLength || HeadLength == -1)
-                            {
-                                /* 一种清空流的方式
-                                memoryStream.Close();//关闭内存流
-                                memoryStream.Dispose();//释放内存资源
-                                memoryStream = new MemoryStream();//创建新的内存流
-                                */
 
-                                //流复用的方式 不用重新new申请
+                            //流复用的方式 不用重新new申请
-                                memoryStream.Position = 0;
+                            memoryStream.Position = 0;
-                                memoryStream.SetLength(0);
+                            memoryStream.SetLength(0);
 
-                                memoryStream.Write(getData, StartIndex, getData.Length - StartIndex);//从新将接受的消息写入内存流
+                            memoryStream.Write(getData, StartIndex, getData.Length - StartIndex);//从新将接受的消息写入内存流
-                                break;
+                            break;
-                            }
+                        }
-                            else
+                        else
-                            {
+                        {
-                                //把头去掉，就可以吃了，蛋白质是牛肉的六倍
+                            //把头去掉，就可以吃了，蛋白质是牛肉的六倍
-                                //DataCallBackReady(getData.Skip(StartIndex+4).Take(HeadLength-4).ToArray());
+                            //DataCallBackReady(getData.Skip(StartIndex+4).Take(HeadLength-4).ToArray());
 
-                                //改为Array.Copy 提升效率
+                            int CoreLenght = HeadLength - 4;
-                                int CoreLenght = HeadLength - 4;
+                            //改为Array.Copy 提升效率
-                                byte[] retData = new byte[CoreLenght];
+                            //byte[] retData = new byte[CoreLenght];
-                                Array.Copy(getData, StartIndex + 4, retData, 0, CoreLenght);
+                            //Array.Copy(getData, StartIndex + 4, retData, 0, CoreLenght);
-                                DataCallBackReady(retData);
+                            //DataCallBackReady(retData);
-                                StartIndex += HeadLength;//当读取一条完整的数据后，读取数据的起始下标应为当前接受到的消息体的长度（当前数据的尾部或下一条消息的首部）
+
-                            }
+                            //用Span
+                            Span<byte> getData_span = getData;
+                            getData_span = getData_span.Slice(StartIndex + 4, CoreLenght);
+                            DataCallBackReady(getData_span.ToArray());
+
+                            StartIndex += HeadLength;//当读取一条完整的数据后，读取数据的起始下标应为当前接受到的消息体的长度（当前数据的尾部或下一条消息的首部）
                         }
                     }
                 }
             }
+        }
 
-            private void CheckUpdatetimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
+        private void CheckUpdatetimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
+        {
+            //接收服务器数据计数
+            RevIndex--;
+            if (RevIndex <= 0)
             {
-                //接收服务器数据计数
+                //判定掉线
-                RevIndex--;
+                OnCloseReady();
-                if (RevIndex <= 0)
+                return;
-                {
-                    //判定掉线
-                    OnCloseReady();
-                    return;
-                }
-
-                //发送计数
-                SendIndex--;
-                if (SendIndex <= 0)//需要发送心跳包了
-                {
-                    //重置倒计时计数
-                    SendIndex = MaxSendIndexNum;
-
-                    SendHeartbeat();
-                }
             }
 
-            public void LogOut(string Msg)
+            //发送计数
+            SendIndex--;
+            if (SendIndex <= 0)//需要发送心跳包了
             {
-                //Console.WriteLine(Msg);
+                //重置倒计时计数
-                OnLogOut(Msg);
+                SendIndex = MaxSendIndexNum;
-            }
 
-            public Socket GetClientSocket()
+                SendHeartbeat();
-            {
-                return client;
             }
         }
+
+        public void LogOut(string Msg)
+        {
+            //Console.WriteLine(Msg);
+            OnLogOut(Msg);
+        }
+
+        public Socket GetClientSocket()
+        {
+            return client;
+        }
     }
 }

NetLib/HaoYueNet.ClientNetworkNet4x/packages.config

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="utf-8"?>
+<packages>
+  <package id="System.Buffers" version="4.5.1" targetFramework="net452" />
+  <package id="System.Memory" version="4.5.5" targetFramework="net452" />
+  <package id="System.Runtime.CompilerServices.Unsafe" version="4.5.3" targetFramework="net452" />
+</packages>