手撕netty源码(二)- 初始化ServerBootstrap

文章目录

  • 前言
  • 一、ServerBootstrap 的创建和初始化
    • 1.1 创建
    • 1.2 初始化group
    • 1.3 初始化channel
    • 1.3 初始化option和attr
    • 1.4 初始化handler 和 childHandler
  • 总结


前言

接上一篇:手撕netty源码(一)- NioEventLoopGroup
本篇讲解 ServerBootstrap 的创建以及初始化:group、channel、option、attr、handler、childHandler


一、ServerBootstrap 的创建和初始化

在这里插入图片描述

public class ServerBootstrap extends AbstractBootstrap<ServerBootstrap, ServerChannel>public class Bootstrap extends AbstractBootstrap<Bootstrap, Channel>

看的出来,AbstractBootstrap 是个比较重要的类,他里面其实包含了netty客户端和服务端的逻辑,所以有些属性和方法要注意一下

1.1 创建

创建很简单,只是new了一个对象而已

ServerBootstrap b = new ServerBootstrap();// io/netty/bootstrap/ServerBootstrap.java
public ServerBootstrap() {
}

1.2 初始化group

可以看到,这个操作其实只是初始化了 ServerBootstrap 的两个属性:group 和 childGroup

b.group(bossGroup, workerGroup)// io/netty/bootstrap/ServerBootstrap.java
public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) {super.group(parentGroup);if (this.childGroup != null) {throw new IllegalStateException("childGroup set already");}this.childGroup = ObjectUtil.checkNotNull(childGroup, "childGroup");return this;
}// 下面是super.group(parentGroup)
// io/netty/bootstrap/AbstractBootstrap.java
public B group(EventLoopGroup group) {ObjectUtil.checkNotNull(group, "group");if (this.group != null) {throw new IllegalStateException("group set already");}this.group = group;return self();
}

1.3 初始化channel

这一步其实是初始化 channelFactory ,可以看到,实际的channelFactory 实现是 ReflectiveChannelFactory,即通过反射来创建 channel,不过这里并没有开始创建 channel ,只是给 channelFactory 属性赋了值

b.channel(NioServerSocketChannel.class);//io/netty/bootstrap/AbstractBootstrap.java
public B channel(Class<? extends C> channelClass) {return channelFactory(new ReflectiveChannelFactory<C>(ObjectUtil.checkNotNull(channelClass, "channelClass")));
}//io/netty/bootstrap/AbstractBootstrap.java
public B channelFactory(io.netty.channel.ChannelFactory<? extends C> channelFactory) {return channelFactory((ChannelFactory<C>) channelFactory);
}//io/netty/bootstrap/AbstractBootstrap.java
public B channelFactory(ChannelFactory<? extends C> channelFactory) {ObjectUtil.checkNotNull(channelFactory, "channelFactory");if (this.channelFactory != null) {throw new IllegalStateException("channelFactory set already");}this.channelFactory = channelFactory;return self();
}

1.3 初始化option和attr

AbstractBootstrap 定义了两个ConcurrentHashMap

  • ChannelOption 主要是用于配置netty中一些相关的参数,这些参数的key已经在ChannelOption中以静态变量的方式设置好了,可以直接拿来使用,并且配置相关的value,如果ChannelOption设置了一个不存在的key,就会以日志的形式提示错误信息,但是不会抛出异常。
  • AttributeKey 主要用于维护业务数据,业务数据随着业务流转
private final Map<ChannelOption<?>, Object> options = new ConcurrentHashMap();
private final Map<AttributeKey<?>, Object> attrs = new ConcurrentHashMap();public <T> B option(ChannelOption<T> option, T value) {ObjectUtil.checkNotNull(option, "option");if (value == null) {this.options.remove(option);} else {this.options.put(option, value);}return this.self();
}public <T> B attr(AttributeKey<T> key, T value) {ObjectUtil.checkNotNull(key, "key");if (value == null) {this.attrs.remove(key);} else {this.attrs.put(key, value);}return this.self();
}

稍微往里面看一看,会发现ChannelOption和AttributeKey都继承了AbstractConstant,且内部都使用ConstantPool维护了数据 。
这里注意一下:ChannelOption和AttributeKey都提供了方法valueOf和newInstance,二者的区别是 valueOf 同样的参数 多次调用返回的是同一个对象,而newInstance 同样的参数 多次调用返回的是不同的对象

1.4 初始化handler 和 childHandler

handler 被定义在AbstractBootstrap,childHandler 被定义在ServerBootstrap。所以 handler 服务端和客户端都会被用到,而childHandler 只有服务端可以用到

// io/netty/bootstrap/AbstractBootstrap.java
public B handler(ChannelHandler handler) {this.handler = ObjectUtil.checkNotNull(handler, "handler");return self();
}// io/netty/bootstrap/ServerBootstrap.java
public ServerBootstrap childHandler(ChannelHandler childHandler) {this.childHandler = ObjectUtil.checkNotNull(childHandler, "childHandler");return this;
}

总结

本文先简单介绍一下 ServerBootstrap 的创建和属性初始化赋值,并没有实质的操作,下一篇会讲解 bind 方法,这个方法里有很多内容

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

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

相关文章

项目开发的详细步骤(精华版)

项目开发是指从项目启动到项目交付的全过程&#xff0c;涵盖了需求分析、设计、编码、测试、部署等多个环节。以下为项目开发的详细步骤&#xff1a; 1. 项目启动与规划 项目立项 商业论证&#xff1a;分析项目投资回报率、风险、市场前景等&#xff0c;确定项目价值和可行性…

Vue

文章目录 Vue1. 创建Vue实例2. 插值表达式3. 响应式特性4. 常用指令4.1 内容渲染指令4.2 条件渲染指令4.3 事件绑定指令4.4 单向属性绑定指令4.5 双向属性绑定指令4.6 列表渲染指令 5. 修饰符5.1 事件修饰符5.2 键盘事件修饰符5.3 修饰符串联5.4 v-model 修饰符 6. computed计算…

Android SDK Manager安装Google Play Intel x86 Atom_64 System Image依赖问题

Package Google Play Intel x86 Atom_64 System Image,Android API R, revision 2 depends on SDK Platform Android R Preview, revision 2 问题 一开始以为网络还有依赖包没有勾选&#xff0c;尝试了很多次&#xff0c;勾选这边报错对应的license即可。此时点击一下其他licen…

CountDownLatch使用错误+未最终断开连接导致线程池资源耗尽

错误描述&#xff1a; 我设置了CountDownLatch对线程的协作做出了一些限制&#xff0c;但是我发现运行一段时间以后便发现定时任务不运行了。 具体代码&#xff1a; public void sendToCertainWeb() throws IOException, InterruptedException {List<String> urlList …

(LdAiChat、Ai Loading、不墨AI助手、360AI搜索、TIG AI)分析好用的ChatGPT

目录 1、LdAiChat 2、Ai Loading 3、不墨AI助手 - 会话式AI工具 4、360AI搜索 5、TIG AI

如何利用美国站群服务器实现有效的SEO优化策略?

如何利用美国站群服务器实现有效的SEO优化策略? 在当今数字化时代&#xff0c;SEO优化对于网站的可见性和吸引力至关重要。站群服务器作为一种有效的SEO策略&#xff0c;可以通过多个相关联的网站在不同服务器上的部署&#xff0c;增强网站的权威性和链接多样性。尤其是在利用…

ZYNQ之嵌入式开发04——自定义IP核实现呼吸灯、固化程序

文章目录 自定义IP核——呼吸灯实验固化程序 自定义IP核——呼吸灯实验 Xilinx官方提供了很多IP核&#xff0c;在Vivado的IP Catalog中可以查看这些IP核&#xff0c;在构建自己复杂的系统时&#xff0c;只使用Xilinx官方的免费IP核一般满足不了设计的要求&#xff0c;因此很多…

Java使用XStream将压缩成gz格式xml文件转换成List详解及问题

Java使用XStream将压缩成gz格式xml文件转换成List详解及问题 前言 这次说是写文章,感觉更是像填坑,几年前我就写过vo对象list转换成xml并压缩的相关文章 Java将数据生成XML文件并进行压缩成GZ格式 那会都没发现没有怎么解压缩,一个工具类整整写了一天,遇到了很多问题,…

机器人自动驾驶时间同步进阶

0. 简介 之前时间同步也写过一篇文章介绍机器人&自动驾驶中的时间同步。在最近的学习中发现一些额外需要阐述学习的内容&#xff0c;这里就再次写一些之前没写到的内容。 1. NTP NTP 是网络时间协议&#xff0c;用来同步网络中各计算机时间的协议&#xff0c;把计算机的时…

「PHP系列」PHP 发送电子邮件详解

文章目录 一、PHP发送电子邮件二、PHP mail() 函数1. 函数原型2. 参数说明3. 返回值4. 常见的 $headers 属性5. 注意事项6. 示例 三、相关链接 一、PHP发送电子邮件 在 PHP 中&#xff0c;你可以使用内置的 mail() 函数来发送电子邮件。然而&#xff0c;mail() 函数在发送邮件…

FPGA verilog 模板设计示例(持续更新)

重温一下大道至简的至简设计法&#xff0c;正式开发两年多回顾当时的设计方法&#xff0c;又有了更多的体会和感触&#xff0c;希望将模块化运用起来会更有条例。1 FPGA设计代码模板 信号命名规范&#xff1a; 1 clk 表示时钟信号小写 2 rstn 表示高电平复位信号 小写 3 rst_n…

品牌差异化战略:Kompas.ai如何打造独特的内容声音

在当今竞争激烈的商业环境中&#xff0c;品牌差异化已成为企业获取市场优势的关键策略。一个鲜明的品牌形象和独特的内容声音不仅能够帮助企业吸引目标客户&#xff0c;还能够在消费者心中建立起独特的地位。本文将深入探讨品牌差异化的重要性&#xff0c;分析Kompas.ai如何帮助…

centos操作命令

CentOS操作命令包括但不限于以下几种&#xff1a; 系统操作命令&#xff1a; 关机、重启及登出&#xff1a; shutdown -h now&#xff1a;关闭系统。init 0 或 telinit 0&#xff1a;关闭系统。shutdown -r now&#xff1a;重启系统。reboot&#xff1a;重启系统。logout&…

Ubuntu搭建Python虚拟环境:virtualenv

1 缘起 一阶段&#xff1a;Python开发&#xff0c;使用Windows环境&#xff0c;使用的相关依赖在Windows环境都能使用&#xff1b; 进入二阶段&#xff0c;开发了一个新功能&#xff0c;使用了k8s&#xff0c;Python依赖为&#xff1a;easy_k8s&#xff0c; 刚好&#xff0c;e…

揭秘 IDM:下载管理大师的全面指南与实用技巧深度解析

IDM&#xff08;Internet Download Manager&#xff09;是一款流行的下载管理软件&#xff0c;它可以帮助用户以更快的速度下载文件&#xff0c;并且支持多种协议和浏览器。IDM 通过将大文件分割成多个部分并同时下载这些部分来加快下载速度&#xff0c;这种技术被称为多线程下…

Linux中手工创建一个用户

当我们需要新创建一个用户时&#xff0c;有两种方法 1&#xff0c;使用useradd命令&#xff1a; [rootlocalhost /]# useradd tmg 然后给它设置一个密码 [rootlocalhost etc]# passwd tmg Changing password for user tmg. New password: BAD PASSWORD: The password is a…

通过 USB 或网络控制安卓设备:无需 root 权限 | 开源日报 No.231

barry-ran/QtScrcpy Stars: 15.6k License: Apache-2.0 QtScrcpy 是一款支持通过 USB 或网络显示和控制 Android 设备的实时显示控制软件&#xff0c;不需要 root 权限。 其主要功能和优势包括&#xff1a; 轻量化&#xff08;仅显示设备屏幕&#xff09;高性能&#xff08;3…

RAG:智能图书馆员引领AI的知识之旅

想象一下&#xff0c;你是一个法官&#xff0c;面对一个复杂的案件&#xff0c;你需要查阅大量的法律文献来找到相关的案例和法律条文。在AI的世界里&#xff0c;也有一个类似的“法官”——大型语言模型&#xff08;LLMs&#xff09;。它们能够回答各种问题&#xff0c;但有时…

vue 表格获取当前行索引,加颜色

vue 表格获取当前行索引&#xff0c;加颜色 <span styledisplay:inline-block;width:10px;height:10px;border-radius:50% :style"{background:color[scope.$index]}" />//定义颜色color: [#5387F7, #A794E0, #F3543C, #999999, #77D3F8, #FFA1B4, #26CEBA, #…

关于Linux系统的配置文件(UBOOT、Kernel、rootfs)

对于编译 U-Boot、内核和根文件系统&#xff0c;每个部分都需要相应的配置文件&#xff0c;这些配置文件指定了编译过程中的选项、参数和设置。以下是每个部分的配置文件中可能包含的内容&#xff1a; U-Boot 配置文件&#xff08;一般是 config.mk 或 defconfig 文件&#xf…