自定義協議封裝包頭、包體

底層通信消息類，定義消息ID、消息體，和初始化

using System;  
  
/// <summary>  
/// 底層通信消息  
/// </summary>  
public class TSocketMessage : IDisposable  
{  
    /// <summary>  
    /// 消息ID  
    /// </summary>  
    public int MsgID;  
    /// <summary>  
    /// 消息內容  
    /// </summary>  
    public byte[] MsgBuffer;  
  
    public TSocketMessage(int msgID, byte[] msg)  
    {  
        this.MsgID = msgID;  
        this.MsgBuffer = msg;  
    }  
  
    public void Dispose()  
    {  
        this.Dispose(true);  
        GC.SuppressFinalize(this);  
    }  
  
    protected virtual void Dispose(bool flag1)  
    {  
        if (flag1) { this.MsgBuffer = null; }  
    }  
}  

消息解析器，封裝包頭、包體、解析包

using System;  
using System.Collections.Generic;  
using System.IO;  
using System.Text;  
  
// 消息解析器  
public class MarshalEndian  
{  
    //用於存儲剩余未解析的字節數  
    private List<byte> _LBuff = new List<byte>(2);  
    //默認是utf8的編碼格式  
    private UTF8Encoding utf8 = new UTF8Encoding();  
  
    //包頭1  
    const Int16 t1 = 0x55;  
    //包頭2  
    const Int16 t2 = 0xAA;  
    //字節數常量 兩個包頭4個字節，一個消息id4個字節，封裝消息長度 int32 4個字節  
    const Int32 ConstLenght = 8;  
  
    public void Dispose()  
    {  
        this.Dispose(true);  
        GC.SuppressFinalize(this);  
    }  
  
    protected virtual void Dispose(bool flag1)  
    {  
        if (flag1)  
        {  
            IDisposable disposable2 = this.utf8 as IDisposable;  
            if (disposable2 != null) { disposable2.Dispose(); }  
            IDisposable disposable = this._LBuff as IDisposable;  
            if (disposable != null) { disposable.Dispose(); }  
        }  
    }  
  
    public byte[] Encode(TSocketMessage msg)  
    {  
        MemoryStream ms = new MemoryStream();  
        BinaryWriter bw = new BinaryWriter(ms, new UTF8Encoding());  
        byte[] msgBuffer = msg.MsgBuffer;  
 
        #region 封裝包頭  
        bw.Write((Int16)t1);  
        bw.Write((Int16)t2);  
        #endregion  
 
        #region 包協議  
        if (msgBuffer != null)  
        {  
            bw.Write((Int32)(msgBuffer.Length + 4));  
            bw.Write(msg.MsgID);  
            bw.Write(msgBuffer);  
        }  
        else { bw.Write((Int32)0); }  
        #endregion  
  
        bw.Close();  
        ms.Close();  
        bw.Dispose();  
        ms.Dispose();  
        return ms.ToArray();  
    }  
  
    public List<TSocketMessage> GetDcAppMess(byte[] buff, int len)  
    {  
        //拷貝本次的有效字節  
        byte[] _b = new byte[len];  
        Array.Copy(buff, 0, _b, 0, _b.Length);  
        buff = _b;  
        if (this._LBuff.Count > 0)  
        {  
            //拷貝之前遺留的字節  
            this._LBuff.AddRange(_b);  
            buff = this._LBuff.ToArray();  
            this._LBuff.Clear();  
            this._LBuff = new List<byte>(2);  
        }  
  
        List<TSocketMessage> list = new List<TSocketMessage>();  
        MemoryStream ms = new MemoryStream(buff);  
        BinaryReader buffers = new BinaryReader(ms, this.utf8);  
        try  
        {  
            byte[] _buff;  
            Label_00983:  
 
            #region 包頭讀取  
            //循環讀取包頭             
            //判斷本次解析的字節是否滿足常量字節數   
            if ((buffers.BaseStream.Length - buffers.BaseStream.Position) < ConstLenght)  
            {  
                _buff = buffers.ReadBytes((int)(buffers.BaseStream.Length - buffers.BaseStream.Position));  
                this._LBuff.AddRange(_buff);  
                return list;  
            }  
            Int16 tt1 = buffers.ReadInt16();  
            Int16 tt2 = buffers.ReadInt16();  
            if (!(tt1 == t1 && tt2 == t2))  
            {  
                long ttttt = buffers.BaseStream.Seek(-3, SeekOrigin.Current);  
                goto Label_00983;  
            }  
            #endregion  
 
            #region 包協議  
            int offset = buffers.ReadInt32();  
            #endregion  
 
            #region 包解析  
            //剩余字節數大於本次需要讀取的字節數  
            if (offset <= (buffers.BaseStream.Length - buffers.BaseStream.Position))  
            {  
                int msgID = buffers.ReadInt32();  
                _buff = buffers.ReadBytes(offset - 4);  
                list.Add(new TSocketMessage(msgID, _buff));  
                if ((buffers.BaseStream.Length - buffers.BaseStream.Position) > 0)  
                {  
                    goto Label_00983;  
                }  
            }  
            else  
            {  
                //剩余字節數剛好小於本次讀取的字節數 存起來，等待接受剩余字節數一起解析  
                _buff = buffers.ReadBytes((int)(buffers.BaseStream.Length - buffers.BaseStream.Position + ConstLenght));  
                this._LBuff.AddRange(_buff);  
            }  
            #endregion  
        }  
        catch (Exception ex) { Console.WriteLine(ex); }  
        finally  
        {  
            if (buffers != null) { buffers.Dispose(); }  
            buffers.Close();  
            if (buffers != null) { buffers.Dispose(); }  
            ms.Close();  
            if (ms != null) { ms.Dispose(); }  
        }  
        return list;  
    }  
}