diff --git a/src/main/java/org/redkale/net/ProtocolCodec.java b/src/main/java/org/redkale/net/ProtocolCodec.java index f88a97987..278f46b19 100644 --- a/src/main/java/org/redkale/net/ProtocolCodec.java +++ b/src/main/java/org/redkale/net/ProtocolCodec.java @@ -114,9 +114,7 @@ class ProtocolCodec implements CompletionHandler { return; } try { - // channel.readRegisterInIOThread(this); - // 服务端接收到一个SocketConnection后调用,因此不存在并发readRegister - channel.readRegister(this); + channel.readRegisterInIOThread(this); } catch (Exception te) { channel.dispose(); // response.init(channel); 在调用之前异常 if (context.logger.isLoggable(Level.FINEST)) {