提交 7ce8321e 编写于 作者: 武汉红喜's avatar 武汉红喜

Netty线程模型

上级 d7adbeda
......@@ -408,9 +408,7 @@ header的decode细节在`RocketMQSerializable`里
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline()
// DefaultEventExecutorGroup
// defaultEventExecutorGroup用于执行pipeline里的channelHandlers
// 如果没有设置defaultEventExecutorGroup,则用workerGroup执行
// DefaultEventExecutorGroup: optionalGroup (相当于netty提供的业务线程池)
.addLast(defaultEventExecutorGroup, HANDSHAKE_HANDLER_NAME,
new HandshakeHandler(TlsSystemConfig.tlsMode))
.addLast(defaultEventExecutorGroup,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册