在 SpringBoot 中使用 Netty 的思路，偷梁换柱之计

[wellR]

项目中准备用 netty 做些定制化的功能，自然而然用上了 SpringBoot 这套，招不在老管用就好。思路就是不启动 tomcat ，在主线程启动 netty 。

	public static void main(String[] args) {
        StopWatch stopWatch = new StopWatch();
        stopWatch.start("start app...");
        ConfigurableApplicationContext context = SpringApplication.run(NettyServer.class, args);
        //get bean
        SecondHandler handler = context.getBean(SecondHandler.class);
        int port = context.getEnvironment().getProperty("server.port", Integer.class, 9000);
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup(16);
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .localAddress(new InetSocketAddress(port))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) {
                            ch.pipeline()
                                    .addLast("codec", new HttpServerCodec())
                                    .addLast("compressor", new HttpContentCompressor())
                                    .addLast("aggregator", new HttpObjectAggregator(65536))
                                    .addLast("handler", handler);
                        }
                    })
                    .childOption(ChannelOption.SO_KEEPALIVE, true);
            ChannelFuture f = b.bind().sync();
            stopWatch.stop();
            log.info("Netty Server started ，Listening on {}, info={}", port, stopWatch.prettyPrint());
            f.channel().closeFuture().sync();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }

项目链接

[cookii]

直接用 webflux 。除非是非 http 协议

[crazyweeds]

太复杂，直接：
CountDownLatch countdown = new CountDownLatch(1);
countdown.await();
然后 netty 该怎么写就怎么写。

[justRua]

有现成的 grpc-spring-boot-starter ，协议是 grpc ，实现是 netty

[byte10]

我用的是 springboot + vert.x ，我也推荐你使用 vert.x ，当然，最好直接用虚拟线程 + vert.x ，不过我好像测试出现 bug 。你尝试一下

[wellR]

@byte10 java 中现在能用虚拟线程了吗

[byte10]

@wellR java 19 就有预览版，现在 java20 版本也出来了。预计明年应该可以出生产 版吧。前期我推荐使用 线程池 来解决代码同步编程的问题（异步转同步 ），后续直接使用虚拟线程代替线程池，完美接管。可以先了解下 虚拟线程的目前存在的问题吧

[wellR]

@byte10 生产上还是 java8 ，不敢上太高版本的

[wellR]

@byte10 我的解决思路是，缓存 ChannelHandlerContext ，等待回调或者 mq 消息，再取出对应的 ChannelHandlerContext 执行 writeAndFlush 响应客户端

[cslive]

将 tomcat 依赖改成 netty 也可以啊，又不非得用 tomcat 启动

[tramm]

啊, 我一直以为不加 web 依赖, 就没有 Tomcat 了...