netty入门-5 ServerBootstrap与Bootstarp

前言

本来这篇应该紧接着说明FuturePromise
但是考虑前文第三篇即用到了ServerBootstrap来启动一个服务器,并且我读的闪电侠netty,先写的服务器与客户端启动这部分。索性就先写出来了。主要内容来自闪电侠netty

ServerBootstrap

ServerBootstrap就是一个辅助我们把服务器拉起来的辅助类,怎么用直接看下面。

服务器编写

解释全写在注释里,方便看。
示例程序是书里的。

public class NettyServer{public static  void  main(String[] args){//下面我们可以看到用了两个EventLoopGroup,一个作为boss,一个作为worker。//boss内的EventLoop负责处理连接请求。//worker中则是负责连接后的channel的io请求处理。NioEventLoopGroup  bossGroup  =  newNioEventLoopGroup();NioEventLoopGroup  workerGroup  =  newNioEventLoopGroup();ServerBootstrap  serverBootstrap  =  newServerBootstrap();serverBootstrap.group(bossGroup,  workerGroup)//给服务器指定boss和worker。两个线程组职能分离.channel(NioServerSocketChannel.class)//这里使用NIO类型的ServerSocketChannel。也有其他类型,不过常用NIO类型的。//childHandler之前第三篇文章说过,child指代ServerSocketChannel处理连接请求后产生的新的SocketChannel,所以childHandler表示对服务器连接的Channel添加的处理器。也即对Channel的数据读写如何进行处理。第三篇文章讲到了。.childHandler(newChannelInitializer<NioSocketChannel>(){protectedvoid  initChannel(NioSocketChannel  ch){}})//绑定一个端口serverBootstrap.bind(8000);}
}

梳理一下就是用ServerBootstrap 类,指定groupIo模型channel),写新连接的读写处理逻辑,绑定端口。

这里注意bind操作是一个异步操作
且我们要绑定的端口可能已经被其他应用占用了。所以需要我们递增寻找一个没有被占用的端口。
我们在第四篇文章中说到有这个ChannelFuture处理异步结果。
而这个bind也是一个异步操作,也会返回一个ChannelFuture
我们正好可以对bind操作产生的`ChannelFuture添加一个回调,来进行递增寻找端口的操作。

端口递增绑定

比如端口9000被占用了,我们要继续去bind 9001,直到找到一个可用端口。

//下面代码是一个框架,可以通过future的状态来做不同处理(关于future的状态,下篇来讲,这里可以理解为通过isSuccess()可以了解到bind操作是否成功)
//成功不用多说,失败了就要递增访问端口号。
serverBootstrap.bind(8000).addListener((ChannelFutureListener) future -> {if(future.isSuccess()){}else{serverBootstrap.bind(8001);}
})//书里这个代码挺妙的
//我们发现直接在else部分写一个bind操作似乎不行,因为这个bind操作做完失败的话我们就没有后续了。
//抽象一下,似乎无限复制代码在else部分再写一个bind(8000).addListener..,然后在其内部再写一个逻辑判断,再进行bind。
//失败就不断调用本身,递归思想private static void Bind(ServerBootstrap serverBootstrap, int port){serverBootstrap.bind(8000).addListener((ChannelFutureListener) future -> {if(future.isSuccess()){system.out.println("端口 " + port +"绑定成功" );}else{system.out.println("端口 " + port +"绑定失败" );Bind(serverBootstrap,port+1);	}})
} 

其他方法

这些方法课上确实没咋说,书里这里带了一笔。

//handler方法,和上文的childHandler一样,第三篇文章说到了。
//childHandler用于给新Channel指定读写操作的处理逻辑
//handler就是给服务器启动过程指定一些逻辑。通常用不到
serverBootstrap.handler(newChannelInitializer<NioServerSocketChannel>(){protected void initChannel(NioServerSocketChannel  ch)  {System.out.println("服务端启动中")}
})//attr和childAttr两个方法都是给Channel添加一个键值对。attr是给ServerSocketChannel的。childAttr是给所有正常连接channel的。
//即Channel内部会维护一个Map存储这些键值对。要取可以再用attr或者childAttr,根据键来取属性值
serverBootstrap.attr(AttributeKey.newInstance("serverName"),  "nettyServer")
serverBootstrap.childAttr(AttributeKey.newInstance("clientKey"),  "clientValue")//option和childOption方法是设置TCP参数的。
//同样一个针对ServerSocketChannel。childOption针对其他正常连接channel
//书中给了几个例子
serverBootstrap
//表示系统用于临时存放已完成三次握手的请求的队列的最大长度,如果连接建立频繁,服务器处理创建新连接较慢,则可以适当调大这个参数。
.option(ChannelOption.SO_BACKLOG,  1024)
//ChannelOption.SO_KEEPALIVE表示是否开启TCP底层心跳机制,true表示开启。
.childOption(ChannelOption.SO_KEEPALIVE,  true)
//ChannelOption.TCP_NODELAY表示是否开启Nagle算法,true表示关闭,false表示开启。通俗地说,如果要求高实时性,有数据发送时就马上发送,就设置为关闭;如果需要减少发送次数,减少网络交互,就设置为开启。
.childOption(ChannelOption.TCP_NODELAY,  true)

Bootstarp

ServerBootstrap类似,不过Bootstrap是用于启动客户端的辅助类。

客户端启动

同样是指定线程模型(group),IO模型(NioSocketChannel),IO操作处理逻辑(handler)。
其实同服务器启动基本一致。
不过这里书里提到了连接失败的重试处理。我们来看看

NioEventLoopGroup  workerGroup  =  newNioEventLoopGroup()Bootstrap  bootstrap  =  newBootstrap();
bootstrap
//  1.指定线程模型
.group(workerGroup)
//  2.指定IO  类型为NIO
.channel(NioSocketChannel.class)
//  3.IO 处理逻辑
.handler(newChannelInitializer<SocketChannel>(){@Overridepublicvoid  initChannel(SocketChannel  ch){}
});
//  4.建立连接
bootstrap.connect("juejin.cn",  80).addListener(future  ->if(future.isSuccess()){System.out.println("连接成功!");}else{System.err.println("连接失败!");}
});
//我们见到与上面服务器创建时,我们要做端口递增绑定类似的部分。
//这里原理类似,因为connect与bind都是异步方法,所以我们要写好异步回调,表明在异步操作成功后做什么,失败后做什么
//connect失败说明连接失败。我们可以用重试,一定次数后放弃连接,并且不会在失败后立即重连,指数增长重试事件,如1秒,2秒,4秒,8秒等。默认次数设为5次下面是实现逻辑。
//也采用封装一个递归函数来递归调用的方法。
private static void connect(Bootstrap bootstrap,String host,int port,int retry){bootstrap.connect(host,  port).addListener(future ->{if(future.isSuccess()){System.out.println("连接成功!");}else if(retry  ==  0) {System.err.println("重试次数已用完,放弃连接!");}else{//  第几次重连int  order  =  (MAX_RETRY  -  retry)  +  1;//  本次重连的间隔int  delay  =  1  <<  order;System.err.println(newDate()  +  ":连接失败,第"  +  order  +  "次重连……");bootstrap.config().group().schedule(()  ->  connect(bootstrap,  host,  port,retry--),  delay,  TimeUnit.SECONDS);}});
} 

上面代码比较好懂,
不过这里等待一定时间后执行任务的操作,即定时任务操作,用了bootstrap.config().group().schedule()来做。
group()返回我们配置的workerGroupschedule()正是其中的方法,来定时执行一个任务。
在上面最后的else中,根据剩余重试次数retry,来确定本次重试之前要等多长时间,即delay,再通过schedule()递归调用函数本身,不过递归函数的参数retry要减1,因为它代表剩余重试次数。

其他方法

ServerBootstrap一样,Bootstrap也有attr方法来给Channel设置键值对。不再赘述。
也有option方法来设置TCP参数。
书中给了如下参数

.option(ChannelOption.CONNECT_TIMEOUT_MILLIS,  5000)
.option(ChannelOption.SO_KEEPALIVE,  true)
.option(ChannelOption.TCP_NODELAY,  true)

ChannelOption.CONNECT_TIMEOUT_MILLIS表示连接的超时时间,超过这个时间,如果仍未连接到服务端,则表示连接失败。
ChannelOption.SO_KEEPALIVE表示是否开启TCP底层心跳机制,true表示开启。
ChannelOption.TCP_NODELAY表示是否开始Nagle算法,true表示关闭,false表示开启。通俗地说,如果要求高实时性,有数据发送时就马上发送,就设置为true;如果需要减少发送次数,减少网络交互,就设置为false

结语

本文内容均来自《跟着闪电侠学Netty》。
看了看书,感觉挺有帮助的。技术还是视频,书籍,源码,实践相辅相成好。

本篇仅是对ServerBootstrapBootstrap的补充说明,后续还会按视频课程的编排来写。中间穿插一些书中写到但是视频没有提到的东西。

下篇就是开头说要写的PromiseFuture了。篇幅应该不长,只写一点。
按顺序再后面应该是handlerpipeline,还有ByteBuf

这里稍微说下,这本书里的内容其实和课程中很多部分都是重复的,毕竟说的都是Netty吗。
然后我对比了一下二者的基础部分,书接下来讲的通信协议编解码,PipelineChannelHandler,粘包拆包,双向通信。实现一个简单群聊。这些视频同样讲到了。可能有几个章节是二者独有的。二者可以对比学习。效果应该会更好吧。

后面写我尽量结合两边来写。

感谢阅读,欢迎批评指正。

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

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

相关文章

LabVIEW和IQ测试仪进行WiFi测试

介绍一个使用LabVIEW和LitePoint IQxel-MW IQ测试仪进行WiFi测试的系统。包括具体的硬件型号、如何实现通讯、开发中需要注意的事项以及实现的功能。 使用的硬件​ IQ测试仪型号: LitePoint IQxel-MW 电脑: 配置高效的台式机或笔记本电脑 路由器: 支持802.11ax (Wi-Fi 6) 的…

C语言 | Leetcode C语言题解之第282题给表达式添加运算符

题目&#xff1a; 题解&#xff1a; #define MAX_COUNT 10000 // 解的个数足够大 #define NUM_COUNT 100 // 操作数的个数足够大 long long num[NUM_COUNT] {0};long long calc(char *a) { // 计算表达式a的值// 将数字和符号&#xff0c;入栈memset(num, 0, sizeof(num));in…

探索自注意力机制:目标检测领域的革新者

探索自注意力机制&#xff1a;目标检测领域的革新者 在深度学习的目标检测领域&#xff0c;自注意力机制&#xff08;Self-Attention Mechanism&#xff09;以其独特的能力&#xff0c;为处理图像中的目标提供了一种全新的视角。自注意力机制允许模型在处理图像时&#xff0c;…

Android MVVM最佳实践(LifecyclesRetrofit)

当结合MVVM架构、Lifecycle以及网络请求时&#xff0c;通常会使用Retrofit库来进行网络请求操作。以下是如何在Android应用中整合Retrofit进行网络请求&#xff0c;并与MVVM架构和Lifecycle结合的示例&#xff1a; 1. 添加依赖项 确保在项目的build.gradle文件中添加Retrofit…

开发环境搭建:步入C++编程世界的基石

在探索C++这一强大而灵活的编程语言时,搭建一个高效、舒适的开发环境是每位初学者的首要任务。开发环境不仅影响着编程的效率,还直接关系到编程体验和学习效果。本文将详细阐述如何为C++编程搭建一个全面的开发环境,从选择合适的IDE(集成开发环境)、配置编译器,到管理项目…

2024大家都想掌握的4种PDF翻译技巧

借着互联网的东风现在全球化的交流越发频繁&#xff0c;很多时候都会遇到跨语言交流的问题。外语不好的小伙伴阅读外国文献的时候应该都很头疼吧&#xff0c;这时候pdf翻译成中文的工具就可以解决这个问题啦。 1.福昕翻译 直通车&#xff1a;https://fanyi.pdf365.cn/ 这个…

@Builder注释导致@RequestBody的前端json反序列化失败,HTTP400

项目里发生了一个bug&#xff0c;就是前端请求一个接口时候&#xff0c;报了HTTP 400 Bad Request 通常来说这个问题是前后端的参数没对齐&#xff0c;比如前端传了个String&#xff0c;但后端对应的是Integer。 所以我就排查了半天&#xff0c;结果没发现啥错误&#xff0c;…

PSINS工具箱函数介绍——insplot

insplot是一个绘图命令,用于将avp数据绘制出来 本文所述的代码需要基于PSINS工具箱,工具箱的讲解: PSINS初学指导基于PSINS的相关程序设计(付费专题)使用方法 此函数使用起来也很简单,直接后面加avp即可,如: insplot(avp);其中,avp为: 每行表示一个时间1~3列为姿态…

量化交易策略解读

光大证券-20190606-重构情绪体系&#xff0c;探知市场温度——市场情绪体系系列报告之二.pdf 市场情绪与股市择时体系研究 市场情绪的重要性 市场情绪反映了投资者心理状态的集体体现&#xff0c;对市场走势有同步或滞后的影响&#xff0c;并在某些情况下预示市场转折点。 择…

一键解锁:科研服务器性能匹配秘籍,选择性能精准匹配科研任务和计算需求的服务器

一键解锁&#xff1a;科研服务器性能匹配秘籍 HPC科研工作站服务器集群细分领域迷途小书童 专注于HPC科研服务器细分领域kyfwq001 &#x1f3af;在当今科技飞速发展的时代&#xff0c;科研工作对计算资源的需求日益增长&#x1f61c;。选择性能精准匹配科研任务和计算需求的服…

力扣39题:组合总和的 Java 实现

引言 力扣&#xff08;LeetCode&#xff09;是一个在线编程平台&#xff0c;提供了大量的编程题目供开发者练习。第39题“组合总和”是一个经典的回溯算法问题&#xff0c;要求找出所有可能的组合&#xff0c;使得组合中的数字之和等于给定的目标值。本文将介绍如何使用 Java …

集合的面试题和五种集合的详细讲解

20240724 一、面试题节选二、来自于b站人人都是程序员的视频截图 &#xff08;感谢人人都是程序员大佬的视频&#xff0c;针对于个人复习。&#xff09; 一、面试题节选 二、来自于b站人人都是程序员的视频截图 hashmap&#xff1a; 唯一的缺点&#xff0c;无序&#xf…

maven项目容器化运行之3-优雅的利用Jenkins和maven使用docker插件调用远程docker构建服务并在1Panel中运行

一.背景 在《maven项目容器化运行之1》中&#xff0c;我们开启了1Panel环境中docker构建服务给到了局域网。在《maven项目容器化运行之2》中&#xff0c;我们基本实现了maven工程创建、远程调用docker构建镜像、在1Panel选择镜像运行容器三大步骤。 但是&#xff0c;存在一个问…

昇思25天学习打卡营第23天 | CycleGAN图像风格迁移互换

昇思25天学习打卡营第23天 | CycleGAN图像风格迁移互换 文章目录 昇思25天学习打卡营第23天 | CycleGAN图像风格迁移互换CycleGAN模型模型结构循环一致损失函数 数据集数据下载创建数据集 网络构建生成器判别器损失函数和优化器前向计算梯度计算与反向传播 总结打卡 CycleGAN模…

【办公软件】Office 2019以上版本PPT 做平滑切换

Office2019以上版本可以在切页面时做平滑切换&#xff0c;做到一些简单的动画效果。如下在快捷菜单栏中的切换里选择平滑。 比如&#xff0c;在两页PPT中&#xff0c;使用同一个形状对象&#xff0c;修改了大小和颜色。 选择切换为平滑后&#xff0c;可以完成如下的动画显示。 …

java-poi实现excel自定义注解生成数据并导出

因为项目很多地方需要使用导出数据excel的功能&#xff0c;所以开发了一个简易的统一生成导出方法。 依赖 <dependency> <groupId>org.apache.poi</groupId> <artifactId>poi-ooxml</artifactId> <version>4.0.1</version…

数学基础 -- 分段函数的导数

分段函数的导数 分段函数的导数是指分段函数在每一段上的导数情况&#xff0c;以及在分段点上的导数情况。具体可以通过以下步骤进行计算&#xff1a; 确定分段函数的定义&#xff1a;首先明确分段函数的每一段的表达式和对应的区间。 逐段求导&#xff1a;在每个区间内&…

【TortoiseGit】合并单个commit(提交)到指定分支上

0、前言 当我们用Git的时候经常用到多个分支&#xff0c;会经常有如下情况&#xff1a;一个dev分支下面会有多个test分支&#xff0c;而每个test分支由不同的开发者。而我们会有这样的需求&#xff1a; 当某个test分支完成了相应功能验证&#xff0c;就要把成功验证的功能代码…

智能卡芯片载带条带AOI外观检测设备及系统

智能卡及其芯片载带简介 我国智能卡产业的发展始于1993年的“金卡工程”&#xff0c;它是一项把货币电子化&#xff0c;运用芯片技术来搭载电子货币应用&#xff0c;运用互联网技术建立从发行到受理的电子货币系统&#xff0c;以提高社会运作效率&#xff0c;方便人们工作生活为…

多角度解析高防CDN防御DDOS及CC攻击

网络攻击的形式也日益多样化&#xff0c;其中DDoS&#xff08;分布式拒绝服务&#xff09;和CC&#xff08;Challenge Collapsar&#xff09;攻击尤为突出&#xff0c;给网站和企业带来了巨大的安全威胁。高防CDN&#xff08;Content Delivery Network&#xff09;作为一种专业…