1 usingSystem;2 usingSystem.Collections.Generic;3 usingSystem.IO;4 usingSystem.Text;5

6 //消息解析器

7 public classMarshalEndian8 {9 //用于存储剩余未解析的字节数

10 private List _LBuff = new List(2);11 //默认是utf8的编码格式

12 private UTF8Encoding utf8 = newUTF8Encoding();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 voidDispose()22 {23 this.Dispose(true);24 GC.SuppressFinalize(this);25 }26

27 protected virtual void Dispose(boolflag1)28 {29 if(flag1)30 {31 IDisposable disposable2 = this.utf8 asIDisposable;32 if (disposable2 != null) { disposable2.Dispose(); }33 IDisposable disposable = this._LBuff asIDisposable;34 if (disposable != null) { disposable.Dispose(); }35 }36 }37

38 public byte[] Encode(TSocketMessage msg)39 {40 MemoryStream ms = newMemoryStream();41 BinaryWriter bw = new BinaryWriter(ms, newUTF8Encoding());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 returnms.ToArray();64 }65

66 public List GetDcAppMess(byte[] buff, intlen)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(2);79 }80

81 List list = new List();82 MemoryStream ms = newMemoryStream(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)

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(newTSocketMessage(msgID, _buff));118 if ((buffers.BaseStream.Length - buffers.BaseStream.Position) > 0)119 {120 gotoLabel_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 returnlist;141 }142 }