Netty服务端ChannelInitializer处理器中JPA repository.save方法失效问题

1 异常根因 #

你遇到的NullPointerException以及无错误日志、进程假死的现象由两个核心错误共同导致：

• 初始化NettyServerHandler时未注入TestRepo实例：你在ServerService的ChannelInitializer中直接调用构造创建NettyServerHandler，没有将Spring容器托管的testRepo传入，导致handler中的testrepo属性为null，调用testrepo.save()时触发第一次空指针。
• NettyServerHandler未初始化日志对象：代码中直接使用log.info输出日志，但没有声明初始化Logger实例，导致第一次空指针进入catch块后，调用log.info触发第二次未捕获的空指针，因此看不到异常日志，线程异常终止表现为阻塞状态。

另外还存在一个隐藏的流程错误：你将Netty服务启动的阻塞逻辑直接写在了ServerService的构造方法中，bootstrap.bind(port).sync().channel().closeFuture().sync()是阻塞方法，会直接卡住Spring Bean的初始化线程，导致后续容器初始化流程中断，可能引发JPA、数据源等组件未完成初始化的问题。

修复步骤 #

步骤1：调整Netty服务启动逻辑，避免阻塞Spring初始化 #

将Netty启动逻辑从构造方法迁移到@PostConstruct注解的方法中，且新开线程运行，不要阻塞主线程：

@Service
public class ServerService {
    private static final Logger logger = LoggerFactory.getLogger(ServerService.class);
    private final TestRepo testRepo;
    @Value("${hs.host}") 
    private String host;
    @Value("${hs.port}") 
    private int port;

    @Autowired
    public ServerService(TestRepo testRepo) {
        this.testRepo = testRepo;
    }

    @PostConstruct
    public void startNettyServer() {
        // 新开线程启动Netty，不阻塞Spring初始化
        new Thread(() -> {
            EventLoopGroup booGroup = new NioEventLoopGroup();
            EventLoopGroup workerGroup = new NioEventLoopGroup();
            try {
                ServerBootstrap bootstrap = new ServerBootstrap()
                        .group(booGroup, workerGroup)
                        .channel(NioServerSocketChannel.class)
                        .handler(new LoggingHandler(LogLevel.INFO))
                        .option(ChannelOption.SO_BACKLOG, 128) 
                        .childOption(ChannelOption.SO_KEEPALIVE, true)
                        .localAddress(host, port)
                        .childHandler(new ChannelInitializer<SocketChannel>() {
                            @Override
                            protected void initChannel(SocketChannel ch) throws Exception {
                                ChannelPipeline pipeline = ch.pipeline();
                                // 传入Spring托管的testRepo实例
                                pipeline.addLast(new NettyServerHandler(testRepo));
                            }
                        });
                logger.info("Netty服务启动，端口：{}", port);
                bootstrap.bind(port).sync().channel().closeFuture().sync();
            } catch (InterruptedException e) {
                logger.error("Netty服务启动异常", e);
                Thread.currentThread().interrupt();
            } finally {
                logger.info("Netty服务关闭，端口：{}", port);
                booGroup.shutdownGracefully();
                workerGroup.shutdownGracefully();
            }
        }).start();
    }
}

步骤2：修复NettyServerHandler的初始化问题 #

补充日志对象声明，新增异常处理逻辑避免线程异常终止：

public class NettyServerHandler extends ChannelInboundHandlerAdapter {
    // 补充日志初始化
    private static final Logger log = LoggerFactory.getLogger(NettyServerHandler.class);
    private final TestRepo testrepo;

    public NettyServerHandler(TestRepo testrepo) {
        this.testrepo = testrepo;
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        TestModel trans = new TestModel();
        // id是自增主键，不需要手动设置，避免主键冲突
        trans.setTestf("d11");
        trans.setTransactionType("test");
        log.info("before save");
        try {
            testrepo.save(trans);
        } catch (Exception e) {
            log.error("数据保存失败", e);
        }
        log.info("after save");
        // 释放Netty接收的ByteBuf对象，避免内存泄漏
        ReferenceCountUtil.release(msg);
    }

    // 补充全局异常处理
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        log.error("通道处理异常", cause);
        ctx.close();
    }
}

内容的提问来源于stack exchange，提问作者Rahmatullah Darwish