java - Netty 中的业务逻辑？

Question

我正在开发一个基于 Netty libraby 的服务器，但我遇到了如何根据业务逻辑构建应用程序的问题。

当前我在最后一个处理程序中拥有业务逻辑，这就是我访问数据库的地方。我无法理解的是访问数据库的延迟(阻塞代码)。是否建议在处理程序中执行此操作，或者是否有其他选择？代码如下:

public void channelRead(ChannelHandlerContext ctx, Object msg)
        throws Exception {
    super.channelRead(ctx, msg);
    Msg message = (Msg)msg;
    switch(message.messageType){
        case MType.SIGN_UP:
            userReg.signUp(message.user);// blocking database access
            break;
    }
}

Answer 1

您应该在 DefaultEventExecutorGroup 或添加处理程序时添加的自定义线程池中执行阻塞调用

pipeline.addLast(new DefaultEventExecutorGroup(50),"BUSSINESS_LOGIC_HANDLER", new BHandler());

ctx.executor().execute(new Runnable() {
@Override
public void run() {
    //Blocking call
}});