码迷,mamicode.com
首页 > Web开发 > 详细

Netty实现服务端客户端长连接通讯及心跳检测

时间:2017-08-09 14:21:04      阅读:4021      评论:0      收藏:0      [点我收藏+]

标签:业务   服务   事件驱动   tty   一个   .com   win   线程   sock   

Minma是英文Minma Is Not Mina的简称

该框架采用Java NIO的核心技术,实现了基于事件驱动的多线程异步通信框架,支持常见的长连接(腾讯QQ)短连接(http通信)

对于开发人员而言,所有的底层技术都是透明的,开发人员仅仅只需要处理业务逻辑,把复杂的NIO简化成了类似Java Swing事件驱动式的编程。

长连接实例图

技术分享

具体通信流程
1.客户端连接服务端,服务端通过Selector接收到连接请求,将其socketChannel通道保存到通道集合,并触发客户端连接事件
2.客户端发送数据包请求到服务端,服务端将请求的SelectionKey压入“读消息生产者队列”,立即进入下一批Select
3.读消息消费者线程池中派遣一个就绪线程从客户端读取数据包DataPacket,并触发onReaded事件
4.开发人员在onReaded事件编写逻辑代码,并且决定读入的数据包的去向(返回给客户端,还是结束)
5.若在onReaded事件里,开发人员决定数据包要返回到客户端,则将该SelectionKey压入写消息生产者队列
6.写消息消费者线程池中派遣一个就绪线程,将数据包写到客户端,并触发onWrited事件
 
这就完成了长连接的一次通信,在所有的通信中都是异步的,没有出现阻塞的地方
 
若要深入了解,请先了解Java NIO技术
短连接实例
技术分享
和长连接相比,短连接唯一的区别就是,不需要保存客户端的通信通道
通信的节奏为:连接->读入->计算、逻辑->返回客户端->断开连接
 
1.客户端连接服务端,服务端通过Selector接收到连接请求
2.客户端发送数据包请求到服务端,服务端将请求的SelectionKey压入“读消息生产者队列”,立即进入下一批Select
3.读消息消费者线程池中派遣一个就绪线程从客户端读取数据包DataPacket,并触发onReaded事件
4.开发人员在onReaded事件编写逻辑代码,读入的数据包的去向始终是客户端
5.若在onReaded事件里,开发人员决定数据包要返回到客户端,则将该SelectionKey压入写消息生产者队列
6.写消息消费者线程池中派遣一个就绪线程,将数据包写到客户端,并触发onWrited事件
7.断开与客户端连接,触发onClientClose事件
 
 若要深入了解,请先了解Java NIO技术
下面分别写2个Demo来看看
首先是长连接Demo 
 首先在classpath创建一个配置文件minma.xml
技术分享

服务端代码

技术分享

技术分享

技术分享

 客户端代码

技术分享

技术分享

技术分享

 运行结果
服务端
技术分享

技术分享

下面看看短连接Demo
服务端代码
技术分享

技术分享

技术分享

客户端代码

技术分享

技术分享

技术分享

运行结果

服务端

技术分享

客户端

技术分享

可以看到框架用起来还是非常方便的,开发人员完全看不到底层的通信,仅仅只需要编写事件逻辑代码即可。

Netty实现服务端客户端长连接通讯及心跳检测

标签:业务   服务   事件驱动   tty   一个   .com   win   线程   sock   

原文地址:http://www.cnblogs.com/austinspark-jessylu/p/7324923.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!