MemoryStreamHelp.cs 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267
  1. using System;
  2. using System.IO;
  3. using System.Text;
  4. namespace WS
  5. {
  6. ///<summary>流数据操作扩展</summary>
  7. public static class MemoryStreamHelp
  8. {
  9. public static int GetStringCount(this MemoryStream ms)
  10. {
  11. return (int)(ms.Length - ms.Position);
  12. }
  13. #region Short
  14. /// <summary>
  15. /// 从流中读取一个short数据
  16. /// </summary>
  17. /// <returns></returns>
  18. public static short ReadShort(this MemoryStream ms)
  19. {
  20. byte[] arr = new byte[2];
  21. ms.Read(arr, 0, 2);
  22. return BitConverter.ToInt16(arr, 0);
  23. }
  24. /// <summary>
  25. /// 把一个short数据写入流
  26. /// </summary>
  27. /// <param name="value"></param>
  28. public static void WriteShort(this MemoryStream ms, short value)
  29. {
  30. byte[] arr = BitConverter.GetBytes(value);
  31. ms.Write(arr, 0, arr.Length);
  32. }
  33. #endregion
  34. #region UShort
  35. /// <summary>
  36. /// 从流中读取一个ushort数据
  37. /// </summary>
  38. /// <returns></returns>
  39. public static ushort ReadUShort(this MemoryStream ms)
  40. {
  41. byte[] arr = new byte[2];
  42. ms.Read(arr, 0, 2);
  43. return BitConverter.ToUInt16(arr, 0);
  44. }
  45. /// <summary>
  46. /// 把一个ushort数据写入流
  47. /// </summary>
  48. /// <param name="value"></param>
  49. public static void WriteUShort(this MemoryStream ms, ushort value)
  50. {
  51. byte[] arr = BitConverter.GetBytes(value);
  52. ms.Write(arr, 0, arr.Length);
  53. }
  54. #endregion
  55. #region Int
  56. /// <summary>
  57. /// 从流中读取一个int数据
  58. /// </summary>
  59. /// <returns></returns>
  60. public static int ReadInt(this MemoryStream ms)
  61. {
  62. byte[] arr = new byte[4];
  63. ms.Read(arr, 0, 4);
  64. return BitConverter.ToInt32(arr, 0);
  65. }
  66. /// <summary>
  67. /// 把一个int数据写入流
  68. /// </summary>
  69. /// <param name="value"></param>
  70. public static void WriteInt(this MemoryStream ms, int value)
  71. {
  72. byte[] arr = BitConverter.GetBytes(value);
  73. ms.Write(arr, 0, arr.Length);
  74. }
  75. #endregion
  76. #region UInt
  77. /// <summary>
  78. /// 从流中读取一个uint数据
  79. /// </summary>
  80. /// <returns></returns>
  81. public static uint ReadUInt(this MemoryStream ms)
  82. {
  83. byte[] arr = new byte[4];
  84. ms.Read(arr, 0, 4);
  85. return BitConverter.ToUInt32(arr, 0);
  86. }
  87. /// <summary>
  88. /// 把一个uint数据写入流
  89. /// </summary>
  90. /// <param name="value"></param>
  91. public static void WriteUInt(this MemoryStream ms, uint value)
  92. {
  93. byte[] arr = BitConverter.GetBytes(value);
  94. ms.Write(arr, 0, arr.Length);
  95. }
  96. #endregion
  97. #region Long
  98. /// <summary>
  99. /// 从流中读取一个long数据
  100. /// </summary>
  101. /// <returns></returns>
  102. public static long ReadLong(this MemoryStream ms)
  103. {
  104. byte[] arr = new byte[8];
  105. ms.Read(arr, 0, 8);
  106. return BitConverter.ToInt64(arr, 0);
  107. }
  108. /// <summary>
  109. /// 把一个long数据写入流
  110. /// </summary>
  111. /// <param name="value"></param>
  112. public static void WriteLong(this MemoryStream ms, long value)
  113. {
  114. byte[] arr = BitConverter.GetBytes(value);
  115. ms.Write(arr, 0, arr.Length);
  116. }
  117. #endregion
  118. #region ULong
  119. /// <summary>
  120. /// 从流中读取一个ulong数据
  121. /// </summary>
  122. /// <returns></returns>
  123. public static ulong ReadULong(this MemoryStream ms)
  124. {
  125. byte[] arr = new byte[8];
  126. ms.Read(arr, 0, 8);
  127. return BitConverter.ToUInt64(arr, 0);
  128. }
  129. /// <summary>
  130. /// 把一个ulong数据写入流
  131. /// </summary>
  132. /// <param name="value"></param>
  133. public static void WriteULong(this MemoryStream ms, ulong value)
  134. {
  135. byte[] arr = BitConverter.GetBytes(value);
  136. ms.Write(arr, 0, arr.Length);
  137. }
  138. #endregion
  139. #region Float
  140. /// <summary>
  141. /// 从流中读取一个float数据
  142. /// </summary>
  143. /// <returns></returns>
  144. public static float ReadFloat(this MemoryStream ms)
  145. {
  146. byte[] arr = new byte[4];
  147. ms.Read(arr, 0, 4);
  148. return BitConverter.ToSingle(arr, 0);
  149. }
  150. /// <summary>
  151. /// 把一个float数据写入流
  152. /// </summary>
  153. /// <param name="value"></param>
  154. public static void WriteFloat(this MemoryStream ms, float value)
  155. {
  156. byte[] arr = BitConverter.GetBytes(value);
  157. ms.Write(arr, 0, arr.Length);
  158. }
  159. #endregion
  160. #region Double
  161. /// <summary>
  162. /// 从流中读取一个double数据
  163. /// </summary>
  164. /// <returns></returns>
  165. public static double ReadDouble(this MemoryStream ms)
  166. {
  167. byte[] arr = new byte[8];
  168. ms.Read(arr, 0, 8);
  169. return BitConverter.ToDouble(arr, 0);
  170. }
  171. /// <summary>
  172. /// 把一个double数据写入流
  173. /// </summary>
  174. /// <param name="value"></param>
  175. public static void WriteDouble(this MemoryStream ms, double value)
  176. {
  177. byte[] arr = BitConverter.GetBytes(value);
  178. ms.Write(arr, 0, arr.Length);
  179. }
  180. #endregion
  181. #region Bool
  182. /// <summary>
  183. /// 从流中读取一个bool数据
  184. /// </summary>
  185. /// <returns></returns>
  186. public static bool ReadBool(this MemoryStream ms)
  187. {
  188. return ms.ReadByte() == 1;
  189. }
  190. /// <summary>
  191. /// 把一个bool数据写入流
  192. /// </summary>
  193. /// <param name="value"></param>
  194. public static void WriteBool(this MemoryStream ms, bool value)
  195. {
  196. ms.WriteByte((byte)(value == true ? 1 : 0));
  197. }
  198. #endregion
  199. #region String_1
  200. /// <summary>
  201. /// 从流中读取一个sting数组
  202. /// </summary>
  203. /// <returns></returns>
  204. public static string ReadUTF8String(this MemoryStream ms)
  205. {
  206. ushort len = ms.ReadUShort();
  207. byte[] arr = new byte[len];
  208. ms.Read(arr, 0, len);
  209. return Encoding.UTF8.GetString(arr);
  210. }
  211. /// <summary>
  212. /// 把一个string数据写入流
  213. /// </summary>
  214. /// <param name="str"></param>
  215. public static void WriteUTF8String(this MemoryStream ms, string str)
  216. {
  217. byte[] arr = Encoding.UTF8.GetBytes(str);
  218. if (arr.Length > 65535)
  219. {
  220. throw new InvalidCastException("字符串超出范围");
  221. }
  222. ms.WriteUShort((ushort)arr.Length);
  223. ms.Write(arr, 0, arr.Length);
  224. }
  225. #endregion
  226. #region String_2
  227. ///<summary>写入String</summary>
  228. public static void WriteString(this MemoryStream ms, string str)
  229. {
  230. byte[] arr = Encoding.UTF8.GetBytes(str);
  231. ms.Write(arr, 0, arr.Length);
  232. }
  233. ///<summary>读取String</summary>
  234. public static string ReadString(this MemoryStream ms, int len)
  235. {
  236. byte[] arr = new byte[len];
  237. ms.Read(arr, 0, len);
  238. return Encoding.UTF8.GetString(arr);
  239. }
  240. #endregion
  241. }
  242. }