效劳器长连接socket效劳搭建.pdfVIP

效劳器基于BIO成立Socket效劳 1 多线程阻塞等待，成立Socket效劳. 基于 BIO IO模型成立多线程阻塞等待客户端的连接操作。等待的连接线程独立； 连接成功：成立新的线程，处置发送和接收消息等操作； 连接失败：报io异样，连接线程不中断，继续等待新的客户端连接； 无连接：线程阻塞等待； 2 生产消费者模式，等待接收来自客户端 Socket消 一个socket通信成立起来以后，开启新的线程处置发送，接收消息，在那个新的线程里面，成立一个并发的 队列，效劳器生产数据，客户端消费数据，没有数据发送的时候，线程队列维持阻塞等待状态。 3 支持心跳机制，让客户端维持长连接不断线 效劳器设置了读超机会制，客户端若是在指定的时刻内没有向效劳器发送数据进行通信，效劳器认定客户端是离 线状态，主动断开等待线程，终止对某一个客户端的socket通信 心跳检测步骤： 1 客户端每隔一个时刻距离发生一个探测包给效劳器 2 客户端发包时启动一个超时按时器 3 效劳器端接收到检测包，应该回应一个包 3 若是客户机收到效劳器的应答包，那么说明效劳器正常，删除超时按时器 4 若是客户端的超时按时器超时，仍然没有收到应答包，那么说明效劳器挂了 很多人会用boolean socketFlag = () ()来判定就好了，但事实上这些方式都是访问socket 在内存驻留的 状态，当socket 和效劳器端成立链接后，即便socket 链接断掉了，挪用上面的方式返回的仍然是链接时的 状态，而不是socket 的实时链接状态，因此如此心跳用那个不靠谱 4 Socket 效劳载入Spring Bean 容器中，结合业务组件进行业务操作 通过注解的方式@Componment 的方式把 socket 接口回调类注入 spring 容器中，如此就能够够很方面的在 spring 操纵器中处置关于socket效劳的各项回调接口，完成相关业务操作 5 成立Socket状态连接表和消息记录表 通过tbl_sockets 监控sockets 的连接状态 通过tbl_sockets_messages 记录sockets 通信记录信息 表结构 -- -- Table structure for tbl_sockets(socket 连接表) -- DROP TABLE IF EXISTS `tbl_sockets`; CREATE TABLE `tbl_sockets` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 自增加id, `socket_ip` varchar(255) NOT NULL COMMENT 客户端ip地址, `socket_online_time` datetime NOT NULL COMMENT 客户端上线时刻, `socket_offline_time` datetime DEFAULT NULL COMMENT 客户端下线时刻, `socket_state` int(1) NOT NULL COMMENT socket连接状态-1:上线 0:离线, `userid` int(11) DEFAULT NULL COMMENT socket-用户id-外键, FOREIGN KEY (userid) REFERENCES tbl_user(id), PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8; -- 添加唯一性约束条件 ALTER TABLE `tbl_sockets` ADD unique(`socket_ip`); -- -- Table structure for tbl_sockets_messages(socket消息记录表) -- DROP TABLE IF EXISTS `tbl_sockets_messages`; CREATE TABLE `tbl_sockets_messages` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 自增加id, `socket_data` varchar(255) NOT NULL COMMENT 消息文本, `socket_time` datetime NOT NULL COMMENT 消息接收： 0,发送时刻：1, `socket_type` int(1) N