蚌埠网站建设/网站推广120种方法

蚌埠网站建设,网站推广120种方法,软文营销的作用,如何建设一个生活服务网站文章目录 概述源码分析小结 概述 ServerBootstrap bootstrap new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024).childHandler(new ChannelInitializer<SocketChannel>() …

文章目录

  • 概述
  • 源码分析
  • 小结

在这里插入图片描述

在这里插入图片描述

概述

在这里插入图片描述

   ServerBootstrap bootstrap = new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();//加入特殊分隔符分包解码器pipeline.addLast(new DelimiterBasedFrameDecoder(10240, Unpooled.copiedBuffer("_".getBytes())));//向pipeline加入解码器pipeline.addLast("decoder", new StringDecoder());//向pipeline加入编码器pipeline.addLast("encoder", new StringEncoder());//加入自己的业务处理handlerpipeline.addLast(new ChatServerHandler());}});

这段代码使用Netty构建了一个服务器。

  1. ServerBootstrap bootstrap = new ServerBootstrap(); - 创建一个ServerBootstrap实例，用于启动服务器。

  2. bootstrap.group(bossGroup, workerGroup) - 指定了服务器使用的两个EventLoopGroup，分别是bossGroup和workerGroup。其中，bossGroup用于接受传入的连接，而workerGroup用于处理已接受连接的流量。

  3. bootstrap.channel(NioServerSocketChannel.class) - 指定了服务器的Channel类型为NioServerSocketChannel，这表示使用NIO进行网络通信。

  4. bootstrap.option(ChannelOption.SO_BACKLOG, 1024) - 设置服务器的配置选项。在这里，设置了SO_BACKLOG，表示服务器套接字的连接队列大小为1024。

  5. bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {...}) - 指定了当一个新的连接被接受时，所要执行的ChannelInitializer。这个匿名内部类用于配置新接受的Channel的ChannelPipeline，即为每个新接受的连接设置处理器。

  6. pipeline.addLast(new DelimiterBasedFrameDecoder(10240, Unpooled.copiedBuffer("_".getBytes()))) - 向ChannelPipeline中添加了一个DelimiterBasedFrameDecoder，用于根据特殊分隔符进行分包解码，这里的特殊分隔符是下划线"_”。

  7. pipeline.addLast("decoder", new StringDecoder()) - 向ChannelPipeline中添加了一个StringDecoder，用于将接收到的ByteBuf解码为字符串。

  8. pipeline.addLast("encoder", new StringEncoder()) - 向ChannelPipeline中添加了一个StringEncoder，用于将字符串编码为ByteBuf。

  9. pipeline.addLast(new ChatServerHandler()) - 向ChannelPipeline中添加了一个ChatServerHandler，这是自定义的业务处理Handler，用于处理接收到的消息。

总的来说，这段代码创建了一个基于Netty的服务器，配置了服务器的事件处理流程，包括接受连接、解码、编码和业务处理。

源码分析

ServerBootstrap bootstrap = new ServerBootstrap();

ServerBootstrap类的构造函数。在这个构造函数中，没有参数，它是一个默认构造函数。

bootstrap.group(bossGroup, workerGroup)

这段代码是ServerBootstrap类中的group方法的实现。

/*** Set the {@link EventLoopGroup} for the parent (acceptor) and the child (client). These* {@link EventLoopGroup}'s are used to handle all the events and IO for {@link ServerChannel} and* {@link Channel}'s.*/
public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) {// 调用父类的group方法，设置父EventLoopGroupsuper.group(parentGroup);// 检查子EventLoopGroup是否为空，如果为空则抛出NullPointerExceptionif (childGroup == null) {throw new NullPointerException("childGroup");}// 检查是否已经设置了子EventLoopGroup，如果已经设置了则抛出IllegalStateExceptionif (this.childGroup != null) {throw new IllegalStateException("childGroup set already");}// 将传入的子EventLoopGroup赋值给成员变量childGroupthis.childGroup = childGroup;// 返回ServerBootstrap实例，用于链式调用return this;
}

这段代码的作用是设置ServerBootstrap的父（acceptor）和子（client）EventLoopGroup。这两个EventLoopGroup分别用于处理服务器端（acceptor）和客户端（client）的事件和IO操作。具体来说，这个方法会将传入的父EventLoopGroup设置给父类AbstractBootstrap，并将传入的子EventLoopGroup赋值给ServerBootstrap的成员变量childGroup。

在方法的实现中，

  • 首先调用了父类的group方法来设置父EventLoopGroup。
  • 然后，检查传入的子EventLoopGroup是否为空，如果为空则抛出NullPointerException。接着，检查是否已经设置了子EventLoopGroup，如果已经设置了则抛出IllegalStateException。
  • -最后，将传入的子EventLoopGroup赋值给成员变量childGroup，并返回ServerBootstrap实例，以支持链式调用。

总的来说，这段代码的目的是为ServerBootstrap设置父和子EventLoopGroup，以便于处理服务器和客户端的事件和IO操作，并提供了异常处理机制以确保参数的有效性。

我们看下 调用父类的group方法，设置父EventLoopGroup

super.group(parentGroup);

这段代码是一个泛型方法，通常用于在Netty的Bootstrap或ServerBootstrap中设置用于处理事件的EventLoopGroup。

/*** The {@link EventLoopGroup} which is used to handle all the events for the to-be-created* {@link Channel}*/
public B group(EventLoopGroup group) {// 检查传入的EventLoopGroup是否为空，如果为空则抛出NullPointerExceptionif (group == null) {throw new NullPointerException("group");}// 检查是否已经设置了EventLoopGroup，如果已经设置了则抛出IllegalStateExceptionif (this.group != null) {throw new IllegalStateException("group set already");}// 将传入的EventLoopGroup赋值给成员变量groupthis.group = group;// 返回调用该方法的实例，以支持链式调用return self();
}

这个方法主要用于设置用于处理事件的EventLoopGroup，它会将传入的EventLoopGroup赋值给成员变量group。

在方法的实现中，

  • 首先检查传入的EventLoopGroup是否为空，如果为空则抛出NullPointerException。
  • 然后，检查是否已经设置了EventLoopGroup，如果已经设置了则抛出IllegalStateException。
  • 最后，将传入的EventLoopGroup赋值给成员变量group，并返回调用该方法的实例，以支持链式调用。

总的来说，这段代码的作用是为Netty的Bootstrap或ServerBootstrap设置EventLoopGroup，以便于处理事件，并提供了异常处理机制以确保参数的有效性。

channel(NioServerSocketChannel.class)

这段代码是一个泛型方法，用于设置用于创建Channel实例的Class对象。

/*** The {@link Class} which is used to create {@link Channel} instances from.* You either use this or {@link #channelFactory(io.netty.channel.ChannelFactory)} if your* {@link Channel} implementation has no no-args constructor.*/
public B channel(Class<? extends C> channelClass) {// 检查传入的channelClass是否为空，如果为空则抛出NullPointerExceptionif (channelClass == null) {throw new NullPointerException("channelClass");}// 调用channelFactory方法，传入一个ReflectiveChannelFactory实例，该实例用于通过反射创建Channel实例return channelFactory(new ReflectiveChannelFactory<C>(channelClass));
}

这个方法主要用于设置用于创建Channel实例的Class对象。它接受一个Class对象作为参数，并将其传递给channelFactory方法。

在这个方法内部，会创建一个ReflectiveChannelFactory实例，并将传入的Class对象作为参数传递给它。

在方法的实现中，

  • 首先检查传入的channelClass是否为空，如果为空则抛出NullPointerException。
  • 然后，创建一个ReflectiveChannelFactory实例，并将传入的Class对象作为参数传递给它。
  • 最后，调用channelFactory方法，将ReflectiveChannelFactory实例传递给它，并返回调用该方法的实例，以支持链式调用。

总的来说，这段代码的作用是为Netty的Bootstrap或ServerBootstrap设置用于创建Channel实例的Class对象，并提供了异常处理机制以确保参数的有效性。

new ReflectiveChannelFactory<C>(channelClass)

这段代码是ReflectiveChannelFactory类的构造函数实现。它接受一个Class对象作为参数，并使用反射机制获取该类的公共无参数构造方法。让我们逐步解释它：

public ReflectiveChannelFactory(Class<? extends T> clazz) {// 检查传入的clazz是否为空，如果为空则抛出NullPointerExceptionObjectUtil.checkNotNull(clazz, "clazz");try {// 使用反射获取传入的类的公共无参数构造方法this.constructor = clazz.getConstructor();} catch (NoSuchMethodException e) {// 如果获取构造方法失败，则抛出IllegalArgumentException异常throw new IllegalArgumentException("Class " + StringUtil.simpleClassName(clazz) +" does not have a public non-arg constructor", e);}
}

这个构造函数的作用是初始化ReflectiveChannelFactory实例。

它接受一个Class对象作为参数，该Class对象表示要实例化的Channel类。在构造函数内部，

  • 首先检查传入的Class对象是否为空，如果为空则抛出NullPointerException。
  • 然后，使用反射机制尝试获取传入类的公共无参数构造方法。如果获取构造方法失败，则抛出IllegalArgumentException异常，指示传入的类没有公共无参数构造方法。

总的来说，这段代码的作用是为ReflectiveChannelFactory类创建一个实例，并在构造函数中使用反射机制获取要实例化的Channel类的构造方法。

在这里插入图片描述

@Override
public T newChannel() {try {// 使用之前获取的构造方法实例化新的Channel对象return constructor.newInstance();} catch (Throwable t) {// 如果实例化过程中出现异常，则抛出ChannelException异常throw new ChannelException("Unable to create Channel from class " + constructor.getDeclaringClass(), t);}
}
/*** @deprecated Use {@link #channelFactory(io.netty.channel.ChannelFactory)} instead.*/
@Deprecated
public B channelFactory(ChannelFactory<? extends C> channelFactory) {// 检查传入的channelFactory是否为空，如果为空则抛出NullPointerExceptionif (channelFactory == null) {throw new NullPointerException("channelFactory");}// 检查是否已经设置了channelFactory，如果已经设置了则抛出IllegalStateExceptionif (this.channelFactory != null) {throw new IllegalStateException("channelFactory set already");}// 将传入的channelFactory赋值给成员变量channelFactorythis.channelFactory = channelFactory;return self();
}

在这里插入图片描述

option(ChannelOption.SO_BACKLOG, 1024)

这段代码定义了一个方法，用于为创建的Channel实例设置ChannelOption。

/*** Allow to specify a {@link ChannelOption} which is used for the {@link Channel} instances once they got* created. Use a value of {@code null} to remove a previous set {@link ChannelOption}.*/
public <T> B option(ChannelOption<T> option, T value) {// 检查传入的option是否为空，如果为空则抛出NullPointerExceptionif (option == null) {throw new NullPointerException("option");}// 如果value为空，则从options中移除之前设置的optionif (value == null) {synchronized (options) {options.remove(option);}} else {// 否则，将option和对应的value放入options中synchronized (options) {options.put(option, value);}}// 返回调用该方法的实例，以支持链式调用return self();
}

这个方法的作用是允许指定一个ChannelOption，该选项在创建Channel实例后使用。如果value为null，则表示要移除之前设置的ChannelOption。否则，将option和对应的value放入options中。

在方法的实现中，

  • 首先检查传入的option是否为空，如果为空则抛出NullPointerException。
  • 然后，如果value为null，则从options中移除之前设置的option；否则，将option和对应的value放入options中。
  • 最后，返回调用该方法的实例，以支持链式调用。

这个方法的灵活性在于它允许用户根据需要设置或删除特定的ChannelOption，以满足不同场景的需求。

在这里插入图片描述

childHandler()

这段代码定义了一个方法，用于设置用于处理连接到ServerBootstrap的每个子Channel的ChannelHandler。

/*** Set the {@link ChannelHandler} which is used to serve the request for the {@link Channel}'s.*/
public ServerBootstrap childHandler(ChannelHandler childHandler) {// 检查传入的childHandler是否为空，如果为空则抛出NullPointerExceptionif (childHandler == null) {throw new NullPointerException("childHandler");}// 将传入的childHandler赋值给成员变量childHandlerthis.childHandler = childHandler;// 返回ServerBootstrap实例，以支持链式调用return this;
}

这个方法的作用是设置用于处理连接到ServerBootstrap的每个子Channel的ChannelHandler。传入的ChannelHandler将会被添加到每个新创建的子Channel的ChannelPipeline中，用于处理该子Channel的所有事件。

在方法的实现中，

  • 首先检查传入的childHandler是否为空，如果为空则抛出NullPointerException。
  • 然后，将传入的childHandler赋值给成员变量childHandler。
  • 最后，返回ServerBootstrap实例，以支持链式调用。

这种设计模式允许用户通过链式调用一系列方法来配置ServerBootstrap的参数，从而更加简洁和灵活地构建Netty服务器。

小结

ServerBootstrap是Netty中用于创建服务器端应用程序的引导类。它的设计目的是提供一种简洁、灵活的方式来配置和启动服务器，并处理与客户端的连接。

以下是ServerBootstrap的设计要点总结：

  1. 引导配置链式调用：ServerBootstrap类提供了一系列方法，允许用户通过链式调用来配置服务器的各种参数，如设置EventLoopGroup、Channel类型、Channel选项、ChannelHandler等。这种设计模式使得配置过程更加简洁和灵活。

  2. EventLoopGroup的配置：通过group方法，用户可以设置用于处理服务器端连接和客户端连接的EventLoopGroup。通常，一个用于接受连接的bossGroup和一个用于处理连接请求的workerGroup会被设置。

  3. Channel类型的设置：用户可以通过channel方法设置用于创建Channel实例的类型，例如NioServerSocketChannel.class。这决定了服务器将使用的底层传输协议。

  4. Channel选项的设置：option/childOption方法允许用户为创建的Channel实例设置各种选项，如SO_BACKLOG、TCP_NODELAY等。

  5. ChannelHandler的配置：通过childHandler方法，用户可以设置用于处理连接到服务器的每个子Channel的ChannelHandler。这些ChannelHandler将被添加到每个新创建的子Channel的ChannelPipeline中，用于处理子Channel的所有事件。

  6. 灵活性和可扩展性：ServerBootstrap的设计允许用户根据具体需求灵活地配置服务器的各种参数，同时也提供了可扩展的接口和回调机制，使得用户可以根据需要自定义处理逻辑。

总的来说，ServerBootstrap的设计通过提供一系列简洁而灵活的配置方法，以及可扩展的接口和回调机制，使得用户能够轻松地构建高性能、可定制的服务器应用程序。
在这里插入图片描述

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

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

相关文章

微信小程序（四十二）wechat-http拦截器

微信小程序（四十二）wechat-http拦截器

注释很详细&#xff0c;直接上代码 上一篇 新增内容&#xff1a; 1.wechat-http请求的封装 2.wechat-http请求的拦截器的用法演示 源码&#xff1a; utils/http.js import http from "wechat-http"//设置全局默认请求地址 http.baseURL "https://live-api.ith…
阅读更多...
HCIA-HarmonyOS设备开发认证V2.0-3.2.轻量系统内核基础-中断管理

HCIA-HarmonyOS设备开发认证V2.0-3.2.轻量系统内核基础-中断管理

目录 一、中断基础概念二、中断管理使用说明三、中断管理模块接口四、代码分析&#xff08;待续...&#xff09; 一、中断基础概念 在程序运行过程中&#xff0c;出现需要由 CPU 立即处理的事务时&#xff0c;CPU 暂时中止当前程序的执行转而处理这个事务&#xff0c;这个过程…
阅读更多...
指纹浏览器如何颠覆传统浏览器的使用？

指纹浏览器如何颠覆传统浏览器的使用？

传统浏览器在互联网时代发挥了巨大的作用&#xff0c;但随着科技的不断进步和用户需求的不断变化&#xff0c;新一代的浏览器工具开始崭露头角。指纹浏览器作为一种创新性的浏览器工具&#xff0c;正逐渐颠覆传统浏览器的使用方式。本文将探讨指纹浏览器如何颠覆传统浏览器&…
阅读更多...
【蓝桥杯单片机记录】IO基础与LED控制

【蓝桥杯单片机记录】IO基础与LED控制

目录 一、IO基础 1.1 IAP15F2K61S2芯片原理图 1.2不同工作模式 二、新建工程的一些补充 2.1 keil中没有IAP15F2K61S2的头文件 解决&#xff1a;在isp软件中找到如下​编辑 2.2keil中的芯片选择 2.3推荐字体 三、sbit关键字 四、LED控制 4.1原理图 4.2不能直接通过IO…
阅读更多...
unity2017 遇到visual studio 2017(社区版) 30日试用期到了

unity2017 遇到visual studio 2017(社区版) 30日试用期到了

安装unity2017 遇到visual studio 2017 30日试用期到了&#xff0c;网上百度搜了好多方法都没有成功。 最后用了这个方法&#xff1a; 1)启动vs2017&#xff0c;在弹出要登录的窗口之前&#xff0c;迅速的点击工具-》选项-》账户&#xff0c;勾选在添加账户或对账户重新进行身…
阅读更多...
origin技巧

origin技巧

origin技巧 1.去掉白边2.曲线平滑3.合并多层图例3.图例换方向 1.去掉白边 ctrlu 2.曲线平滑 3.合并多层图例 3.图例换方向 图例右键 “图例” 水平排布修改图例字&#xff1a;双击图例修改 https://blog.csdn.net/m0_47746156/article/details/121295151 https://blog.csdn.…
阅读更多...
MacOS - 菜单栏上显示『音量』

MacOS - 菜单栏上显示『音量』

教程步骤 点击打开系统偏好『设置』&#xff0c;并找到『控制中心』 在『控制中心模块』找到『声音』&#xff0c;选择『始终在菜单栏显示』
阅读更多...
1g的视频怎么压缩到200m？3个步骤解决~

1g的视频怎么压缩到200m？3个步骤解决~

把1G的文件压缩到200M&#xff0c;可以有效节省存储空间&#xff0c;加快传输速度&#xff0c;在某些情况下&#xff0c;压缩文件可以提供更好的安全性&#xff0c;例如通过加密或压缩算法保护文件内容。下面就向大家介绍3个好用的方法。 方法一&#xff1a;使用嗨格式压缩大师…
阅读更多...
游泳可以戴的耳机有哪些，游泳耳机哪个牌子好性价比高

游泳可以戴的耳机有哪些，游泳耳机哪个牌子好性价比高

在游泳训练中&#xff0c;尤其是在进行长距离游泳、控制节奏和进行长时间游泳燃脂时&#xff0c;很容易感到单调乏味。为了帮助自己完成每一个来回&#xff0c;许多游泳运动员除了依赖能量棒和功能饮料外&#xff0c;还会选择通过音乐提高注意力和兴奋度。研究表明&#xff0c;…
阅读更多...
2.11日学习打卡----初学RocketMQ（二）

2.11日学习打卡----初学RocketMQ（二）

2.11日学习打卡 一. RocketMQ整合springboot 首先配置pom.xml文件 <dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><scope>annotationProcessor</scope></dependency><dependency>…
阅读更多...
记录一下，我使用stm32实现pwm波输入，以及对频率和占空比的计算，同时通过串口输出（实现-重要）

记录一下，我使用stm32实现pwm波输入，以及对频率和占空比的计算，同时通过串口输出（实现-重要）

1&#xff0c;首先看下半物理仿真 看下我的配置&#xff1a; 看下计算方法以及matlab的仿真输出的数据&#xff1a; timer3的ch2是选择高电平&#xff0c;计算频率 timer3的ch1是选择的是低电平&#xff0c;用来计算周期 其中TemPIpre表示的是CH2输出的值&#xff0c; TemPI…
阅读更多...
用HTML5 + JavaScript绘制花、树

用HTML5 + JavaScript绘制花、树

用HTML5 JavaScript绘制花、树 <canvas>是一个可以使用脚本 (通常为JavaScript) 来绘制图形的 HTML 元素。 <canvas> 标签/元素只是图形容器&#xff0c;必须使用脚本来绘制图形。 HTML5 canvas 图形标签基础https://blog.csdn.net/cnds123/article/details/112…
阅读更多...
Linux--常用命令（详解）

Linux--常用命令（详解）

详细目录 一、终端命令格式二、显示文件列表命令-ls2.1作用2.2格式2.3 ls常用选项2.3.1 ls -a2.3.2 ls -l(等价于 ll)2.3.2 ls -h 三、相对路径与绝对路径3.1绝对路径3.2相对路径 四、目录操作命令 -cd4.1作用4.2格式4.3案例4.3.1 cd -&#xff1a; 返回上一次所在目录4.3.2 cd…
阅读更多...
使用maven命令安装Oracle的jar包到本地仓库

使用maven命令安装Oracle的jar包到本地仓库

mvn install:install-file -DgroupIdcom.oracle -DartifactIdojdbc6 -Dversion11.2.0.4 -Dpackagingjar -DfileD:\ojdbc6-11.2.0.4.jar ojdbc6-11.2.0.4.jar 下载 链接&#xff1a;https://pan.baidu.com/s/1SqO3Ug7KF8kGr9-jOy3MJQ 提取码&#xff1a;36p9
阅读更多...
「Linux」用户操作

「Linux」用户操作

root用户 su&#xff1a;切换账户 语法&#xff1a;su [–] [用户名] -&#xff1a;可选&#xff0c;表示是否在切换用户后加载环境变量&#xff0c;建议带上用户名&#xff1a;表示要切换的用户&#xff0c;省略时表示切换到root切换用户后&#xff0c;通过exit命令退回上一个…
阅读更多...
服务异步通信

服务异步通信

服务异步通信 消息队列在使用过程中&#xff0c;面临着很多实际问题需要思考&#xff1a; 1.消息可靠性 消息从发送&#xff0c;到消费者接收&#xff0c;会经理多个过程&#xff1a; 其中的每一步都可能导致消息丢失&#xff0c;常见的丢失原因包括&#xff1a; 发送时丢失…
阅读更多...
CTFSHOW web 89-100

CTFSHOW web 89-100

这边建议去我的gitbook或者github看观感更好（图片更完整） github:https://github.com/kakaandhanhan/cybersecurity_knowledge_book-gitbook.22kaka.fun gitbook:http://22kaka.fun 🏈 CTFSHOW PHP特性 （1）WEB 89 ①代码解释 <?php/* # -*- coding: utf-8 -*- # @…
阅读更多...
第二篇【传奇开心果微博系列】Python微项目技术点案例示例：成语接龙游戏

第二篇【传奇开心果微博系列】Python微项目技术点案例示例：成语接龙游戏

传奇开心果微博系列 系列微博目录Python微项目技术点案例示例系列 微博目录一、微项目目标二、雏形示例代码三、扩展整体思路四、玩家输入示例代码五、成语判断示例代码六、回答判断示例代码七、电脑判断示例代码八、游戏结束示例代码九、界面优化示例代码十、扩展成语库示例代…
阅读更多...
面试经典150题——长度最小的子数组

面试经典150题——长度最小的子数组

​"In the midst of winter, I found there was, within me, an invincible summer." - Albert Camus 1. 题目描述 2. 题目分析与解析 首先理解题意&#xff0c;题目要求我们找到一个长度最小的 连续子数组 满足他们的和大于target&#xff0c;需要返回的是子数组的…
阅读更多...
架构篇34：深入理解微服务架构 - 银弹 or 焦油坑？

架构篇34：深入理解微服务架构 - 银弹 or 焦油坑？

文章目录 微服务与 SOA 的关系微服务的陷阱小结 微服务是近几年非常火热的架构设计理念&#xff0c;大部分人认为是 Martin Fowler 提出了微服务概念&#xff0c;但事实上微服务概念的历史要早得多&#xff0c;也不是 Martin Fowler 创造出来的&#xff0c;Martin 只是将微服务…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023