Netty，英文全称为Netty Project，是一个开源的异步事件驱动的网络应用框架，用于快速开发高性能、高可靠性的网络服务器和客户端程序。Netty是由JBoss提供的一个NIO客户端/服务器框架，用于快速开发可维护的高性能协议服务器和客户端。
Netty是什么：
Netty是一种Java NIO（New input/output）框架，也就是可以为一个高性能、高效、高可扩展性的网络应用程序提供基础架构。 Netty的架构特别灵活，包含了许多好用的解码器、编码器等组件，可以帮助我们快速进行网络编程的开发工作。
Netty学习路线：
1.了解Java NIO。
2.学习Netty框架的基本结构和原理。
3.学习Netty中的各种组件和设计模式。
4.掌握基本的Netty应用场景。
5.深入掌握Netty的性能优化。
6.学习Netty的高级应用，如RPC、Websocket等。
Netty的优点：
1.高性能：Netty基于NIO，利用了事件驱动模型和多路复用机制，实现了非常高效的I/O操作。
2.可扩展：Netty提供了很多的组件、接口以及设计模式，使得用户可以方便地扩展Netty的功能。
3.易于使用：Netty使用简单，通过一些很好的编解码器、ChannelHandler，可以快速构建出高性能的网络应用程序。
4.应用场景广泛：Netty可以应用于各种不同类型的网络应用，包括Web应用、游戏服务器等。
Netty的缺点：
1.需要深入理解Java NIO，不太友好。
2.不支持HTTP/2。
应用实例：
Netty的应用场景非常多，常见的应用场景有：
1.聊天服务器
2.游戏服务器
3.视频直播
4.高并发Web服务器
5.高性能代理服务器
6.安全、稳定的文件传输服务器
集成Springboot：
首先在pom.xml里添加以下依赖：
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.29.Final</version>
</dependency>接着创建一个NettyServerConfig类，如下：
@Configuration
public class NettyServerConfig {
@Value("${netty.server.host}")
private String host;
@Value("${netty.server.port}")
private int port;
/**
* Netty服务端ServerBootstrap配置
*/
@Bean(name = "nettyServerBootstrap")
public ServerBootstrap nettyServerBootstrap(){
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(nettyServerBossGroup(), nettyServerWorkerGroup())
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_BACKLOG, 1024)
.childOption(ChannelOption.SO_KEEPALIVE, true)
.childOption(ChannelOption.TCP_NODELAY, true)
.childHandler(new NettyServerChannelInitializer());
return serverBootstrap;
}
/**
* Netty服务端EventLoop Group，负责处理网络事件
*/
@Bean(name = "nettyServerBossGroup")
public NioEventLoopGroup nettyServerBossGroup() {
return new NioEventLoopGroup(1);
}
/**
* Netty服务端EventLoop Group，负责处理网络事件
*/
@Bean(name = "nettyServerWorkerGroup")
public NioEventLoopGroup nettyServerWorkerGroup() {
return new NioEventLoopGroup();
}
/**
* Netty服务端绑定的IP和端口号
*/
@Bean(name = "nettyServerSocketAddress")
public InetSocketAddress nettyServerSocketAddress() {
return new InetSocketAddress(host, port);
}
@PreDestroy
private void preDestroy() throws InterruptedException {
nettyServerBossGroup().shutdownGracefully().sync();
nettyServerWorkerGroup().shutdownGracefully().sync();
}
}然后创建一个NettyServerChannelInitializer类，如下：
public class NettyServerChannelInitializer extends ChannelInitializer<SocketChannel> {
@Autowired
private NettyServerHandler nettyServerHandler;
@Override
protected void initChannel(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(new DelimiterBasedFrameDecoder(1024 * 1024, Unpooled.wrappedBuffer(new byte[] {13, 10})));
pipeline.addLast(new StringDecoder(CharsetUtil.UTF_8));
pipeline.addLast(new DelimiterBasedFrameEncoder(Unpooled.wrappedBuffer(new byte[] {13, 10})));
pipeline.addLast(new StringEncoder(CharsetUtil.UTF_8));
pipeline.addLast(nettyServerHandler);
}
}最后创建一个NettyServerHandler类，如下：
@Component
@Sharable
public class NettyServerHandler extends SimpleChannelInboundHandler<String> {
/**
* 接收到客户端数据
*/
@Override
protected void channelRead0(ChannelHandlerContext ctx, String request) throws Exception {
System.out.println(request);
// do something...
}
/**
* 异常处理
*/
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
}完整代码可以参考以下Github地址：
