一种基于nio的简易高效的socket通信框架

摘要

本发明公开一种基于nio的简易高效的socket通信框架，分为TCP连接建立部分和IO读写处理部分。客户端或者服务端连接建立之后，将建立起的会话session交给IO读写处理部分，将客户端和服务端的连接建立部分抽象出来，将连接建立和IO读写处理分离。使用基于事件的消息通知机制，简化了用户编程接口，使得用户在编写网络程序时无需考虑复杂的底层实现机制，专注在自己的业务逻辑上面；基于可配置的多线程IO读写机制，高效的处理IO读写事件，提高socket读写性能，同时在业务压力降低时能释放不用的线程资源；考虑各种常见问题处理的session的设计，有效的处理超时，TCP消息拆包、粘包问题。

主权项

一种基于nio的简易高效的socket通信框架，其特征包括TCP连接建立部分和IO读写处理部分，将连接建立和IO读写分离；其中：连接建立部分包含客户端连接建立和服务端连接建立，服务端部分启动时开启监听端口，等待客户端的连接；连接建立后，将建立的socket以及建立时间等信息封装为session，交给IO读写处理部分进行读写处理；IO读写处理部分主要用来处理IO事件，采用多线程，线程数目可以配置，并且在没有待处理的session时，线程会自动结束，释放系统资源；所述连接建立部分，其中session用来保存从TCP连接建立到连接关闭之间所用到的和此连接相关的所有状态信息，包含以下部分：①和此session关联的客户端和服务端连接信息，客户端地址、服务端地址；②连接时间信息，包括连接建立时间，上次读、写事件的时间；记录时间信息主要用来判断当前session是否处于活动状态，如果不活动的话生成Idle事件；idle事件有三类：读idle、写idle、读写同时idle；③发送消息队列，记录待发送的所有消息，在IO繁忙时可以作为数据缓存；④接收消息队列，存储接收的所有消息，由于TCP是基于流的协议设计，在发送或者接受消息时存在拆包、粘包的现象，消息队列可以缓存数据，等数据接收完成时再进行处理；⑤统计信息，包括读取、发送的所有数据大小，产生的连续的idle事件数目。