Netty中如何实现TimeServer-古蔺大橙子建站
RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
Netty中如何实现TimeServer

这篇文章主要介绍Netty中如何实现TimeServer,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!

创新互联建站是一家专业提供六合企业网站建设,专注与成都网站设计、成都网站制作H5响应式网站、小程序制作等业务。10年已为六合众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。

No1、什么是Netty

Netty是业界最流行的NIO框架之一,它的性能、健壮性、应用范围等都在同类框架中首屈一指。例如RPC框架dubbo、Hadoop的RPC框架Avro就使用Netty作为底层的通信框架。

No2、JDK中的I/O的缺点

相信大家学过Socket编程的朋友们都看到过如下的代码:

Netty中如何实现TimeServer

处理逻辑图如下所示

Netty中如何实现TimeServer

这是一个最简单的Socket程序,服务端接收到request后立即创建一个线程来处理这个request。看起来没什么毛病,但是如果并发量稍稍大一点的话,server端创建线程、销毁线程会特别消耗性能。有朋友一定会说,既然系统的瓶颈在线程的创建和销毁上,用线程池不久可以了吗?将系统创建的线程数控制在一定范围内,不会因为并发量而耗尽系统线程。确实是这样,但由于底层的通信依然采用同步阻塞模型,无法从根本上解决问题。

No3、为什么选择Netty

不选择JAVA原生NIO的原因如下:

  • NIO库和API复杂

  • 代码复杂

  • 入门困难,需要大量JAVA知识储备

  • JDK NIO的Bug

  • 。。。

选择Netty的原因如下:

  • API简单,开发门槛低

  • 功能强大,预置了多种编码解码功能

  • 性能高,成熟稳定

  • 社区活跃度高

  • 修复了NIO中已发现的所有Bug

  • 。。。

No4、Netty入门小Demo——TimeServer

好,下面我们就来写一个最简单的基于Netty的网络小程序,程序功能是client链接到server,server给client返回当前的时间

Step1、工程搭建

创建一个maven工程,引入相关的依赖

Netty中如何实现TimeServer

Step2、编写服务端——TimeServer

Netty中如何实现TimeServer

  1. 创建两个NioEventLoopGroup实例,NioEventLiipGroup是一个线程组,它包含了一组NIO线程。创建两个的原因是一个用于服务端接收客户端的连接,另一个用于Sockerchannel的读写。

  2. 创建ServerBootstrap,它是Netty启动服务的启动类,将EventLoop Group传入ServerBootstrap中,最后绑定I/O事件的处理类ChildChannelHandler。

  3. bind端口,调用同步阻塞方法sync等待绑定操作完成,并返回一个ChannelFuture对象,它的功能类似于java.util.concurrent.Future,主要用于异步回调。

  4. 等待服务器端链路关闭后main方法结束

I/O事件处理类ChildChannelHandler.java的实现

Netty中如何实现TimeServer

  1. 将msg转化为ByteBuf对象,此对象相当于byte[],不过比byte[]封装了更多操作。

  2. ByteBuf的readableBytes()方法可以获取缓冲区中可读到的字节数,并将它写入byte[]中

  3. 创建响应,并写给客户端。

这就是server端的代码,很简单吧

Step3、编写客户端——TimeClient

Netty中如何实现TimeServer

  1. 创建EventLoopGroup实例

  2. 创建Bootstrap实例,与TimeServer不同的是,此处Channel需要设置为NioSockerChannel

  3. 调用connect发起异步连接,然后调用sync等待连接成功

  4. 关闭连接,释放资源

TimeClientHandler.java的实现

Netty中如何实现TimeServer

  1. 当client与server的TCP连接成功后,Netty的NIO线程调用channelActive方法,向服务器发送请求

  2. 将byte[]数据封装到ByteBuf中,并发送请求

  3. 将响应msg转化为ByteBuf对象,写入byte[]中

  4. 打印响应数据

以上是“Netty中如何实现TimeServer”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注创新互联行业资讯频道!


当前文章:Netty中如何实现TimeServer
网页地址:http://scgulin.cn/article/gsghce.html