博客
关于我
Netty源码—4.客户端接入流程二
阅读量:800 次
发布时间:2023-02-15

本文共 1415 字,大约阅读时间需要 4 分钟。

Netty客户端连接接入问题整理

Reactor线程模型和服务端启动流程

Netty的Reactor线程模型采用了多线程的事件驱动模式,能够高效处理大量的网络连接。服务端启动时,会创建一个NioEventLoopGroup,并将服务端Channel绑定到boss线程组,而客户端连接则绑定到worker线程组。这种设计使得服务端能够高效处理大量连接,同时保持每个连接的响应时间。

Netty新连接接入的整体处理逻辑

当服务端Channel接收到新连接请求时,会执行以下步骤:

  • 创建NioSocketChannel并包装JDK底层的SelectableChannel
  • 将NioSocketChannel注册到对应的NioEventLoopGroup中
  • 通过ServerBootstrapAcceptor处理新连接,包括设置ChannelOption、ChannelAttr和用户自定义的ChannelHandler
  • 绑定Reactor线程,并注册读事件
  • 新连接接入之检测新连接

    在服务端Channel的Pipeline中,ServerBootstrapAcceptor处理器负责检测新连接。当有新的连接接入时,ServerBootstrapAcceptor的channelRead()方法会被调用。此时会创建一个NioSocketChannel,并将其注册到对应的NioEventLoopGroup中。

    新连接接入之创建NioSocketChannel

    NioSocketChannel是Netty对JDK底层SelectableChannel的封装,主要负责处理网络事件。创建NioSocketChannel时,会设置用户自定义的ChannelHandler、ChannelOption和ChannelAttr,并将其绑定到Reactor线程上。

    新连接接入之绑定NioEventLoop线程

    将NioSocketChannel绑定到NioEventLoop线程的过程包括以下步骤:

  • 将NioSocketChannel添加到NioEventLoopGroup的Selector中
  • 调用NioEventLoopGroup的register()方法,选择一个NioEventLoop进行绑定
  • 将NioSocketChannel的读事件注册到NioEventLoop的Selector中
  • 注册Reactor线程总结

  • NioEventLoopGroup的register()方法会调用NioEventLoop的register()方法
  • NioEventLoop通过线程选择器选择一个NioEventLoop进行绑定
  • 将NioSocketChannel的读事件注册到NioEventLoop的Selector中
  • 新连接接入总结

    新连接接入的过程主要包括以下步骤:

  • 服务端Channel在boss线程组中接收到新连接请求
  • 创建NioSocketChannel并包装JDK底层SelectableChannel
  • 通过ServerBootstrapAcceptor处理新连接,设置ChannelOption、ChannelAttr和用户自定义的ChannelHandler
  • 将NioSocketChannel绑定到对应的NioEventLoop线程,并注册读事件
  • 整个过程确保了新连接能够快速接入并开始数据读写,保证了Netty服务端的高效性能。

    转载地址:http://jvcfk.baihongyu.com/

    你可能感兴趣的文章
    Objective-C实现alternate disjoint set不相交集算法(附完整源码)
    查看>>
    Objective-C实现An Armstrong number阿姆斯特朗数算法(附完整源码)
    查看>>
    Objective-C实现anagrams字谜算法(附完整源码)
    查看>>
    Objective-C实现ApproximationMonteCarlo蒙特卡洛方法计算pi值算法 (附完整源码)
    查看>>
    Objective-C实现area under curve曲线下面积算法(附完整源码)
    查看>>
    Objective-C实现arithmetic算术算法(附完整源码)
    查看>>
    Objective-C实现armstrong numbers阿姆斯壮数算法(附完整源码)
    查看>>
    Objective-C实现articulation-points(关键点)(割点)算法(附完整源码)
    查看>>
    Objective-C实现atoi函数功能(附完整源码)
    查看>>
    Objective-C实现average absolute deviation平均绝对偏差算法(附完整源码)
    查看>>
    Objective-C实现average mean平均数算法(附完整源码)
    查看>>
    Objective-C实现average median平均中位数算法(附完整源码)
    查看>>
    Objective-C实现average mode平均模式算法(附完整源码)
    查看>>
    Objective-C实现avl 树算法(附完整源码)
    查看>>
    Objective-C实现AvlTree树算法(附完整源码)
    查看>>
    Objective-C实现backtracking Jump Game回溯跳跃游戏算法(附完整源码)
    查看>>
    Objective-C实现BACKTRACKING 方法查找集合的幂集算法(附完整源码)
    查看>>
    Objective-C实现bailey borwein plouffe算法(附完整源码)
    查看>>
    Objective-C实现base64加密和base64解密算法(附完整源码)
    查看>>
    Objective-C实现base64加解密(附完整源码)
    查看>>