客户端 Client

客户端启动入口一般从 Bootstrap.connect 开始。和服务端 ServerBootstrap 不同，客户端只有一个 EventLoopGroup这个 group 同时负责客户端 Channel 的注册、连接、读写等 I/O 事件；服务端才有 parent/boss 和 child/worker 的分工。

常见痛点：很多同学在阅读官方文档时只看到 “Bootstrap.connect”。却不知道背后到底发生了哪些步骤，导致调试连接失败时找不到切入口。

// 初始化线程组
EventLoopGroup group = new MultiThreadIoEventLoopGroup);try {
Bootstrap b = new Bootstrap;// 设置处理线程组
b.group
// 设置 Channel 类型
.channel
// 设置 ChannelOption
.option
// 初始化客户端 Channel 的 Pipeline
.handler {
@Override
public void initChannel throws Exception {
ChannelPipeline p = ch.pipeline;// ，…可以在这里添加编解码、业务处理器…，p.addLast);}
})，// 连接服务端
ChannelFuture f = b.connect.sync;// 等待直到关闭
f.channel.closeFuture.sync;} finally {
// 优雅关闭
// …}

整体流程

客户端连接主线：

Bootstrap.connect
-> doResolveAndConnect
-> initAndRegister
-> 创建 Channel
-> Bootstrap.init
-> EventLoopGroup.register
-> doResolveAndConnect0
-> 地址解析
-> doConnect
-> channel.connect
-> pipeline.connect
-> HeadContext.connect
-> Unsafe.connect
-> doConnect
-> 立即成功或等待 OP_CONNECT

Bootstrap.connect

Bootstrap.connect 最终会进入 doResolveAndConnect。

private ChannelFuture doResolveAndConnect(final SocketAddress remoteAddress。final SocketAddress localAddress) {
// 创建 Channel、初始化 Pipeline，并注册到 EventLoop
final ChannelFuture regFuture = initAndRegister;final Channel channel = regFuture.channel;// 判断注册 Future 是否已经完成
if ) {
if ) {
return regFuture;}
return doResolveAndConnect0(channel。remoteAddress,localAddress,channel.newPromise);} else {
// 注册尚未完成时添加监听器，等注册成功后再继续连接
// …}
}

痛点提醒：很多人误以为 initAndRegister 完成后就已经可以“直接”发起网络请求，其实只有当 Channel 成功注册到 EventLoop 后后续的连接动作才会真正提交到对应的 I/O 线程执行。

initAndRegister

initAndRegister 的职责可以拆成三步：

1. 创建客户端 Channel，例如 NioSocketChannel。 不过，
2. 调用 Bootstrap.init 初始化客户端 Channel。
3. 调用 config.group.register,把 Channel 注册到 EventLoop。

痛点：If you forget to call .handler,pipeline will be empty and you won’t see any inbound events such as #channelActive。making debugging feel like “nothing happens”.

void init {
// 设置 ChannelOption
setChannelOptions,logger);// 设置 Attribute
setAttributes);ChannelPipeline p = channel.pipeline;// 加入使用者配置的 handler，通常就是 ChannelInitializer
p.addLast);// 执行客户端初始化
点
// …}

NIO 环境下注册阶段最终会把 Channel 绑定到某个 EventLoop，并在底层 Selector 上完成注册。

doResolveAndConnect0

注册完成后连接流程进入 doResolveAndConnect0.

private ChannelFuture doResolveAndConnect0(final Channel channel。SocketAddress remoteAddress,final SocketAddress localAddress,final ChannelPromise promise) {
try {
// disableResolver 为 true 表示禁用地址解析，不会再走 AddressResolver
if {
doConnect;return promise;}
// 如果地址已经解析。或者 resolver 不支持该地址类型，就直接连接；// 否则先异步解析地址，解析成功后再 doConnect。// ，} catch {
promise.tryFailure;}
return promise;}

Pain point:If you set .disableResolver

doConnect

private static void doConnect(final SocketAddress remoteAddress。final SocketAddress localAddress,final ChannelPromise connectPromise) {
final Channel channel = connectPromise.channel;channel.eventLoop.execute -> {
if {
channel.connect;} else {
channel.connect;}
connectPromise.addListener;})，}