开篇都是吹牛逼哈。。。
我原本打算使用dotnetty来解决传输问题,但是试了下没有成功,也没有找到相关问题解决方法,导出源码,好大啊。暂时不想研究,而且是.Net Core的。最后没有办法,就自己封装了。我就不上代码了,已经传到GIT上面了,和其它项目。
我主要介绍过程原理,;
1.ISocketChannel接口,继承实现通信,继承类封装Socket.
2.外层封装ServerSocketChannel,仿造dotnetty服务端,设置socket参数,接收线程数,设置数据的解析类及打包的类以及数据接收类。
具体ServerSocketChannel:
里面定义了一个ServerSocketTask,启动接收连接,采用SocketAsyncEventArgs 接收连接,用一个缓冲池保持对象,每接收一个就再次接收一个;
接收连接后,放入到一个集合中,然后由启动的多个接收线程抽取数据,监测是否有数据读取,有就读取,没有就休眠一下,接收采用缓冲buffer,主要是解决多包数据问题,接收完整一包后还是要合并一个byte[],然后再次传入给设置的接收类中。
3.SocketChannel是解决客户端,客户端直接采用SocketAsyncEventArgs接收,不用再使用其它方法,毕竟客户端再同一台机器不可能成百上千,直接由底层线程池接收就可以了。c#的线程池有自己的算法,会动态维护。不用再麻烦处理了。当然我实现了手动控制线程,启动多个线程去接收数据。
项目地址:https://github.com/jinyuttt/StremCloud.git
其中解决方案下的NetHighSocket项目就是通信实现,但是还需要项目SrvNetSocket,通信接口库,为啥会有这个库,我后面博文会简单说的。
---------------------
作者:jason成都
来源:CSDN
原文:https://blog.csdn.net/jinyuttt/article/details/83005994?utm_source=copy
版权声明:本文为博主原创文章,转载请附上博文链接!