netty系列(三)client启动

client启动:

server是在bootstrap.bind的时候启动,而同样,client是在bootstrap.connect时启动,流程都是一样的:创建NioSocketChannel,和workgroup中的一个eventloop绑定起来,然后再执行connect。

笔记:connect操作和write操作一样,都是客户端主动调用,然后write事件被丢到netty,而网络可读可写等事件则是由netty自动接收然后处不处理后再丢到pipeline,然后pipeline中的handler再调用我们的程序,也就是说前者是由netty外到netty内,后者是由netty内到netty外。
建议copy到本地阅读

BootStrap.connectBootStrap.doResolveAndConnectAbstractBootStrap.initAndRegister #创建NioSocketChannel并且注册到workgoup的某个eventloop线程对应的selector中,然后发送channelRegister事件,略BootStrap.doResolveAndConnect0    #执行连接操作BootStrap.doConnectAbstractChannel.connect       #这里就开始和NioServerSocketChannel的bind一样了,一路connect,最终来到java nio socket的connect#然后connect成功后再发送channelActive事件DefaultChannelPipeline.connectAbstractChannelHandlerContext.connect     #tail.connectAbstractChannelHandlerContext.connect   #重载AbstractChannelHandlerContext.invokeConnect #调用handler的connect函数MyHandler.connect                         #我们自定义的handler......HeadContext.connect                   #最终来到了headContext的connect,由此可见网络数据的进出都由headcontext负责#正因为数据进出都要通过connect,所以connect的时候从tail开始往前就可以理解了AbstractNioUnsafe.connect           #boolean connected = SocketUtils.connect  #调用java Nio 的connect,所以netty就是对java nio的一个封装if (!connected) {selectionKey().interestOps(SelectionKey.OP_CONNECT); #丢到eventloop,因为connect不一定立即成功}......略......NioEventLoop.processSelectedKey   #上一步我们向selector注册了OP_CONNECT事件,然后就进入eventloop循环了,#当connect成功以后就会唤醒selector,然后走select流程#直接来到这里processSelectedKey,前面的代码略if ((readyOps & SelectionKey.OP_CONNECT) != 0):k.interestOps                      #从selector中取消监听connect事件,因为channel连接只需要一次AbstractNioUnsafe.finishConnect AbstractNioUnsafe.fulfillConnectPromiseDeafultChannelPipeline.fireChannelActive  #连接成功以后把channelActive事件丢到pipeline,#然后后面就是pipeline的流程,即依次调用handler的channelActive方法,后续流程略

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

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

相关文章

[Python学习篇] Python函数

定义函数 语法:使用关键字 def def 函数名(参数): 代码1 代码2 ...... 调用函数 语法: 函数名(参数) 注意:不同的需求,参数可有可无。在Python中,函数必须先定义后使用 示例: # 定义函数 d…

Linux 程序打包

参考文献: Linux(ubuntu)下打包C代码并运行于其他ubuntu上linux C打包程序总结Linux shell 中获取当前目录的方法Linux shell路径变量出现空格时的处理方法 假设编译了一个 cmd 可执行文件,想要把它交给其他人运行。 找到动态库 首先新建一个文件夹 …

csdn如何建立专栏,并且把已发布的文章,放到专栏里

不会在csdn上建立专栏,管理自己的博客? 建立了专栏,不知道该怎么放入文章? 本文将一步步带你解决这些问题。 我是蚊子码农,欢迎各位的点赞、关注和收藏,有了你们的激励,我会带来更好的作品。…

聚焦 Navicat 17 新特性 | 让用户界面交互更丝滑

随着 Navicat 17 的发布,引起业界热烈反响和深入讨论。早前,我们介绍了 Navicat 17 《模型设计创新与优化​​​​​​​》与《查询与配置》的新特性。此外,Navicat 在用户界面交互方面进行了显著优化,新增了一系列实用的功能&…

(javascript)为什么await在forEach中不生效?

转载:为啥await在forEach中不生效?-腾讯云开发者社区-腾讯云 (tencent.com) 两天要写循环遍历请求接口,于是就在forEach中用到了await,但是根本不是我想要的啊! 于是各种查,各种搜,终于有点明…

《后端程序猿 · 基于 Lettuce 实现缓存容错策略》

📢 大家好,我是 【战神刘玉栋】,有10多年的研发经验,致力于前后端技术栈的知识沉淀和传播。 💗 🌻 近期刚转战 CSDN,会严格把控文章质量,绝不滥竽充数,如需交流&#xff…

机器学习辅助的乙醇浓度检测

目录 1.为什么要机器学习 2. 神经网络一般组成 3.BP神经网络工作过程 4.评价指标 5.实操代码 1.为什么要用机器学习 人工分析大量的谐振模式,建立各种WGM的响应与未知目标之间的关系,是一个很大的挑战。机器学习(ML)能够自行识别全谱的全部特征。作为…

如何在Lazada平台快速出单?测评助力商家突破销量瓶颈

Lazada在短短的几年里已经发展成了东南亚地区最大的在线购物网站之一 ,很多商家也想要在这样一个大的跨境平台上发展。那么,对于希望在Lazada平台上大展拳脚的商家而言,出单是否容易呢? ​一、Lazada出单容易吗? Lazada出单的难易程度并非…

漫步5G-A City,一份独属于上海的浪漫

作家亨利詹姆斯曾写道,“城市漫步,让我接触到了这个世界上最好的东西”。 用漫无目的地行走,来体验和观察一座城市,上海凭借丰富多元的文化特质,成为citywalk这种浪漫生活方式的流行地。 无论你是漫步在美术馆、画廊林…

数据抓取技术在视频内容监控与快速读取中的应用

引言 在数字化时代,视频内容的快速读取和监控对于内容提供商来说至关重要。思通数科的OPEN-SPIDER抓取技术为这一需求提供了高效的解决方案。 OPEN-SPIDER技术概述 OPEN-SPIDER是思通数科开发的一种先进的数据抓取技术,它能够: - 高效地从各…

ananconda 和 pip傻傻分不清???

Anaconda 和 pip 都是 Python 编程语言中用于管理包(libraries)和环境的工具,但它们在功能和设计理念上有所不同。 Anaconda Anaconda 是一个面向科学计算的发行版,包括了 Python 语言和许多常用的科学计算及数据分析库。Anacon…

Stable Diffusion【基础篇】:降噪强度(denoising strength)

提到降噪强度(denoising strength),大家一定不会陌生,这个参数是图生图中最关键的参数之一。今天在Stable Diffusion Art网站看到一篇介绍降噪强度(denoising strength)的文章(地址:…

uniapp返回上一页并传递参数,上一页接收参数并刷新数据

因为navigateBack不支持携带参数,所以只能触发一个自定义事件,并传递参数 params 给上一页。 // 触发自定义事件,并返回上一页 uni.$emit(refreshPreviousPage, params); //返回上一页 uni.navigateBack({ delta: 1 }); 在上一页的 onShow …

vcanfd配置与使用

canfd CAN FD (Controller Area Network Flexible Data-rate) 是传统 CAN (Controller Area Network) 的升级版本,旨在满足现代汽车电子系统和工业自动化中对更高数据速率和更大数据负载的需求。以下是对 CAN FD 的详细介绍: CAN 和 CAN FD 的背景 CA…

从hugging face 下模型

支持国内下载hugging face 的东西 下模型权重 model_id 是红色圈复制的 代码 记得设置下载的存储位置 import os from pathlib import Path from huggingface_hub import hf_hub_download from huggingface_hub import snapshot_downloadmodel_id"llava-hf/llava-v1…

C#——MD5 base64加密-base64加密解密

MD5 base64加密 在C#中,MD5是一个不可逆的加密算法,因为它是散列函数,用于创建信息的唯一指纹(也称为摘要)。不过,可以使用MD5进行加密,然后使用Base64对结果进行编码。但是,请注意…

[AI Perplexica] 深入解析,AI 架构揭秘

[AI Perplexica] AI驱动的开源搜索引擎 上一篇文章,我们对 Perplexica 做了个基本介绍,包括特点,以及如何安装。 今天,我们来深入看下 Perplexica 的架构。 Perplexica 的架构 Perplexica 的架构由以下关键组件组成&#xff1…

(2024)docker-compose实战 (8)部署LAMP项目(最终版)

前言 在前一篇文章中, 我们已经搭建LAMP环境, 但php没有安装扩展, 这篇文章将安装PHP扩展, 实现正常的PHP项目部署我在git中查找到一个简易安装PHP扩展的方法(GitHub - mlocati/docker-php-extension-installer: Easily install PHP extensions in Docker containers).通过这个…

MySQL 忘记了密码怎么办?

如果 MySQL 普通账户忘记了密码,很容易解决,可以通过登录 root 账户来重置普通账户密码。然而,如果 root 账户的密码也忘记或丢失了,该怎么办呢? 这篇文章将教你如何重置 root 账户密码,亲测有效。 版本&…

【Python机器学习】模型评估与改进——二分类指标

目录 1、错误类型 2、不平衡数据集 3、混淆矩阵 与精度的关系。 准确率、召回率与f-分数 分类报告 4、考虑不确定性 5、准确率-召回率曲线 6、受试者工作特征(ROC)与AUC 二分类可能是实践中最常见的机器学习应用,也是概念最简单的应…