Netty系列(五):源码解读ServerBootstrapAcceptor类职能,探究Netty启动流程

news2024/9/21 18:47:15

ServerBootstrapAcceptor是Netty服务端用来接收客户端连接的核心类,本文将介绍ServerBootstrapAcceptor的职能。

init方法

在上一篇文章源码解读 backlog 参数作用中我们知道,在Netty服务端启动时,会调用ServerBootstrap.bind()绑定本地端口用来监听客户端的连接。

而这个方法会通过反射创建ServerSocketChannel并初始化,ServerBootstrap.init()会初始化ServerSocketChannel,将ServerBootstrapAcceptor添加到服务端ChannelPipeline中。

在这里插入图片描述

init方法用于服务端Channel的初始化,初始化ServerSocketChannelChannelPipeline,并向ChannelPipeline中添加了一个ChannelInitializer

ChannelInitializer是一个ChannelHandler,但它不处理任何出站、入站事件,其目的只为了完成Channel的初始化。

ChannelHandler被添加到ChannelPipeline后,会触发一个handlerAdded方法回调,这个方法里会调用initChannel()进行初始化,初始化完成后会将自己从Pipeline中删除,

在这里插入图片描述

We are done with init the Channel, removing the initializer now.(完成 Channel 的初始化后,删除初始化器。)

我们再看回ServerBootstrapAcceptor类,其中在向ChannelPipeline中添加ChannelInitializer时,在initChannel方法中会向ChannelPipeline中添加一个ServerBootstrap.handler()。这是个用户自定义的ChannelHandler,如果用户没有设置,就不会通过判空校验,也就不会添加到ChannelPipeline中。

在处理完用户自定义的ChannelHandler后,还会再添加一个ServerBootstrapAcceptor

在这里插入图片描述

ServerBootstrapAcceptor

我们先看一下ServerBootstrapAcceptor类图结构(虚线表示实现接口,实线表示类继承),我们得知ServerBootstrapAcceptor实现了ChannelInboundHandler接口,而是ChannelInboundHandler本身就是进站处理器,处理channel进站的一系列事件。

在这里插入图片描述

ServerBootstrapAcceptor类属性也就是childChannel相关的配置信息,相关介绍如下:

  1. childGroup: Reactor模型中的WorkerGroup
  2. childHandler: 客户端Channel的ChannelHandler
  3. childOptions: 客户端Channel的Options
  4. childAttrs: 客户端Channel的Attrs
  5. enableAutoReadTask: 启用自动读取的任务

ServerBootstrapAcceptor类重写了channelRead方法,这是它最主要的方法。

在这里插入图片描述

channelRead方法中,整个过程如下:

  1. 设置SocketChannelPipeline
  2. 设置ChannelOptionsAttributes
  3. Channel注册到WorkerGroup中。
  4. Channel注册到workGroup中。

如果整个过程出现了异常,Netty会调用forceClose()强制关闭连接,其底层是调用了SocketChannel.close()方法关闭连接。

什么时候会触发channelRead方法

debug模式启动netty后,我们在channelRead方法打断点,通过nc连接netty服务端。


nc localhost 8888

运行nc指令后,我们会发现断点位置阻塞了。
我们可以看到,传入的msg是NioSocketChannel,记录的是与客户端连接的channel。接下来我们仔细看一下调用栈,该方法被触发时是运行在bossGroup的线程中的。

在这里插入图片描述

当有新客户端连接时,就会触发ServerBootstrapAcceptor类的channelRead方法。

总结

ServerBootstrapAcceptor类是一个特殊的ChannelHandler,是Netty服务端用来接收客户端连接的核心类。

ServerBootstrap在初始化Channel时,会往它的ChannelPipeline中添加ServerBootstrapAcceptor,而ServerBootstrapAcceptor重写了ChannelRead回调,当有新客户端连接时,就会触发ChannelRead回调,这样ServerBootstrapAcceptor就可以拿到客户端连接,并对客户端连接进行初始化并注册到WorkerGroup中。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/60211.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

玩转GDAL一文带你深入Windows下FileGDB驱动支持

前言 了解GDAL的朋友一定知道,GDAL3.5以下(含)默认配置下是只支持gdb文件的读的,是不支持写的。更要命的是,默认的OpenFileGDB在读取时,如果我们在矢量文件中设置了属性表字段的别名,默认驱动是…

Git项目演练

Git项目演练 首先,进入到项目路径 然后,初始化,产生.git库 创建gitignore文件 将不需要的文件放入到,gitignore 将所有的文件添加到追踪的状态 对文件进行一次提交 使用git log查看变动 使用编译器修改代码中的内容 对修改进…

基于javaweb的学籍管理系统计算机毕业论文java毕业设计选题源代码

💖💖更多项目资源,最下方联系我们✨✨✨✨✨✨ 目录 Java项目介绍 资料获取 Java项目介绍 计算机毕业设计java毕设之基于javaweb的学籍管理系统-IT实战营_哔哩哔哩_bilibili项目资料网址: http://itzygogogo.com软件下载地址:http://itzy…

【能效管理】安科瑞新能源充电桩收费运维管理云平台应用分析

概述 AcrelCloud-9000安科瑞充电桩收费运营云平台系统通过物联网技术对接入系统的汽车充电站、电动自行车充电站以及各个充电桩进行不间断地数据采集和监控,实时监控充电桩运行状态,进行充电服务、支付管理,交易结算,资源管理、电…

ADSP-21569/ADSP-21593的开发入门(上)

作者的话 ADI的SHARC系列DSP,目前已经出到5系列了,最新的一颗叫2159x,按照ADI的说法,这颗DSP的性能是21569的两倍,但又能和21569做P2P的替换,所以下面我们就以21593为例,写一点资料&#xff0c…

头歌计算机组成原理MIPS RAM设计

完整答案点击底部 <?xml version"1.0" encoding"UTF-8" standalone"no"?> <project source"2.15.0.2.exe" version"1.0"> This file is intended to be loaded by Logisim http://logisim.altervista.org &l…

数字化门店| 旧衣回收店系统 | 智慧门店小程序开发教程

随着人们生活质量的提升&#xff0c;无论男女&#xff0c;衣柜鞋柜里摆满了各种衣物&#xff0c;覆盖了多个场景下的衣物非常多&#xff0c;同时如今大多数人已经不再穿补丁衣服&#xff0c;旧或破就会扔掉买新的。为了节省资源及合理二次利用&#xff0c;旧衣回收行业逐渐出现…

用译码器来设计组合逻辑电路

三线到八线&#xff1a;输入端只有三个所以只能是三变量 我们先来看书上的一个例子 设计的过程第一步 将函数表达式整理成最小项和的形式 我们用来举例&#xff0c;不是最小项的形式 三变量函数可以用三变量的最小项来表示 为了看的更清楚&#xff0c;我们写成最小项的编号&…

四、Git本地仓库基本操作——查看提交历史和版本回退前进

1. 查看提交历史 查看git提交历史一般常用两个命令&#xff1a; # 查看历史提交记录 git log # 以列表形式查看指定文件的历史记录 git blame <文件名>git log 该命令会按照我们提交的时间线&#xff0c;然后列出所有的历史提交。 示例&#xff1a; git log 显示的…

[附源码]计算机毕业设计JAVA医疗预约系统

[附源码]计算机毕业设计JAVA医疗预约系统 项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis M…

【Pytorch】广播机制

【参考&#xff1a;The size of tensor a must match the size of tensor b (y) at non-singleton dimension z_点PY的博客-CSDN博客】 报错&#xff1a;The size of tensor a (x) must match the size of tensor b (y) at non-singleton dimension z 其广播机制遵循以下规则…

[附源码]计算机毕业设计基于springboot的连锁药店销售管理系统

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…

mediasoup学习与实践

一、mediasoup基本概念&#xff1a; 基础架构 1、worker 2、router 3、producer 4、consumer 5、transport 整体结构 特性 1、支持IPv6 2、ICE/DRLS/RTP/RTCP over UDP and TCP 3、支持simulcast和svc 4、支持拥塞控制 5、带宽控制 6、支持&#xff1a;STCP 7、多流使用同一…

安全可靠的SRT实时传输协议

Secure Reliable Transport(SRT)是安全、可靠、低延时的多媒体实时传输协议。SRT协议使用AES进行数据加密&#xff0c;运用FEC进行前向纠错&#xff0c;并且有流量控制、拥塞控制。类似于QUIC协议&#xff0c;SRT采用UDP代替TCP&#xff0c;在应用层提供发送确认机制、ARQ自动重…

ArcGIS基础:点要素分割线要素和提取线要素的交点

第一个实验&#xff1a;【点要素分割线要素】 看下原始数据&#xff1a;下图所示&#xff0c;&#xff12;个红点和一条绿线&#xff0c;用&#xff12;个点去分割这条线。 找到【数据管理工具】&#xff0c;在找到【要素】&#xff0c;再找到【在点处分割线】&#xff0c;如…

【云原生 | Kubernetes 实战】07、Pod 高级实战:Pod 生命周期、启动钩子、停止钩子

目录 一、Pod 生命周期 1.1 pod 生命周期的重要行为 二、初始化容器最佳实战 2.1 Init 容器 2.2 初始化容器使用案例 2.3 初始化容器生产应用 三、主容器 3.1 容器钩子 3.2 演示 postStart 和 preStop 用法 总结 一、Pod 生命周期 pod从开始创建到终止退出的时间…

51单片机自学报告--实验部分

微机接口技术-自主学习笔记 PPT链接&#xff1a;微机接口自学--51单片机自学汇报PPT_猫猫爱吃小鱼的博客-CSDN博客 效果演示gif: 四、Proteus仿真 仿真环境&#xff1a;电路仿真软件: Proteus HEX可执行文件编写软件: keil uVision4 keil uVision4新…

设计模式——模板方法

GOF-23 模式分类 从目的来看&#xff1a; • 创建型&#xff08;Creational&#xff09;模式&#xff1a;将对象的部分创建工作延迟到子类或者其他对象&#xff0c;从而应对需求变化为对象创建时具体类型实 现引来的冲击。 • 结构型&#xff08;Structural&#xff09;模式&a…

OpenCV 透视变换

OpenCV 透视变换1. 简介2. 仿射变换2.1. 平移2.2. 旋转2.3. 放缩2.4. 错切2.5. 仿射变换3. 透视变换1. 简介 汽车的360度全景影像&#xff0c;从拍照视角变成鸟瞰图 这种变换常常用到透视变换 在了解透视变换前&#xff0c;需要了解一下其他的变换&#xff0c;包括 平移&#…

小白必知必会的几个IP协议知识

小白必知必会的几个IP协议知识1.IP地址属于网络层协议2.路由控制3.数据链路的抽象化4.IP属于面向无连接型1.IP地址属于网络层协议 在计算机通信中&#xff0c;为了识别通信对端&#xff0c;必须要有一个类似于地址的识别码进行标识。 MAC地址是用来标识同一个链路中不同计算机…