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

netty

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