Netty是什么

Netty，英文全称为Netty Project，是一个开源的异步事件驱动的网络应用框架，用于快速开发高性能、高可靠性的网络服务器和客户端程序。Netty是由JBoss提供的一个NIO客户端/服务器框架，用于快速开发可维护的高性能协议服务器和客户端。

官网：https://netty.io/

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地址：

https://github.com/wangsbJava/netty-springboot-demo/