Question

netty message received 是多线程吗

Answer 1

一般情况下，netty 做server，接收请求并处理时，会在messageReceived（）阻塞，为了达到多线程处理，我使用了ExecutionHandler，但发现，
在NioWorker的read(SelectionKey k)方法中

if (readBytes > 0) {
bb.flip();

final ChannelBufferFactory bufferFactory =
channel.getConfig().getBufferFactory();
final ChannelBuffer buffer = bufferFactory.getBuffer(readBytes);
buffer.setBytes(0, bb);
buffer.writerIndex(readBytes);

recvBufferPool.release(bb);

// Update the predictor.
predictor.previousReceiveBufferSize(readBytes);

// Fire the event.
fireMessageReceived(channel, buffer);
} else {
recvBufferPool.release(bb);
}

if (ret < 0 || failure) {
k.cancel(); // Some JDK implementations run into an infinite loop without this.
close(channel, succeededFuture(channel));
return false;
}