Day18_Netty

news2024/9/26 1:24:27

文章目录

  • Netty
      • IO 模型
      • Java有哪些数据类型
      • 零拷贝
      • 深拷贝和浅拷贝的区别是什么?
      • BIO、NIO、AIO的区别是什么?
      • Netty 是什么?
      • Netty 基于 NIO,那为啥不直接用 NIO 呢? / 为什么要用 Netty?
      • Netty 应用场景了解么?
      • 那些开源项目用到了 Netty?
      • Netty的核心组件是什么?
      • 请解释Netty的事件模型是什么样的。
      • 什么是Channel和ChannelPipeline?
      • Netty的ByteBuf是什么,有什么优势?
      • Netty支持哪些协议?
      • 什么是编解码器(Codec)?Netty中有哪些内置的编解码器?
      • Netty的线程模型是什么?为什么它是高效的?
      • Netty 中的线程模型有哪几种?
      • 什么是EventLoop,它的作用是什么?
      • NioEventLoopGroup 默认的构造函数会起多少线程呢?
      • ChannelFuture
      • 如何优化Netty应用的性能?
      • Netty如何处理安全性问题?
      • Netty如何支持WebSocket?
      • Netty对HTTP/2的支持是怎样的?
      • 请分享一下你在项目中使用Netty的经验。
      • Netty如何处理粘包和拆包问题?
      • Netty中的ChannelHandlerContext的作用是什么?
      • 有没有使用Netty实现过高性能的网络应用?
      • Reactor模型
      • Netty 服务端和客户端的启动过程了解么?
      • Netty 长连接、心跳机制了解么?
      • Netty 的零拷贝了解么?
      • 如何将长链接转换成短链接,并发送短信?
      • 长链接和短链接如何互相转换?
      • 长链接和短链接的对应关系如何存储?

Netty

IO 模型

UNIX 系统下, IO 模型一共有 5 种: 同步阻塞 I/O、同步非阻塞 I/O、I/O 多路复用、信号驱动 I/O 和
异步 I/O。

BIO:属于同步阻塞 IO 模型 。数据的读取写入必须阻塞在一个线程内等待其完成。
NIO:属于同步非阻塞的 I/O模型。提供了 Channel , Selector,Buffer 等抽象。NIO 提供了与传统 BIO 模型中的Socket 和 ServerSocket 相对应的 SocketChannel 和 ServerSocketChannel 两种不同的套接字通道实现,两种通道都支持阻塞和非阻塞两种模式。对于高负载、高并发的(网络)应用,应使用NIO 的非阻塞模式来开发
AIO:(Asynchronous I/O)异步的IO模型。应用操作之后会直接返回,不会堵塞在那里,当后台处理完成,操作系统会通知相应的线程进行后续的操作。目前来说 AIO 的应用还不是很广泛。Netty 之前也尝试使用过 AIO,不过又放弃了。这是因为,Netty使用了 AIO 之后,在 Linux 系统上的性能并没有多少提升。

5种阻塞模型:同步阻塞、同步非阻塞、同步多路复用、异步阻塞(没有此情况)、异步非阻塞

  • 同步:线程自己从头到尾自己把活干完
  • 异步:至少有两个线程的情况下,让另一个线程干活然后把结果告诉你

阻塞 IO:等待数据阶段用户线程被阻塞了,等待数据期间什么活都干不了只能被阻塞在那里

假设你是一个餐厅的服务员,你正在等厨师做好一道菜给顾客。在厨师做菜的过程中,你什么都做不了,只能干等着,直到菜做好了你才能继续服务下一位顾客。这就是阻塞IO,你的工作(服务员的工作)被阻塞在了等待厨师做菜(IO操作)上

非阻塞 IO:等待数据阶段用户线程运行着干其它活

假设你是一个餐厅的服务员,你告诉厨师顾客要什么菜,然后你就去忙其他事情了(比如接待其他顾客)。每隔一段时间,你就去问一下厨师你的菜好了没有。这种方式虽然不会让你一直等着,但你需要不断地去询问,也就是“轮询”,这会消耗你的时间和精力(CPU资源)。

多路复用:有一个selector专门负责监视多个IO操作然后及时反馈给当前线程,以便于当前线程可以专心搞其它事情

现在有一个多路复用器来帮你管理多个订餐请求。你告诉多路复用器你想要哪些餐厅的哪些菜,然后你就去忙其他事情了。多路复用器会帮你盯着这些餐厅,一旦有餐好了,他就会通知你来取。这样,你既可以处理多个订餐请求,又不需要一直等着或不断地去询问,大大提高了效率。
阻塞IO:是一个线程在干活,干活期间不能干别的活,是同步的,所以叫做同步阻塞

非阻塞IO:也是一个线程在干活,只不过干活期间可以干别的活,所以也是同步的,所以叫同步非阻塞

多路复用:多路复用本质也是当前这一个线程在干活,所以它也是同步的,所以叫同步多路复用

异步阻塞(没有此情况)

异步非阻塞:有两个线程在干活,让另一个线程干活然后把结果告诉你

Java有哪些数据类型

这里是引用

基本数据类型sout打印出来的是数值, 引用数据类型sout打印出来的是对象的地址值
其中八种基本数据类型:byte、short、char‐‐>int‐‐>long‐‐>float‐‐>double,boolean
所占的空间大小:

	byte(1)
short(2)、char(2)
int(4)、long(8)
float(4)、double(8)

说说这 8 种基本数据类型对应的包装类型?
这八种基本类型都有对应的包装类分别为:Byte、Short、Character、Integer、Long、Float、Double、Boolean

那基本类型和包装类型有啥区别不?
Byte、Short、Character、Integer、Long、Float、Double、Boolean这些包装类的默认值是null,因为它们是对象类型。

基本类型是有默认值的:byte默认值0、short默认值0、char默认值’\u0000’、int默认值0、long默认值0L、float默认值0.0f、double默认值0.0d,boolean默认值false

零拷贝

传统的 IO 将一个文件通过 socket 写出,内部工作流程是这样的:

在传统的数据传输过程中,当应用程序需要从磁盘读取数据并通过网络发送时,通常需要经历以下步骤:

这里是引用

这个过程涉及了多次数据拷贝和上下文切换(用户态和内核态之间的切换),这会导致CPU资源的浪费和数据传输效率的降低。

“零拷贝”这个名字听起来很神奇,好像数据在传输过程中完全没有被拷贝一样。但实际上,这里的“零拷贝”是指减少了数据在用户空间和内核空间之间的拷贝次数,并不是没有拷贝而是减少了拷贝次数,特别是避免了将数据从内核空间拷贝到用户空间,然后再从用户空间拷贝回内核空间(如网络发送缓冲区)的过程。这样,数据的传输变得更加高效,减少了CPU的负担和内存带宽的占用。

深拷贝和浅拷贝的区别是什么?

浅拷贝:被复制对象的所有变量都含有与原来的对象相同的值,而所有的对其他对象的引用仍然指向原来的对象.换言之,浅拷贝仅仅复制所考虑的对象,而不复制它所引用的对象。
深拷贝:被复制对象的所有变量都含有与原来的对象相同的值.而那些引用其他对象的变量将指向被复制过的新对象.而不再是原有的那些被引用的对象.换言之.深拷贝把要复制的对象所引用的对象都复制了一遍。

BIO、NIO、AIO的区别是什么?

BIO:属于同步阻塞 IO 模型 。数据的读取写入必须阻塞在一个线程内等待其完成。

NIO:属于同步非阻塞的 I/O模型。提供了 Channel , Selector,Buffer 等抽象。NIO 提供了与传统 BIO 模型中的Socket 和 ServerSocket 相对应的 SocketChannel 和 ServerSocketChannel 两种不同的套接字通道实现,两种通道都支持阻塞和非阻塞两种模式。对于高负载、高并发的(网络)应用,应使用NIO 的非阻塞模式来开发

AIO:(Asynchronous I/O)异步的IO模型。应用操作之后会直接返回,不会堵塞在那里,当后台处理完成,操作系统会通知相应的线程进行后续的操作。目前来说 AIO 的应用还不是很广泛。Netty 之前也尝试使用过 AIO,不过又放弃了。这是因为,Netty使用了 AIO 之后,在 Linux 系统上的性能并没有多少提升。

Netty 是什么?

就简单用 3 点来概括一下 Netty 吧!

  1. Netty 是一个 基于 NIO 的 client-server(客户端服务器)框架,使用它可以快速简单地开发网络应用程序。
  2. 它极大地简化并优化了 TCP 和 UDP 套接字服务器等网络编程,并且性能以及安全性等很多方面甚至都要更好。
  3. 支持多种协议 如 FTP,SMTP,HTTP 以及各种二进制和基于文本的传统协议。
    易于开发,且性能、稳定性和灵活性都非常的好

Netty 基于 NIO,那为啥不直接用 NIO 呢? / 为什么要用 Netty?

不用 NIO 主要是因为 NIO 的编程模型复杂而且对编程功底要求比较高。
NIO 在面对断连重连、包丢失、粘包等问题时处理过程非常复杂。

Netty 具有下面这些优点:

  • 简单而强大的线程模型。
  • 自带编解码器解决 TCP 粘包/拆包问题。
  • Netty支持多种常见的网络协议,包括TCP、UDP、HTTP、WebSocket等。这使得它适用于各种应用场景
  • 比直接使用 Java 核心 API 有更高的吞吐量、更低的延迟、更低的资源消耗和更少的内存复制。
  • 经历了大型项目的使用和考验,而且很多开源项目都使用到了 Netty, 比如我们经常接触的 Dubbo、RocketMQ 等等。
  • 异步事件驱动:Netty采用基于事件驱动的模型,通过异步的方式处理网络操作。这允许在单线程上处理大量的并发连接,提高了系统的吞吐量和性能。
  • 高性能:Netty通过优化的事件循环、内存管理和零拷贝等技术,实现了出色的性能表现。
  • 支持并发和多连接:Netty通过使用多线程和高效的事件处理机制,能够轻松处理数千甚至数万个并发连接,适用于高并发场景。

Netty 应用场景了解么?

Netty 主要用来做网络通信 :

  1. 作为 RPC 框架的网络通信工具 : 我们在分布式系统中,不同服务节点之间经常需要相互调用,这个时候就需要 RPC 框架了。不同服务节点的通信是如何做的呢?可以使用 Netty 来做。
  2. 实现一个即时通讯系统 : 使用 Netty 我们可以实现一个可以聊天类似微信的即时通讯系统
  3. 物联网(IoT): 在物联网领域,设备之间的通信需要高效、可靠的网络框架,Netty的异步IO模型和卓越的性能使其成为物联网系统的理想选择。

那些开源项目用到了 Netty?

用到了 Netty:Dubbo、RocketMQ、Elasticsearch等

没用用到Netty的:Zookeeper使用Java的原生NIO(非阻塞IO)进行网络通信。

Netty的核心组件是什么?

Netty的核心组件包括以下几个主要部分:

  1. Channel(通道): Channel是Netty中用于处理数据的通道。它负责所有的I/O操作,包括读取、写入、连接和绑定等。Netty提供了不同类型的Channel,用于支持TCP、UDP等不同的传输协议。
  2. EventLoop(事件循环): EventLoop是Netty异步事件处理的核心。每个Channel都与一个EventLoop关联,它负责处理该Channel上的所有事件。EventLoop采用单线程或多线程的方式,负责处理I/O事件、执行任务和定时任务等。
  3. ChannelPipeline(通道管道): ChannelPipeline是一个由一系列ChannelHandler组成的处理链。每个Channel都有一个关联的ChannelPipeline,用于处理入站和出站的数据。ChannelHandler负责处理特定类型的事件,如数据编解码、业务逻辑处理等。
  4. ChannelHandler(通道处理器): ChannelHandler是用于处理I/O事件的组件。开发者可以编写自定义的ChannelHandler来实现特定的业务逻辑,例如数据编解码、业务处理等。ChannelHandler可添加到ChannelPipeline中,形成一个处理链。
  5. ByteBuf(字节缓冲区): ByteBuf是Netty中用于存储和操作字节数据的缓冲区。它提供了灵活的API,支持池化、切片等高级特性,有助于提高性能和内存管理效率。
  6. ChannelFuture(通道未来): ChannelFuture表示异步操作的结果,例如I/O操作的成功、失败或取消。通过ChannelFuture,开发者可以注册监听器以处理操作完成时的回调。
  7. Bootstrap(引导类): Bootstrap是Netty用于启动客户端的引导类。它负责配置和启动Netty的客户端组件,包括设置Channel类型、EventLoop组、ChannelPipeline等。
  8. ServerBootstrap(服务器引导类): ServerBootstrap是Netty用于启动服务器的引导类。它包含了一些服务器独有的配置选项,如处理客户端连接请求、设置TCP参数等。

这些核心组件共同构建了Netty的基础架构,使得开发者能够通过简单而强大的API构建高性能的网络应用和服务。

这里是引用

请解释Netty的事件模型是什么样的。

  1. 事件与事件处理器(Handler)
    在Netty中,网络操作(如连接、读取数据、写入数据等)都被视为事件。当这些事件发生时,Netty会将这些事件传递给相应的事件处理器(Handler)。事件处理器就像是处理网络事件的“工人”,它们负责根据事件的具体类型执行相应的操作。

  2. 事件处理链(ChannelPipeline)
    Netty中的事件处理器并不是单独工作的,它们被组织成一个链(ChannelPipeline)。这个链就像是一个流水线,每个事件都会按顺序通过链中的每个处理器。

  3. 异步与回调
    Netty的I/O操作是异步的,这意味着当你发起一个I/O操作时(如读取数据),Netty会立即返回一个结果(通常是一个Future对象),而不会阻塞当前线程等待操作完成。你可以在结果上注册一个回调(Callback),当操作完成时,Netty会自动调用这个回调,并传入操作的结果。这种方式大大提高了程序的并发处理能力。

  4. EventLoop(事件循环)
    EventLoop负责处理连接上的各种事件,包括接收数据、发送数据、处理IO事件等。Netty使用EventLoop来处理网络事件。它负责处理分配给它的所有Channel(通道)的事件。EventLoop会不断地轮询注册在其上的Channel,处理这些Channel上的IO事件,这样可以确保Channel的所有事件都在同一个线程中按顺序处理,从而避免了多线程并发带来的复杂性。一个EventLoop可能处理着多个channel的事件。一个EventLoop通常关联一个线程,而一个Netty应用可能有多个EventLoop,每个EventLoop运行在独立的线程上

网络事件传递给事件处理器链进行处理,事件处理器链里面有事件处理器来处理,并利用异步和回调机制来提高程序的并发性能。同时,通过EventLoop来管理事件的处理线程,保证了事件处理的顺序性和一致性。

什么是Channel和ChannelPipeline?

  1. Channel(通道):
    • Channel代表了一个网络连接,可以是客户端到服务器的连接,也可以是服务器之间的连接。每个Channel都由一个EventLoop负责处理,而一个EventLoop可以管理多个Channel。Channel中可以执行I/O操作,如读取、写入、连接和绑定等。
  2. ChannelPipeline(通道管道):
    • ChannelPipeline是一个由一系列ChannelHandler组成的处理链。ChannelHandler如进行数据编解码、业务逻辑处理等。ChannelPipeline将这些ChannelHandler串联起来,形成一个处理链。
    • 每个Channel都有一个关联的ChannelPipeline,用于处理入站和出站的数据。

Netty的ByteBuf是什么,有什么优势?

Netty里面有ByteBuf,而NIO里面是ByteBuffer

ByteBuf是对ByteBuffer的增强,是对字节数据的封装。

ByteBuf是可以动态扩容的,而ByteBuffer一旦指定了容量就固定了,所以ByteBuf是对ByteBuffer的增强

bytebuffer是读写共用一个指针,所以需要读写的切换;现在bytebuf就不用

ByteBuf的设计允许进行零拷贝操作,例如,可以直接将ByteBuf的底层字节数组传递给其他组件,避免了中间的数据拷贝,提高了数据传输的效率。

Netty支持哪些协议?

  1. TCP和UDP: Netty提供了对TCP和UDP协议的支持,可以用于构建各种基于这两个传输协议的网络应用。
  2. HTTP和HTTPS: Netty可以用于构建支持HTTP和HTTPS协议的Web服务器和客户端。
  3. WebSocket: Netty支持WebSocket协议,可以用于实现实时、双向通信的Web应用。
  4. SMTP和IMAP: Netty可以用于构建支持邮件协议(如SMTP和IMAP)的服务器和客户端。
  5. DNS: Netty可以用于构建支持域名系统(DNS)的应用。
  6. MQTT: Netty提供了对MQTT(Message Queuing Telemetry Transport)协议的支持,可以用于构建支持物联网设备通信的应用。
  7. Custom Protocols: 由于Netty的灵活性,开发者可以根据需要自定义协议栈,构建适用于特定场景的自定义协议。

什么是编解码器(Codec)?Netty中有哪些内置的编解码器?

编解码器(Codec)是负责将数据在不同表示形式之间进行转换的组件。主要用于处理二进制数据与Java对象之间的相互转换。

内置的编解码器:

  1. ByteToMessageDecoder: 这是一个抽象类,用于将字节数据解码为消息对象。开发者可以继承这个类并实现decode方法,以实现特定协议的解码逻辑。
  2. MessageToByteEncoder: 同样是一个抽象类,用于将消息对象编码为字节数据。开发者可以继承这个类并实现encode方法,以实现特定协议的编码逻辑。

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

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

相关文章

【LwIP源码学习笔记1】LwIP网络接口管理

netif结构体 netif是Lwip抽象出来的网卡,结构体的声明在Lwip/include/lwip/netif.h文件中。 Lwip将每个用netif描述的网卡连接成一个链表(单向链表)。 以下是在netif.h头文件中定义的一些netif的操作函数 struct netif *netif_add_noaddr(s…

SpringBoot整合策略模式之基于 ApplicationContextAware + 枚举类实现

文章目录 1、ILog2、LogType 枚举类3、DemoController4、application.properties5、DesignDemoApplication 1、ILog package com.atguigu.design.demo.spring; import org.springframework.beans.BeansException; import org.springframework.context.ApplicationContext; imp…

Nginx学习(第二天)

一.Nginx高级配置 1.1 Nginx状态页 基于nginx 模块 ngx_http_stub_status_module 实现, 在编译安装nginx的时候需要添加编译参数 --with-http_stub_status_module 否则配置完成之后监测会是提示法错误 注意: 状态页显示的是整个服务器的状态,而非虚拟主机的状态 …

PeriodWave: Multi-Period Flow Matching for High-Fidelity Waveform Generation

preprintKorea Seoul, Korea 文章目录 abstractmethodFlow Matching for Waveform GenerationHigh-frequency Information Modeling for Flow Matching demo page, PeriodWave 三者最好,而且能把原声中的噪声去掉,GAN一类声码器做不到的。 Pe…

vllm 部署GLM4模型进行 Zero-Shot 文本分类实验,让大模型给出分类原因,准确率可提高6%

文章目录 简介数据集实验设置数据集转换模型推理评估 简介 本文记录了使用 vllm 部署 GLM4-9B-Chat 模型进行 Zero-Shot 文本分类的实验过程与结果。通过对 AG_News 数据集的测试,研究发现大模型在直接进行分类时的准确率为 77%。然而,让模型给出分类原…

地理空间数据分析技巧:优化的热点分析与异常值分析的应用

热点分析作为一种常用的空间统计方法,能够帮助我们识别地理空间中的热点和冷点区域,即那些高值或低值集中出现的地方。而优化的热点分析进一步简化了这一过程,使用户无需手动调整参数即可获得可靠的结果。此外,异常值分析则专注于…

wooyu漏洞库YYDS!!!入门之道:重现乌云漏洞库

目录 wooyun乌云漏洞库搭建 1、搭建资料 文件结构分析: ​编辑2、搭建过程 2.1、搭建wooyun网站 2.2、配置数据库 2.2.1、修改数据库配置文件conn.php 2.2.2、创建wooyun数据库,并解压数据库文件 2.2.3、连接数据库(数据库默认连接密…

信号与系统——定义与分类(1)

一、信号与系统 信号:信号是信息的表现形式或传送载体,例如电磁波。信号可以用一个函数 yx (t) 来表示。 系统:是指若干相互关联的事物组合而成,具有特定功能的整体。换句话说就是,系统就是对输入信号进行加工和处理&#xff0c…

Nginx: 反向代理和动静分离概述

反向代理 反向代理服务器介于用户和真实服务器之间,提供请求和响应的中转服务对于用户而言,访问反向代理服务器就是访问真实服务器反向代理可以有效降低服务器的负载消耗,提升效率 1 )反向代理的模型 现在我们有一个用户和真实服…

新版cubemx生成CMake工程浮点数打印问题记录

问题现象 解决方案 set(CMAKE_C_LINK_FLAGS "${CMAKE_C_LINK_FLAGS} --specsnano.specs -u _printf_float")参考Cortex-M4权威指南 重新下载和测试

[Algorithm][综合训练][打怪][判断是不是平衡二叉树][最大子矩阵]详细讲解

目录 1.打怪1.题目链接2.算法原理详解 && 代码实现 2.判断是不是平衡二叉树1.题目链接2.算法原理详解 && 代码实现 3.最大子矩阵1.题目链接2.算法原理详解 && 代码实现 1.打怪 1.题目链接 打怪 2.算法原理详解 && 代码实现 自己的版本&…

C++ 设计模式——代理模式

C 设计模式——代理模式 C 设计模式——代理模式1. 主要组成成分2. 逐步构建代理模式2.1 抽象主题类定义2.2 真实主题类实现2.3 代理类实现2.4 主函数 3. 代理模式 UML 图代理模式 UML 图解析 4. 代理模式的优点5. 代理模式的缺点6. 代理模式的分类7. 代理模式和装饰者模式比较…

MybatisPlus:实现分页效果并解决错误:cant found IPage for args

我们在做开发使用mybatisplus 做分页查询的时候遇到了个问题: 继承 IPage拦截没有作用会默认分页,这个时候报了cant found IPage for args 错误~~~ 我们分析了下,其实这个问题很简单,是因为没有给默认值赋值,因为查询…

日撸Java三百行(day35:图的m着色问题)

目录 一、问题描述 二、思路分析 三、代码实现 总结 一、问题描述 在高中学习排列组合的时候,有一个非常经典的问题,就是涂色问题,即用m种颜色给n块区域涂色,要求每块区域只能涂同一种颜色且相邻区域的颜色不能相同&#xff…

pyinstaller将python程序打包成exe文件

将python代码打包成exe文件可以在不安装python环境的情况下直接运行python代码,譬如自己在自己的电脑上写好了代码,想发给其他人使用,可以用下述方法将python程序打包成exe文件,其他人直接执行exe文件即可使用该程序。 1.安装pyi…

二叉搜索树:数据结构之美

目录 引言基础知识 定义性质操作详解 插入节点删除节点查找节点遍历 前序遍历中序遍历后序遍历高级主题 平衡问题AVL树简介应用案例总结 引言 二叉搜索树(Binary Search Tree, BST)是一种特殊的二叉树,它的每个节点具有以下性质:左子树上的所有节点的键…

Python数据采集与网络爬虫技术实训室解决方案

在大数据与人工智能时代,数据采集与分析已成为企业决策、市场洞察、产品创新等领域不可或缺的一环。而Python,作为一门高效、易学的编程语言,凭借其强大的库支持和广泛的应用场景,在数据采集与网络爬虫领域展现出了非凡的潜力。唯…

Mysql重要参数

1、是否开启慢SQL日志 show VARIABLES like slow_query_log%; 2、慢SQL日志保存位置 show VARIABLES like slow_query_log_file%; 3、慢SQL的阈值,超过则是慢SQL,单位秒,默认10s show VARIABLES like long_query_time%;

小阿轩yx-Kubernetes存储入门

小阿轩yx-Kubernetes存储入门 前言 数据是一个企业的发展核心,它涉及到数据存储和数据交换的内容。在生产环境中尤为重要的一部分在 Kubernetes 中另一个重要的概念就是数据持久化 Volume。 Volume 的概念 对多数项目而言 数据文件的存储是非常常见的 在 Kube…

计算机的错误计算(七十四 )

摘要 回复网友的疑问:用错数解释计算机的错误计算(六十四)中的错误计算原因。 计算机的错误计算(六十四)到(六十九),以及(七十一)与(七十三&…