集成JPA Repository的Netty Socket ChannelInitializer无法向MySQL保存数据

问题原因 #

1. 事务缺失：Spring Data JPA的所有写操作默认依赖事务支持，未配置事务的情况下，save操作不会将数据同步到数据库，甚至会抛出TransactionRequiredException
2. 异常被隐藏：
   • 你的代码仅捕获Exception类型，若抛出Error等Throwable子类不会进入catch逻辑
   • 异常日志用log.info输出，若项目日志级别配置为WARN/ERROR，info级日志会被直接过滤，无法看到报错信息
   • 向上抛出的异常进入exceptionCaught方法后，同样用info级别输出，进一步导致异常无法被观测
3. Netty线程模型误用：数据库操作是阻塞操作，直接在Netty IO线程（NioEventLoop）中执行会导致线程挂起，后续日志和业务逻辑无法正常执行
4. 实体类配置错误：若TestModel未配置主键生成策略，未添加@Entity/@Id注解，save操作会直接失败

解决方案 #

第一步：排查隐藏异常 #

修改异常捕获逻辑，确保所有异常都能被打印：

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    TestModel trans = new TestModel();
    trans.setTestf("d222222");
    System.out.println("before save" + testrepo);
    try {
        testrepo.save(trans);
        System.out.println("after save ");
    } catch (Throwable e) { // 改为捕获所有Throwable类型
        e.printStackTrace();
        log.error("保存数据失败", e); // 用error级别输出，第二个参数传异常对象打印完整栈
    }
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    cause.printStackTrace();
    log.error("Channel 异常", cause); // 改为error级别输出
}

修改后重新运行即可看到具体报错信息，90%以上概率会输出TransactionRequiredException。

第二步：添加事务管理 #

不要直接在ChannelHandler中操作Repository，将数据库逻辑封装到Service层，添加事务注解：

@Service
public class TestService {
    @Autowired
    private TestRepo testRepo;

    @Transactional(rollbackFor = Exception.class)
    public void saveTestData() {
        TestModel trans = new TestModel();
        trans.setTestf("d222222");
        testRepo.saveAndFlush(trans); // 用saveAndFlush可立刻将数据同步到数据库，无需等事务提交
    }
}

将TestService注入到ChannelHandler中调用即可。

第三步：调整Netty线程模型 #

数据库阻塞操作不能在IO线程执行，需要提交到独立的业务线程池：

// 全局业务线程池，可根据业务规模调整参数
private static final ExecutorService BUSINESS_POOL = new ThreadPoolExecutor(
        8, 32, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(2000)
);

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    BUSINESS_POOL.submit(() -> {
        try {
            testService.saveTestData();
            System.out.println("after save");
        } catch (Throwable e) {
            e.printStackTrace();
            log.error("保存数据失败", e);
        }
    });
}

第四步：检查实体类配置 #

确保TestModel配置正确：

@Entity
public class TestModel {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY) // 适配MySQL自增主键
    private Long id;
    private String testf;
    // 省略getter、setter
}

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