探索高性能之路：Spring Boot Starter Netty 开源项目实战

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
 
public class NettyServer {
 
    private int port;
 
    public NettyServer(int port) {
        this.port = port;
    }
 
    public void start() throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     // 添加自定义的处理器(Handler)
                 }
             });
 
            ChannelFuture f = b.bind(port).sync();
            System.out.println("服务器启动，监听端口：" + port);
            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }
 
    public static void main(String[] args) throws Exception {
        int port;
        if (args.length > 0) {
            port = Integer.parseInt(args[0]);
        } else {
            port = 8080;
        }
        new NettyServer(port).start();
    }
}

这段代码展示了如何使用Netty框架创建一个简单的服务器。它设置了两个EventLoopGroup，一个用于接受连接，一个用于处理I/O操作。然后，它配置了ServerBootstrap，绑定了端口，并启动了服务器。代码中的注释解释了每一步的作用。这个例子是Netty服务器的基础，开发者可以在其中添加自定义的处理器来处理网络请求。