自定义协议封装包头、包体

底层通信消息类，定义消息ID、消息体，和初始化

 1 using System;
 2
 3 /// <summary>
 4 /// 底层通信消息
 5 /// </summary>
 6 public class TSocketMessage : IDisposable
 7 {
 8     /// <summary>
 9     /// 消息ID
10     /// </summary>
11     public int MsgID;
12     /// <summary>
13     /// 消息内容
14     /// </summary>
15     public byte[] MsgBuffer;
16
17     public TSocketMessage(int msgID, byte[] msg)
18     {
19         this.MsgID = msgID;
20         this.MsgBuffer = msg;
21     }
22
23     public void Dispose()
24     {
25         this.Dispose(true);
26         GC.SuppressFinalize(this);
27     }
28
29     protected virtual void Dispose(bool flag1)
30     {
31         if (flag1) { this.MsgBuffer = null; }
32     }
33 }  

消息解析器，封装包头、包体、解析包

  1 using System;
  2 using System.Collections.Generic;
  3 using System.IO;
  4 using System.Text;
  5
  6 // 消息解析器
  7 public class MarshalEndian
  8 {
  9     //用于存储剩余未解析的字节数
 10     private List<byte> _LBuff = new List<byte>(2);
 11     //默认是utf8的编码格式
 12     private UTF8Encoding utf8 = new UTF8Encoding();
 13
 14     //包头1
 15     const Int16 t1 = 0x55;
 16     //包头2
 17     const Int16 t2 = 0xAA;
 18     //字节数常量 两个包头4个字节，一个消息id4个字节，封装消息长度 int32 4个字节
 19     const Int32 ConstLenght = 8;
 20
 21     public void Dispose()
 22     {
 23         this.Dispose(true);
 24         GC.SuppressFinalize(this);
 25     }
 26
 27     protected virtual void Dispose(bool flag1)
 28     {
 29         if (flag1)
 30         {
 31             IDisposable disposable2 = this.utf8 as IDisposable;
 32             if (disposable2 != null) { disposable2.Dispose(); }
 33             IDisposable disposable = this._LBuff as IDisposable;
 34             if (disposable != null) { disposable.Dispose(); }
 35         }
 36     }
 37
 38     public byte[] Encode(TSocketMessage msg)
 39     {
 40         MemoryStream ms = new MemoryStream();
 41         BinaryWriter bw = new BinaryWriter(ms, new UTF8Encoding());
 42         byte[] msgBuffer = msg.MsgBuffer;
 43
 44         #region 封装包头
 45         bw.Write((Int16)t1);
 46         bw.Write((Int16)t2);
 47         #endregion
 48
 49         #region 包协议
 50         if (msgBuffer != null)
 51         {
 52             bw.Write((Int32)(msgBuffer.Length + 4));
 53             bw.Write(msg.MsgID);
 54             bw.Write(msgBuffer);
 55         }
 56         else { bw.Write((Int32)0); }
 57         #endregion
 58
 59         bw.Close();
 60         ms.Close();
 61         bw.Dispose();
 62         ms.Dispose();
 63         return ms.ToArray();
 64     }
 65
 66     public List<TSocketMessage> GetDcAppMess(byte[] buff, int len)
 67     {
 68         //拷贝本次的有效字节
 69         byte[] _b = new byte[len];
 70         Array.Copy(buff, 0, _b, 0, _b.Length);
 71         buff = _b;
 72         if (this._LBuff.Count > 0)
 73         {
 74             //拷贝之前遗留的字节
 75             this._LBuff.AddRange(_b);
 76             buff = this._LBuff.ToArray();
 77             this._LBuff.Clear();
 78             this._LBuff = new List<byte>(2);
 79         }
 80
 81         List<TSocketMessage> list = new List<TSocketMessage>();
 82         MemoryStream ms = new MemoryStream(buff);
 83         BinaryReader buffers = new BinaryReader(ms, this.utf8);
 84         try
 85         {
 86             byte[] _buff;
 87             Label_00983:
 88
 89             #region 包头读取
 90             //循环读取包头
 91             //判断本次解析的字节是否满足常量字节数
 92             if ((buffers.BaseStream.Length - buffers.BaseStream.Position) < ConstLenght)
 93             {
 94                 _buff = buffers.ReadBytes((int)(buffers.BaseStream.Length - buffers.BaseStream.Position));
 95                 this._LBuff.AddRange(_buff);
 96                 return list;
 97             }
 98             Int16 tt1 = buffers.ReadInt16();
 99             Int16 tt2 = buffers.ReadInt16();
100             if (!(tt1 == t1 && tt2 == t2))
101             {
102                 long ttttt = buffers.BaseStream.Seek(-3, SeekOrigin.Current);
103                 goto Label_00983;
104             }
105             #endregion
106
107             #region 包协议
108             int offset = buffers.ReadInt32();
109             #endregion
110
111             #region 包解析
112             //剩余字节数大于本次需要读取的字节数
113             if (offset <= (buffers.BaseStream.Length - buffers.BaseStream.Position))
114             {
115                 int msgID = buffers.ReadInt32();
116                 _buff = buffers.ReadBytes(offset - 4);
117                 list.Add(new TSocketMessage(msgID, _buff));
118                 if ((buffers.BaseStream.Length - buffers.BaseStream.Position) > 0)
119                 {
120                     goto Label_00983;
121                 }
122             }
123             else
124             {
125                 //剩余字节数刚好小于本次读取的字节数 存起来，等待接受剩余字节数一起解析
126                 _buff = buffers.ReadBytes((int)(buffers.BaseStream.Length - buffers.BaseStream.Position + ConstLenght));
127                 this._LBuff.AddRange(_buff);
128             }
129             #endregion
130         }
131         catch (Exception ex) { Console.WriteLine(ex); }
132         finally
133         {
134             if (buffers != null) { buffers.Dispose(); }
135             buffers.Close();
136             if (buffers != null) { buffers.Dispose(); }
137             ms.Close();
138             if (ms != null) { ms.Dispose(); }
139         }
140         return list;
141     }
142 }