增加protobuf,简单封包

Author: coding2233

Assets/GameFramework/Network/KcpChannel.cs

@@ -62,18 +62,18 @@ public KcpChannel(int port,Action<byte[]> reveiveHandler)
 
 			_receiveMeesages = new Queue<byte[]>();
 
-		    _udpClient.BeginReceive(ReceiveMessage, this);
+		    _udpClient.BeginReceive(UdpReceiveMessage, this);
 
             Thread updataThread = new Thread(Update);
 			updataThread.Start();
 		    updataThread.IsBackground = true;
         }
 
-	    private void ReceiveMessage(IAsyncResult asyncCallback)
+	    private void UdpReceiveMessage(IAsyncResult asyncCallback)
 	    {
 	        byte[] datas = _udpClient.EndReceive(asyncCallback,ref _recEndPoint);
 	        _receiveMeesages.Enqueue(datas);
-	        _udpClient?.BeginReceive(ReceiveMessage,this);
+	        _udpClient?.BeginReceive(UdpReceiveMessage, this);
 	    }
 
 
@@ -97,8 +97,7 @@ public void Send(byte[] datas,bool toAll=false)
 				_currentEndPoint = _targetEndPoinnt;
             _kcp?.Send(datas);
 		}
-
-	
+		
 		private void Update()
 		{
 		    while (true)
@@ -113,9 +112,9 @@ private void Update()
 		            for (var size = _kcp.PeekSize(); size > 0; size = _kcp.PeekSize())
 		            {
 		                var buffer = new byte[size];
-		                if (_kcp.Recv(buffer) > 0)
-		                {
-		                    _reveiveHandler(buffer);
+						if (_kcp.Recv(buffer)>0)
+						{
+							_reveiveHandler(buffer);
 		                }
 		            }
 		        }
@@ -125,6 +124,10 @@ private void Update()
 		    }
 		}
 
+		//private void ReceiveMessage(byt)
+
+
+
 
 	}
 

Assets/GameFramework/Network/KcpService.cs

@@ -0,0 +1,98 @@
+//-----------------------------------------------------------------------
+// <copyright>
+//     Copyright (c) 2018 Zhang Yang. All rights reserved.
+// </copyright>
+// <describe> #Kcp 通信接口,简单封包+序列化# </describe>
+// <email> [email protected] </email>
+// <time> #2018年7月29日 21点05分# </time>
+//-----------------------------------------------------------------------
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using Google.Protobuf;
+
+namespace GameFramework.Taurus
+{
+	public class KcpService
+	{
+		#region 属性
+		private KcpChannel _kcpChannel;
+
+		private Queue<byte[]> _receiveDatas;
+
+		private List<byte> _lastReceiveDatas;
+
+	//	private Action<ushort, byte[]> _receiveDataCallback;
+		private Action<ushort, object> _receiveMessageCallback;
+
+		private ProtobufPacker _protobufPacker;
+		#endregion
+
+		public KcpService(int port,Action<ushort, object> receiveMessageCallback)
+		{
+			_lastReceiveDatas = new List<byte>();
+			_receiveDatas = new Queue<byte[]>();
+			_kcpChannel = new KcpChannel(port, ReceiveData);
+			_receiveMessageCallback = receiveMessageCallback;
+
+			_protobufPacker = new ProtobufPacker();
+		}
+
+		public void SetTargetEndPoint(string ip, int port)
+		{
+			_kcpChannel?.Connect(ip, port);
+		}
+
+
+		public void Update()
+		{
+			while (_receiveDatas.Count > 0)
+			{
+				_lastReceiveDatas.AddRange(_receiveDatas.Dequeue());
+				if (_lastReceiveDatas.Count > 4)
+				{
+					byte[] datas = _lastReceiveDatas.ToArray();
+					int length = System.BitConverter.ToInt32(datas,0);
+					if (_lastReceiveDatas.Count >=length+4)
+					{
+						ushort type =System.BitConverter.ToUInt16(datas, 2);
+						byte[] messageData = _lastReceiveDatas.GetRange(6, length-2).ToArray();
+						//_receiveDataCallback?.Invoke(type, messageData);
+						_receiveMessageCallback?.Invoke(type, ReceiveMessage(type,messageData));
+						_lastReceiveDatas.RemoveRange(0, length + 4);
+					}
+				}
+			}
+		}
+
+		public void SendMessage(object message)
+		{
+			byte[] messageData = _protobufPacker.ToBytes(message);
+			MessageTypeCode typeCode = (MessageTypeCode)Enum.Parse(typeof(MessageTypeCode),message.GetType().ToString());
+			byte[] typeData = BitConverter.GetBytes((ushort) typeCode);
+			byte[] length = BitConverter.GetBytes(messageData.Length+2);
+			byte[] result = new byte[messageData.Length+ 2 + 4];
+			length.CopyTo(result, 0);
+			typeData.CopyTo(result, 4);
+			messageData.CopyTo(result, 6);
+			_kcpChannel?.Send(result);
+		}
+
+		private object ReceiveMessage(ushort typeCode,byte[] data)
+		{
+			MessageTypeCode code = (MessageTypeCode) typeCode;
+			
+			return _protobufPacker.ToMessage(Type.GetType(code.ToString()),data);
+		}
+
+
+		private void ReceiveData(byte[] data)
+		{
+			_receiveDatas.Enqueue(data);
+		}
+
+		
+
+	}
+}

Assets/GameFramework/Network/KcpService.cs.meta

@@ -0,0 +1,28 @@
+//-----------------------------------------------------------------------
+// <copyright>
+//     Copyright (c) 2018 Zhang Yang. All rights reserved.
+// </copyright>
+// <describe> #网络通信类型枚举# </describe>
+// <email> [email protected] </email>
+// <time> #2018年7月29日 21点29分# </time>
+//-----------------------------------------------------------------------
+
+using System;
+
+namespace GameFramework.Taurus
+{
+	/// <summary>
+	/// 列举通信类型的类型
+	/// 因为枚举不支持带.的字符串，所以建议继承Google.Protobuf.IMagess的类型不要加命名空间
+	/// 暂时简化操作，后面可以再在通信类型上添加标记
+	///  </summary>
+	public enum MessageTypeCode: ushort
+	{
+		/// <summary>
+		/// proto测试协议
+		/// </summary>
+		//ProtoTest=0,
+
+	}
+
+}

Assets/GameFramework/Network/MessageTypeCode.cs

@@ -0,0 +1,35 @@
+//-----------------------------------------------------------------------
+// <copyright>
+//     Copyright (c) 2018 Zhang Yang. All rights reserved.
+// </copyright>
+// <describe> #Protobuf的序列化的实现，后期再提接口# </describe>
+// <email> [email protected] </email>
+// <time> #2018年7月29日 21点28分# </time>
+//-----------------------------------------------------------------------
+
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using Google.Protobuf;
+
+namespace GameFramework.Taurus
+{
+	public class ProtobufPacker
+	{
+
+		public byte[] ToBytes(object message)
+		{
+			IMessage msg = message as IMessage;
+			return msg.ToByteArray();
+		}
+
+		public object ToMessage(Type type, byte[] datas)
+		{
+			IMessage result = (IMessage) Activator.CreateInstance(type);
+			result.MergeFrom(datas, 0, datas.Length);
+			return result;
+		}
+
+	}
+}

Assets/GameFramework/Network/MessageTypeCode.cs.meta

@@ -0,0 +1,79 @@
+#region Copyright notice and license
+// Protocol Buffers - Google's data interchange format
+// Copyright 2008 Google Inc.  All rights reserved.
+// https://developers.google.com/protocol-buffers/
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are
+// met:
+//
+//     * Redistributions of source code must retain the above copyright
+// notice, this list of conditions and the following disclaimer.
+//     * Redistributions in binary form must reproduce the above
+// copyright notice, this list of conditions and the following disclaimer
+// in the documentation and/or other materials provided with the
+// distribution.
+//     * Neither the name of Google Inc. nor the names of its
+// contributors may be used to endorse or promote products derived from
+// this software without specific prior written permission.
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+#endregion
+
+using System;
+
+namespace Google.Protobuf
+{
+    /// <summary>
+    /// Provides a utility routine to copy small arrays much more quickly than Buffer.BlockCopy
+    /// </summary>
+    internal static class ByteArray
+    {
+        /// <summary>
+        /// The threshold above which you should use Buffer.BlockCopy rather than ByteArray.Copy
+        /// </summary>
+        private const int CopyThreshold = 12;
+
+        /// <summary>
+        /// Determines which copy routine to use based on the number of bytes to be copied.
+        /// </summary>
+        internal static void Copy(byte[] src, int srcOffset, byte[] dst, int dstOffset, int count)
+        {
+            if (count > CopyThreshold)
+            {
+                Buffer.BlockCopy(src, srcOffset, dst, dstOffset, count);
+            }
+            else
+            {
+                int stop = srcOffset + count;
+                for (int i = srcOffset; i < stop; i++)
+                {
+                    dst[dstOffset++] = src[i];
+                }
+            }
+        }
+
+        /// <summary>
+        /// Reverses the order of bytes in the array
+        /// </summary>
+        internal static void Reverse(byte[] bytes)
+        {
+            for (int first = 0, last = bytes.Length - 1; first < last; first++, last--)
+            {
+                byte temp = bytes[first];
+                bytes[first] = bytes[last];
+                bytes[last] = temp;
+            }
+        }
+    }
+}