Unity的数据序列化与反序列化用于网络传输

雨点打透心脏的1/2处 2022-08-21 10:44 119阅读 0赞

Unity客户端与服务器通信，通过传输byte数组实现。这里使用BitConverter进行数据的序列化与反序列化把int，float，string各种变量封装成一个byte进行通信。

Packet类如下

using UnityEngine;
    using System.Collections;
    using System;
    using System.Collections.Generic;
    using System.Text;
    
    /// <summary>
    /// 用来序列化string
    /// </summary>
    public class MyBitConverter
    {
        static Encoding m_codePage = Encoding.UTF8;
        static public byte[] GetBytes(string sTmp)
        {
            if (sTmp == null)
            {
                return null;
            }
            return m_codePage.GetBytes(sTmp);
        }
    
        static public string GetString(byte[] bufByte, int idx, int iLen)
        {
            return m_codePage.GetString(bufByte, idx, iLen);
        }
    }
    public class Packet : System.Object
    {
        public byte[] m_buf;
        public int m_iPos = 0;
        public int m_iSize = 0;
        
        /// <summary>
        /// 重新设置buf的size
        /// </summary>
        /// <param name="iNewSize"></param>
        public void sizeSet(int iNewSize)
        {
            if (iNewSize < m_iSize)
                return;
            byte[] tmp = new byte[iNewSize];//产生一个新大小的buff
            m_iSize = iNewSize;
            if (m_iPos > 0)
                m_buf.CopyTo(tmp, 0);
            m_buf = tmp;
        }
    
        /// <summary>
        /// 复制操作把一个数组给m_buf
        /// </summary>
        /// <param name="bufByte"></param>
        /// <param name="iLen"></param>
        /// <returns></returns>
        public int write(byte[] bufByte,int iLen)
        {
            int iNewPos = m_iPos + iLen;
            //当新产生的位置大于老的size时，扩容
            if (iNewPos > m_iSize)
                sizeSet(iNewPos);
    
            if(iLen < bufByte.Length)
            {
                Array.Copy(bufByte, 0, m_buf, m_iPos, iLen);//只复制当前部分的数组
            }
            else if (iLen > bufByte.Length)
            {
                bufByte.CopyTo(m_buf, m_iPos);
                for (int i = 0; i < iLen - bufByte.Length; i++)
                {
                    m_buf[m_iPos + bufByte.Length + i] = 0;
                }
            }
            else if (iLen == bufByte.Length)
            {
                bufByte.CopyTo(m_buf, m_iPos);
            }
            m_iPos = iNewPos;
            return m_iPos;
        }
    
        static public Packet operator+(Packet self,int tmp)
        {
            byte[] bufByte = BitConverter.GetBytes(tmp);
            self.write(bufByte, bufByte.Length);
            return self;
        }
    
        static public Packet operator +(Packet self, float tmp)
        {
            byte[] bufByte = BitConverter.GetBytes(tmp);
            self.write(bufByte, bufByte.Length);
            return self;
        }
    
        static public Packet operator +(Packet self, ushort tmp)
        {
            byte[] bufByte = BitConverter.GetBytes(tmp);
            self.write(bufByte, bufByte.Length);
            return self;
        }
    
        static public Packet operator +(Packet self, string tmp)
        {
            if ( tmp == null)
            {
                byte[] bufByte = BitConverter.GetBytes(0);
                self.write(bufByte, sizeof(int));
            }
            
            if(tmp.Length > 0)
            {
                byte[] bufByte = MyBitConverter.GetBytes(tmp);
                byte[] bufLen = BitConverter.GetBytes(tmp.Length);
                self.write(bufLen, sizeof(int));
                self.write(bufByte, bufByte.Length);
            }
            else if (tmp.Length == 0)
            {
                byte[] bufByte = BitConverter.GetBytes(0);
                self.write(bufByte, sizeof(int));
            }
            return self;
        }
    
        public Packet to(ref int tmp)
        {
            int iOffset = 4;
            if (m_iPos + iOffset <= m_buf.Length)
            {
                tmp = BitConverter.ToInt32(m_buf, m_iPos);
                m_iPos += iOffset;
            }
            return this;
        }
    
        public Packet to(ref uint tmp)
        {
            int iOffset = 4;
            if (m_iPos + iOffset <= m_buf.Length)
            {
                tmp = BitConverter.ToUInt32(m_buf, m_iPos);
                m_iPos += iOffset;
            }
            return this;
        }
    
        public Packet to(ref float tmp)
        {
            int iOffset = 4;
            if (m_iPos + iOffset <= m_buf.Length)
            {
                tmp = BitConverter.ToSingle(m_buf, m_iPos);
                m_iPos += iOffset;
            }
            return this;
        }
    
        public Packet to(ref ushort tmp)
        {
            int iOffset = 2;
            if (m_iPos + iOffset <= m_buf.Length)
            {
                tmp = BitConverter.ToUInt16(m_buf, m_iPos);
                m_iPos += iOffset;
            }
            return this;
        }
    
        public Packet to(ref string tmp)
        {
            if (tmp == null)
                tmp = "";
            int iLen = 0;
            this.to(ref iLen);
            if (iLen == 0)
            {
                tmp = "";
                return this;
            }
            tmp = MyBitConverter.GetString(m_buf, m_iPos, iLen);
            m_iPos += iLen;
            return this;
        }
    
        public void posSet(int tmp)
        {
            m_iPos = tmp;
        }
    
        static public Packet bufByteToPkt(byte[] bufByte,int iLen)
        {
            Packet pkt = new Packet();
            pkt.sizeSet(iLen);
            System.Array.Copy(bufByte, 0, pkt.m_buf, 0, iLen);
            pkt.m_iPos = 0;
            return pkt;
        }
    
    }

使用示例如下

using UnityEngine;
    using System.Collections;
    
    public class Test : MonoBehaviour {
    
        int m_iCnt = 0;
        public int m_recv = 0;
        public UILabel m_labShow;
    	// Use this for initialization
    	void Start () {
            Packet pkt = new Packet();
            int i1 = 1;
            int i2 = 2;
            float f3 = 3.0f;
            string str = "luoyikun";
            pkt = pkt + i1 + i2 + f3 + str;
            pkt.posSet(0);
            pktTest(pkt);
    
    	}
    	
        void pktTest(Packet pkt)
        {
            int i1 = 0;
            int i2 = 0;
            float i3 = 0.0f;
            string str = "";
            pkt.to(ref i1).to(ref i2).to(ref i3).to(ref str);
        }
    }