[connect和bind过程详解(一)-CSDN博客](connect和bind过程详解(一))[connect和bind过程详解(二)-CSDN博客](connect和bind过程详解(二))Netty Connect 与 Bind 对比总结一、快速对比表对比项Connect客户端Bind服务端使用场景客户端连接服务端服务端绑定端口Channel 类型NioSocketChannelNioServerSocketChannelJDK 底层操作SocketChannel.connect()ServerSocketChannel.bind()是否异步是可能异步否同步完成返回值含义true立即成功, false正在进行无返回值同步监听的事件OP_CONNECT → OP_READOP_ACCEPT完成后的操作finishConnect() → 读写数据接受新连接EventLoopGroup单个 workerGroupbossGroup workerGroupPipeline 传播tail → headOutboundtail → headOutbound超时处理有可配置连接超时无立即完成二、调用链路对比2.1 Connect 调用链路Bootstrap.connect(host, port) ↓ doResolveAndConnect() ├─→ initAndRegister() [创建 NioSocketChannel] └─→ doResolveAndConnect0() [DNS 解析] ↓ doConnect() [提交任务] ↓ pipeline.connect() [tail → head] ↓ unsafe.connect() ↓ NioSocketChannel.doConnect() ↓ SocketChannel.connect() [JDK] ↓ ┌────────┴────────┐ ↓ ↓ 立即成功 正在进行中 ↓ ↓ 完成Promise 注册 OP_CONNECT ↓ ↓ channelActive 等待事件就绪 ↓ ↓ 注册 OP_READ finishConnect() ↓ 完成Promise ↓ channelActive ↓ 注册 OP_READ2.2 Bind 调用链路ServerBootstrap.bind(port) ↓ doBind() ├─→ initAndRegister() [创建 NioServerSocketChannel] └─→ doBind0() [提交任务] ↓ pipeline.bind() [tail → head] ↓ unsafe.bind() ↓ NioServerSocketChannel.doBind() ↓ ServerSocketChannel.bind() [JDK] ↓ 绑定成功同步 ↓ 完成Promise ↓ channelActive ↓ 注册 OP_ACCEPT ↓ 等待客户端连接 ↓ OP_ACCEPT 就绪 ↓ doReadMessages() [接受连接] ↓ 创建 NioSocketChannel ↓ channelRead 事件 ↓ ServerBootstrapAcceptor ↓ 注册到 workerGroup三、相同点3.1 都必须先 Register无论是 connect 还是 bind都必须先完成 register 操作// 都会先调用 initAndRegister()finalChannelFutureregFutureinitAndRegister();finalChannelchannelregFuture.channel();// 等待 register 完成后再执行 connect 或 bindif(regFuture.isDone()){// register 已完成doXxx(channel,...);}else{// register 还未完成添加监听器regFuture.addListener(newChannelFutureListener(){OverridepublicvoidoperationComplete(ChannelFuturefuture){doXxx(channel,...);}});}3.2 都在 EventLoop 线程中执行// Connectchannel.eventLoop().execute(newRunnable(){Overridepublicvoidrun(){channel.connect(remoteAddress,connectPromise);}});// Bindchannel.eventLoop().execute(newRunnable(){Overridepublicvoidrun(){channel.bind(localAddress,promise);}});3.3 都通过 Pipeline 传播Outbound 事件// 都是从 tail 开始向 head 传播pipeline.connect(remoteAddress,promise);// Connectpipeline.bind(localAddress,promise);// Bind// 传播路径tail → 自定义 OutboundHandler → head3.4 都由 Head 调用 Unsafe// HeadContextOverridepublicvoidconnect(...){unsafe.connect(remoteAddress,localAddress,promise);}Overridepublicvoidbind(...){unsafe.bind(localAddress,promise);}3.5 都会触发 channelActive 事件// 完成后都会触发 channelActiveif(!wasActiveisActive()){pipeline.fireChannelActive();}四、不同点详解4.1 同步 vs 异步Connect异步// 调用 JDK 的 connect可能返回 falsebooleanconnectedSocketUtils.connect(javaChannel(),remoteAddress);if(!connected){// 连接正在进行中注册 OP_CONNECT 事件selectionKey().interestOps(SelectionKey.OP_CONNECT);// 等待 NioEventLoop 监听到 OP_CONNECT 事件// 然后调用 finishConnect() 完成连接}Bind同步// 调用 JDK 的 bind立即完成javaChannel().bind(localAddress,config.getBacklog());// 没有返回值绑定立即完成4.2 监听的事件不同Connect 后监听 OP_READ// 连接完成后开始监听 OP_READ准备读取数据selectionKey().interestOps(SelectionKey.OP_READ);Bind 后监听 OP_ACCEPT// 绑定完成后开始监听 OP_ACCEPT准备接受新连接selectionKey().interestOps(SelectionKey.OP_ACCEPT);4.3 后续处理不同Connect 后的处理// 1. 连接完成finishConnect();// 2. 触发 channelActivepipeline.fireChannelActive();// 3. 开始读写数据// 用户的 handler 可以开始发送和接收数据Bind 后的处理// 1. 绑定完成doBind(localAddress);// 2. 触发 channelActivepipeline.fireChannelActive();// 3. 开始接受新连接// 当有客户端连接时doReadMessages(readBuf);// 接受连接创建 NioSocketChannelpipeline.fireChannelRead(child);// 传递给 ServerBootstrapAcceptorchildGroup.register(child);// 注册到 workerGroup4.4 EventLoopGroup 的使用Connect客户端// 只需要一个 EventLoopGroupEventLoopGroupworkerGroupnewNioEventLoopGroup();BootstrapbnewBootstrap();b.group(workerGroup)// 只设置一个 group.channel(NioSocketChannel.class);Bind服务端// 需要两个 EventLoopGroupEventLoopGroupbossGroupnewNioEventLoopGroup(1);// 接受连接EventLoopGroupworkerGroupnewNioEventLoopGroup();// 处理 IOServerBootstrapbnewServerBootstrap();b.group(bossGroup,workerGroup)// 设置两个 group.channel(NioServerSocketChannel.class);五、代码示例对比5.1 客户端 Connect 示例publicclassNettyClient{publicstaticvoidmain(String[]args)throwsException{EventLoopGroupworkerGroupnewNioEventLoopGroup();try{BootstrapbnewBootstrap();b.group(workerGroup).channel(NioSocketChannel.class).option(ChannelOption.AUTO_READ,true).handler(newChannelInitializerSocketChannel(){OverrideprotectedvoidinitChannel(SocketChannelch){ch.pipeline().addLast(newMyClientHandler());}});// 【Connect】连接服务端ChannelFuturefb.connect(localhost,8080).sync();System.out.println(客户端连接成功);f.channel().closeFuture().sync();}finally{workerGroup.shutdownGracefully();}}}5.2 服务端 Bind 示例publicclassNettyServer{publicstaticvoidmain(String[]args)throwsException{EventLoopGroupbossGroupnewNioEventLoopGroup(1);EventLoopGroupworkerGroupnewNioEventLoopGroup();try{ServerBootstrapbnewServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,128).childHandler(newChannelInitializerSocketChannel(){OverrideprotectedvoidinitChannel(SocketChannelch){ch.pipeline().addLast(newMyServerHandler());}});// 【Bind】绑定端口ChannelFuturefb.bind(8080).sync();System.out.println(服务端启动成功监听端口8080);f.channel().closeFuture().sync();}finally{workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();}}}六、常见问题对比Q1为什么 Connect 可能是异步的而 Bind 是同步的AConnect需要进行 TCP 三次握手涉及网络传输需要时间客户端 ---SYN--- 服务端 客户端 --SYNACK--- 服务端 客户端 ---ACK--- 服务端Bind只是在本地绑定端口不涉及网络通信操作系统可以立即完成Q2为什么服务端需要两个 EventLoopGroupAbossGroup专门负责接受新连接处理 OP_ACCEPT通常只需要 1 个线程接受连接的操作很快workerGroup负责处理已建立连接的 IO 操作需要多个线程根据 CPU 核心数IO 操作比较耗时类比bossGroup 餐厅的迎宾员迎接客人workerGroup 餐厅的服务员为客人服务Q3Connect 超时了怎么办ABootstrapbnewBootstrap();b.option(ChannelOption.CONNECT_TIMEOUT_MILLIS,5000);// 设置连接超时 5 秒ChannelFuturefutureb.connect(localhost,8080);future.addListener(newChannelFutureListener(){OverridepublicvoidoperationComplete(ChannelFuturef){if(!f.isSuccess()){System.out.println(连接失败f.cause());// 可以实现重试逻辑}}});Q4Bind 失败了怎么办Atry{ChannelFuturefserverBootstrap.bind(8080).sync();}catch(Exceptione){// 可能的原因// 1. 端口已被占用// 2. 没有权限绑定该端口如 80 端口需要 root 权限// 3. 地址不可用System.out.println(绑定失败e.getMessage());// 可以尝试绑定其他端口serverBootstrap.bind(8081).sync();}七、性能优化建议7.1 客户端优化BootstrapbnewBootstrap();b.group(workerGroup).channel(NioSocketChannel.class)// 1. 启用 TCP_NODELAY禁用 Nagle 算法减少延迟.option(ChannelOption.TCP_NODELAY,true)// 2. 启用 SO_KEEPALIVE保持长连接.option(ChannelOption.SO_KEEPALIVE,true)// 3. 设置连接超时.option(ChannelOption.CONNECT_TIMEOUT_MILLIS,5000)// 4. 设置发送缓冲区大小.option(ChannelOption.SO_SNDBUF,1024*64)// 5. 设置接收缓冲区大小.option(ChannelOption.SO_RCVBUF,1024*64);7.2 服务端优化ServerBootstrapbnewServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class)// 1. 设置 TCP 连接队列大小.option(ChannelOption.SO_BACKLOG,1024)// 2. 启用地址重用服务重启时快速绑定端口.option(ChannelOption.SO_REUSEADDR,true)// 3. 为子 Channel 启用 TCP_NODELAY.childOption(ChannelOption.TCP_NODELAY,true)// 4. 为子 Channel 启用 SO_KEEPALIVE.childOption(ChannelOption.SO_KEEPALIVE,true)// 5. 设置子 Channel 的缓冲区大小.childOption(ChannelOption.SO_SNDBUF,1024*64).childOption(ChannelOption.SO_RCVBUF,1024*64);八、总结8.1 Connect 的核心要点异步操作可能需要等待 OP_CONNECT 事件单 EventLoopGroup只需要 workerGroup连接完成后开始读写数据超时处理可配置连接超时时间重试机制需要用户自己实现8.2 Bind 的核心要点同步操作立即完成无需等待双 EventLoopGroupbossGroup workerGroup绑定完成后开始接受新连接主从 ReactorbossGroup 接受连接workerGroup 处理 IOServerBootstrapAcceptor负责将新连接注册到 workerGroup8.3 共同点都必须先 register都在 EventLoop 线程中执行都通过 Pipeline 传播Outbound 事件都由 Head 调用 Unsafe都会触发 channelActive 事件