一、基础概念
Netty是由JBOSS的工程师Norman Maurer和Trustin Lee共同开发的,是一个高性能、异步、事件驱动的网络编程框架。
相比于传统的BIO(Blocking IO)和NIO(New IO),Netty在调用方面更加简单,并且提供了更加高效的网络通信模式。同时Netty的高度定制性也让其在开发中得到了广泛的使用和推广。基于这些特点,Netty也成为了Java网络编程的最佳选择。
二、核心特性
下面简单介绍Netty的核心特性以及其对应的优势
1、事件驱动
Netty的IO线程是个单独的线程,这个线程维护了一个事件队列,所有的IO操作都来自事件队列,并且不会有任何的阻塞发生。
这种基于事件队列的高效方式极大地降低了线程频繁切换的开销,同时拥有了更加高效和用户友好的编程体验。
2、高度定制
Netty提供了丰富的插件和编程扩展点,可以满足各种不同的业务需求,同时非常灵活。
比如,Netty提供了ChannelHandler的基础架构,开发者可以基于此进行自己的业务扩展。另外,Netty也提供了基于HTTP、WebSocket等的协议解析和编码器,大大降低了业务开发者的工作量。
3、高性能
Netty在网络I/O上进行了大量的优化和调整,可以轻松实现单线程高并发。在高并发下,Netty的表现往往要优于NIO,因为它内部提供了更加高效的Reactor线程模型,同时也非常友好的支持了多线程。
三、应用实践
下面我们以Chat服务为例,看看如何在Netty中实现一个简单的IM通讯程序。
1、建立连接
Netty连接过程非常简单,只需要创建一个ServerBootstrap对象,并设置好一些必要的参数即可。
EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ChatServerInitializer()); ChannelFuture future = serverBootstrap.bind(PORT).sync(); future.channel().closeFuture().sync(); } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); }
2、业务处理
除了建立连接以外,我们还需要考虑业务处理。这里,我们可以基于Netty的ChannelHandler,来进行文本传输。
public class ChatServerHandler extends SimpleChannelInboundHandler{ private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); @Override public void channelRead0(ChannelHandlerContext ctx, String msg) { Channel channel = ctx.channel(); channelGroup.forEach(ch -> { if (channel != ch) { ch.writeAndFlush(channel.remoteAddress() + "发送的消息:" + msg + "\n"); } else { ch.writeAndFlush("自己发送的消息:" + msg + "\n"); } }); } @Override public void handlerAdded(ChannelHandlerContext ctx) { Channel channel = ctx.channel(); channelGroup.writeAndFlush("[服务器]-" + channel.remoteAddress() + "加入\n"); channelGroup.add(channel); } @Override public void handlerRemoved(ChannelHandlerContext ctx) { Channel channel = ctx.channel(); channelGroup.writeAndFlush("[服务器]-" + channel.remoteAddress() + "离开\n"); channelGroup.remove(channel); } }
四、总结
Netty是一个高效、高可靠、高性能的网络编程框架,旨在为开发者提供更加友好和轻松的编程体验。同时,Netty提供了非常丰富的编程扩展点,可以让每个开发者自由地根据其项目需求添加自己的扩展。在Java网络编程方面,Netty是不二之选。