在 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();
        }
    }

项目链接

[liuhai233]

不是可以选 reactive 嘛，默认就是 netty 了吧

[wellR]

@liuhai233 哦 webflux 没在生产上用过，相对来说 netty 更好做定制化开发

[chendy]

不启动 tomcat 可以直接不要 tomcat ，留个啥东西不让 main 退出就行…

[wellR]

@chendy 是这样的，一直以来用 SpringBoot 搞 web 开发都形成思维定势了，这次是打开思路了，SpringBoot 还可以来做 webMvc 开发之外的东西

[wellR]

SpringBoot 用了这么久了，才知道 SpringApplication.run 返回了 ApplicationContext ，哈

[fzdwx]

以前我也写过一个类似的哈哈 https://github.com/fzdwx/sky

[lsk569937453]

不要加 springboot-web 的 starter,直接用 springboot 的 CommandLineRunner 里运行 netty 即可啊

[silentsky]

这么巧 今天我也在整这个

[zhiyu1998]

学到了，感谢分享

[dreamlike]

🤔你这样写其实没有把 server 的生命周期托管给 spring 看起来，

[wellR]

@dreamlike 是的，这是野路子

[niuroumian]

没必要折腾，https://armeria.dev/

[cnzjl]

用 Smartlifecycle ，不添加 web 依赖

[dreamlike]

等下 我看了你这个代码 其实就是搞了一个基于 netty 的 http 服务器，我建议直接换 vertx or quarkus 吧

[LeegoYih]

这样写不就好了？

SpringApplication application = new SpringApplication(NettyServer.class);
application.setApplicationContextFactory(ApplicationContextFactory.ofContextClass(AnnotationConfigApplicationContext.class));
application.run(args);

[LeegoYih]

new SpringApplicationBuilder(ChatServerApplication.class)
.web(WebApplicationType.NONE)
.run(args);

[WispZhan]

不理解，为什么不直接用 vert.x 之类的？

[wellR]

@dreamlike 是的，要做一个异步实时响应的服务。webflux 不好上手，请问 vertx 的使用体验如何，与 webflux 比怎么样

[wellR]

大体流程：
1 、客户端发送请求，参数中有业务数据、超时时间与回调接口；
2 、服务 A 收到请求，初步处理 task 再发 mq
3 、服务 B 消费 mq 进行一系列比较耗时的操作之后将处理结果发到 mq 广播消息
4 、服务 A 消费 mq 响应客户端
5 、若上述处理流程中超时了，则立即返回客户端，后台 task 跑完了会调客户端的回调

[dreamlike]

@wellR 我看这个需求很简单 也没有什么复杂的逻辑 直接 vertx 上吧 又轻又快 用好 eventbus ，开发速度应该是爆杀 webflux 的，开 n 个 vertical 跑满核心就行了

[imzhoukunqiang]

直接用 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 了...