首页 > 学院 > 开发设计 > 正文

c# socket通信较完善方案

2019-11-17 03:01:54
字体：大 中 小
来源：转载
供稿：网友
c# socket通信较完善方案c#的socket通信应用.文件较多.附件为工程. core AbstractBytesWorker.cs 字节工作器(基类),用于用于同一不同功能的字节工作器 BinaryHand.cs 2进制处理器. ThDispose.cs 处理回收相关 crcentity ThPersonInfo.cs manager ThSocketManager.cs ThSocketManagerBusiness.cs 所有的业务 request RequestCode.cs 请求码 ThPRotocolReq.cs 请求逻辑 ThReqBytesWorker.cs 请求相关的字节工作器 response respLogic ThProtocolResp.cs 处理服务器响应的数据. ThProtocolRespDelegates.cs 所有的代理.用于通知客户的事件. ThProtocolRespEvents.cs 所有的事件.用于调用客户的. ThProtocolRespListeners.cs 所有的监听器,用于控制事件如何订阅 ThProtocolRespLogic.cs 处理服务器的数据 ThRespBytesWorker.cs 响应字节处理器 BinaryMessageHandler.cs 处理数据包粘结,包一次数据不足等情况. ResponseCode.cs 响应码 socket TAsyncTcpClient.cs tcpClient类,read异步. testcase =============================================================== 部分类代码: BinaryMessageHandlerC#代码收藏代码
  1. #pragmawarningdisable0219
  2. usingSystem;
  3. usingSystem.Collections.Generic;
  4. usingSystem.Linq;
  5. usingSystem.Text;
  6. usingSystem.IO;
  8. ///<summary>
  9. ///字节接收处理,粘包问题
  10. ///</summary>
  11. classBinaryMessageHandler:ThDispose
  12. {
  13. List<byte>bytesList=newList<byte>();
  15. privateTAsyncTcpClienttcpClient;
  17. publicBinaryMessageHandler(TAsyncTcpClienttcpClient)
  18. {
  19. this.tcpClient=tcpClient;
  20. }
  21. publicBinaryMessageHandler()
  22. {
  24. }
  26. overridepublicvoidSelfDispose()
  27. {
  28. tcpClient=null;
  29. bytesList=null;
  30. }
  32. ///<summary>
  33. ///累积字节.
  34. ///每次累积后,测试是否有完整的包.
  35. ///</summary>
  36. ///<paramname="buf"></param>
  37. publicvoidWrite(byte[]buf)
  38. {
  39. if(buf.Length>0)
  40. {
  41. //累积字节
  42. bytesList.AddRange(buf);
  43. byte[]bytes=bytesList.ToArray<byte>();
  44. MemoryStreamms=newMemoryStream(bytes);
  45. BinaryReaderreader=newBinaryReader(ms);
  47. intheader=reader.ReadUInt16();
  48. if(header==ThSocketManager.TH_HEADER)
  49. {
  50. intlen=reader.ReadUInt16();
  51. intremainLen=len-4;
  52. if((ms.Length-ms.Position)>=remainLen)
  53. {
  54. //有完整的数据包
  55. ms.Position=0;
  56. byte[]pack=reader.ReadBytes(len);
  58. ReadPackage(pack);
  59. //移除读完的数据包
  60. bytesList.RemoveRange(0,len);
  61. }
  62. }
  63. reader.Close();
  64. ms.Close();
  65. }
  67. }
  69. ///<summary>
  70. ///读取服务端响应信息.
  71. ///</summary>
  72. ///<paramname="bytes"><

上一篇：C#用天气预报的WebServices

下一篇：C# DataTable的詳細用法

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表
学习交流
更多

索泰发布一款GTX 1070 Mini迷你版本:小机

索泰发布一款GTX 1070 Mini迷你版本:小机箱大爱...
热门图片
更多
猜你喜欢的新闻
猜你喜欢的关注

新闻热点

荣耀总裁赵明乌镇演讲：荣耀首款5G手机V30下月发布
2019-10-23 09:17:05
搜狐张朝阳：回归媒体是搜狐重新崛起的关键
2019-10-21 09:20:02
华为轮值董事长郭平：虚拟技术创造现实价值
2019-10-21 09:00:12
滴滴英文服务上线两周年 用户已超200万
2019-09-26 08:57:12
华为推出全球至快AI训练集群Atlas900
2019-09-25 08:46:36
马斯克：特斯拉正组建中国技术团队
2019-09-25 08:15:43

疑难解答

图片精选

网友关注

关于本站 - 网上投稿 - 商务合作 - 隐私政策 - 网站地图
Copyright © 2008 - 2019 VEVB.COM. All Rights Reserved.武林网 版权所有