从零开始学习Netty - 学习笔记 - NIO基础 - ByteBuffer: 简介和基本操作

news2025/2/28 15:55:16

NIO基础

1.三大组件

1.1. Channel & Buffer

在这里插入图片描述

Channel

在Java NIO（New I/O）中，“Channel”（通道）是一个重要的概念，用于在非阻塞I/O操作中进行数据的传输。Java NIO提供了一种更为灵活和高效的I/O处理方式，相比于传统的I/O，它具有更好的性能和可扩展性。

常见的Java NIO中的通道类型：

  1. FileChannel（文件通道）：
    • 用于文件I/O操作的通道，可以在文件中进行读取、写入和操作。
  2. SocketChannel（套接字通道）：
    • 用于TCP协议的通道，可以在网络套接字连接中进行读取和写入数据。(客户端，服务器端都能用)
  3. ServerSocketChannel（服务器套接字通道）：
    • 监听新的TCP连接的通道，当有新的连接进来时，可以接受并创建对应的SocketChannel。（只能用于服务器端）
  4. DatagramChannel（数据报通道）：
    • 用于UDP协议的通道，可以在网络中发送和接收数据报。

通过使用这些通道，Java NIO可以提供非阻塞的I/O操作，允许程序在一个线程中管理多个I/O操作，提高了系统的并发处理能力和性能表现。通道和缓冲区（Buffer）结合使用，能够实现更灵活、高效的数据传输和处理。

Buffer
在Java NIO中，Buffer（缓冲区）是一个核心概念，用于在通道（Channel）和数据源之间进行数据交互。Buffer实际上是一个容器，用于存储特定类型的数据，并提供了方便的方法来读取和写入数据。

常见的Java NIO中的Buffer类型：

  1. ByteBuffer：

    • ByteBuffer是最基本的缓冲区类型，用于存储字节数据。
      • MappedByteBuffer：
        • MappedByteBuffer是ByteBuffer的一个子类，它通过文件通道直接映射到内存中，可以实现高效的文件I/O操作。

  2. CharBuffer：

    • CharBuffer用于存储字符数据。

  3. ShortBuffer、IntBuffer、LongBuffer、FloatBuffer、DoubleBuffer：

    • 这些是用于存储各种基本数据类型的缓冲区，分别用于存储short、int、long、float和double类型的数据。

这些缓冲区提供了一种灵活的方式来管理数据，可以在缓冲区和通道之间进行数据传输，也可以在缓冲区内部进行数据处理。通过缓冲区，Java NIO实现了高效的I/O操作，可以在同一线程内处理多个通道，提高了系统的并发性能。

1.2.Selector

在这里插入图片描述

当使用 Java NIO 进行非阻塞 I/O 操作时，Selector（选择器）是一种关键的组件。它允许单个线程有效地管理多个 Channel，监视它们的状态并且在至少一个 Channel 准备好进行读取、写入或者连接时，唤醒线程。

Selector 的作用是配置一个线程来管理多个 Channel，获取这些 Channel 上发生的事件。这些 Channel 通常工作在非阻塞模式下，因此不会让线程阻塞在一个 Channel 上。Selector 适用于连接数量特别多但流量低的场景，因为它可以有效地利用一个线程来处理多个连接，降低线程创建和上下文切换的开销。

  1. 非阻塞 I/O：
    • Selector 允许程序使用单个线程处理多个 Channel，而不是为每个 Channel 都创建一个线程。这样可以显著减少线程的数量，提高系统的并发处理能力。
  2. Channel 注册：
    • 在使用 Selector 之前，需要将每个 Channel 注册到 Selector 上，并指定感兴趣的事件类型，如读、写、连接等。
  3. 事件就绪集合：
    • Selector 会不断轮询注册在其上的 Channel，当一个或多个 Channel 准备好进行 I/O 操作时，Selector 将返回一个就绪事件的集合。
  4. 事件驱动的编程模型：
    • 应用程序通过监听就绪事件的方式，实现了一种事件驱动的编程模型，根据不同的事件类型执行相应的操作。
  5. 资源管理：
    • 使用完 Selector 后，应及时关闭以释放资源，避免资源泄漏和性能问题。

通过 Selector，Java NIO 提供了一种高效的非阻塞 I/O 模型，使得应用程序能够更好地处理大量并发连接，提高系统的性能和可伸缩性。

2.ByteBuffer

ByteBuffer 是 Java NIO 中用于处理字节数据的缓冲区类之一。它提供了一种灵活的方式来处理字节数据，例如读取、写入、修改、复制等操作。

以下是关于 ByteBuffer 的一些重要特点和用法：

  1. 容量和位置：
    • ByteBuffer 有一个固定的容量，表示它可以存储的最大字节数量。它还有一个位置（position），表示下一个读取或写入操作将要发生的位置。
  2. 读写操作：
    • ByteBuffer 可以被用来进行读取和写入操作。它提供了诸如 put()、get()、putInt()、getInt() 等方法来读取和写入字节数据。
  3. 字节顺序（Byte Order）：
    • ByteBuffer 可以配置为使用不同的字节顺序，例如大端字节序（Big Endian）或小端字节序（Little Endian），以适应不同的数据格式。
  4. 直接缓冲区和非直接缓冲区：
    • ByteBuffer 可以是直接缓冲区或非直接缓冲区。直接缓冲区使用操作系统的内存空间，通常性能更好，而非直接缓冲区使用 Java 虚拟机的堆内存。
  5. 清除、翻转和重绕：
    • ByteBuffer 提供了一些方法来处理缓冲区的状态，例如 clear() 方法清除缓冲区中的数据(写模式)、flip() 方法翻转缓冲区以便读取已写入的数据(读模式)、rewind() 方法重绕缓冲区以便重新读取已读数据(写模式)。
  6. 其他操作：
    • ByteBuffer 还提供了一些其他的操作，如 compact() 方法压缩缓冲区、slice() 方法创建一个新的缓冲区视图等。

ByteBuffer 在网络编程、文件 I/O、数据处理等领域广泛应用，它是 Java NIO 中处理字节数据的重要工具之一，提供了高效、灵活的字节数据处理方式。

2.1.案例1-读取文件内容

/**
 * ByteBuffer 测试测试读取文件
 * @author 13723
 * @version 1.0
 * 2024/2/19 21:30
 */
public class ByteBufferTest {
	private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
    
	@Test
	@DisplayName("测试读取文件")
	public void testReadFile() {
		// 1.读取文件
		try (FileChannel channel = new FileInputStream("data.txt").getChannel()) {
			while (true){
				// 1.1 创建一个缓冲区(划分一块内存作为缓冲区) 每次读取只取5个字节 5个字节读取完毕后再读取下一个5个字节
				ByteBuffer byteBuffer = ByteBuffer.allocate(5);
				// 1.2 读取数据到缓冲区
				int len = channel.read(byteBuffer);
				// 读取到文件末尾 len = -1 退出循环
				if (len == -1) {
					break;
				}
				// 1.3 打印缓冲区的内容
				// 切换到读模式
				byteBuffer.flip();
				while (byteBuffer.hasRemaining()){ // 检查是否存在未读取的数据
					byte b = byteBuffer.get();
					logger.error("读取到的字节为：{}", (char) b);
				}
				// 1.4 每次读取完成切换为写模式
				byteBuffer.clear();
			}
		} catch (IOException e) {
		}
	}
}

在这里插入图片描述

2.2.ByteBuffer结构

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

compact方法，就是把未读取完成的部分向前压缩，然后切换为写模式下次写入的位置，是从上次没有读完的位置开始的

在这里插入图片描述

2.3.案例2-读取写入数据

	@Test
	@DisplayName("测试ByteBuffer写入读取数据")
	public void test2(){
		ByteBuffer buffer = ByteBuffer.allocate(10);
		// 写入一个字节 ‘a’
		buffer.put((byte) 'a');
		// 打印字符
		debugAll(buffer);
		// 再写入两个字节
		buffer.put(new byte[]{'b', 'c'});
		debugAll(buffer);
		// 切换成模式，此时position = 0, limit = 3
		buffer.flip();
		byte b = buffer.get();
		System.out.println((char) b);
		debugRead(buffer);
       
        buffer.compact();
		debugAll(buffer);
	}

在这里插入图片描述

  • 调用compact方法

在这里插入图片描述

2.4.ByteBuffer常见方法

2.4.1.分配空间

可以使用 allocate 方法为 ByteBuffer 分配空间，其他 Buffer 类也有该方法 不能动态调整容量 netty对ByteBuffer这里做了增强，可以动态调整

它使用的是 Java 堆内存（Heap Memory）。allocate 方法分配的是一个非直接缓冲区，即缓冲区的数据存储在 Java 虚拟机的堆内存中。

堆内存的优势在于它的管理由 Java 虚拟机负责，而且垃圾回收器可以有效地回收不再使用的对象，但是在进行 I/O 操作时，需要将数据从堆内存复制到内核空间，存在额外的拷贝开销。

读写效率低

ByteBuffer buffer = ByteBuffer.allocate(10);

allocateDirect(10),它使用的是直接缓冲区（Direct Buffer），可以通过 ByteBuffer.allocateDirect() 方法来创建。直接缓冲区的数据存储在操作系统的内存中（不会受到垃圾回收的影响），减少了数据在 Java 堆和本地堆之间的拷贝操作，提高了 I/O 操作的效率。但是，直接缓冲区的分配和释放通常更昂贵，可能导致内存泄漏问题。、

读写效率高（少一次拷贝）

ByteBuffer buffer1 = ByteBuffer.allocateDirect(10);
2.4.2.包装现有数组

如果有现有的字节数组，可以使用 wrap 方法将其包装成 ByteBuffer

byte[] byteArray = new byte[10];
ByteBuffer buffer = ByteBuffer.wrap(byteArray);
2.4.3.获取和设置容量

获取 ByteBuffer 的容量（capacity）

int capacity = buffer.capacity();

设置 ByteBuffer 的容量（慎用，可能导致数据丢失）

buffer.capacity(20);
2.4.4.获取和设置位置

获取 ByteBuffer 的位置（position）

int position = buffer.position();

设置 ByteBuffer 的位置（position），用于读取或写入数据

buffer.position(5);
2.4.5.获取限制和设置限制

获取 ByteBuffer 的限制（limit），即可以读取或写入的最大位置

int limit = buffer.limit();

设置 ByteBuffer 的限制（limit）

buffer.limit(8);
2.4.6.读取和写入数据

从 ByteBuffer 中读取字节数据

也可也调用channel的wirte方法

byte b = buffer.get();
int r = channel.wite(buffer);

向 ByteBuffer 中写入字节数据

int read = channel.read();

也可也调用channel的read方法

buffer.put((byte) 10);
channel.read(buffer);
2.4.7.翻转缓冲区

将 ByteBuffer 从写模式切换到读模式，通常在写入数据后调用

buffer.flip();
2.4.8.清空缓冲区

清空 ByteBuffer 中的数据，通常在读取数据后调用

buffer.clear();
2.4.9.倒带缓冲区

将 ByteBuffer 的位置设置为 0，通常在重新读取数据时调用

buffer.rewind();
2.4.10.压缩缓冲区

将未读取的数据复制到缓冲区的开始处，然后将位置设置为复制的数据末尾，通常在写入部分数据后调用

buffer.compact();
2.4.11.标记和重置位置

标记当前的位置，通常与 reset 方法一起使用，用于返回到之前标记的位置，,比如中间某些数据重要需要返回读取

buffer.mark();

重置位置到之前标记的位置

buffer.reset();

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

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

相关文章

原创java开源项目发布maven全球中央仓库详细过程示范和遇到的问题解决办法

原创java开源项目发布maven全球中央仓库详细过程示范和遇到的问题解决办法

文章目录 java项目上传到maven全球中央仓库（原创个人开源项目发布maven中央仓库详细过程示范）需求背景第一步 注册sonatype账号第二步 登录sonatype账号并申请新建项目第三步 准备个人GPG数字签名并发布到ubuntu第四步 准备maven配置第五步 修改项目配置…
阅读更多...
【软考高级信息系统项目管理师--第二十四章：法律法规与标准规范】

【软考高级信息系统项目管理师--第二十四章：法律法规与标准规范】

🚀 作者 ：“码上有前” 🚀 文章简介 ：软考高级–信息系统项目管理师 🚀 欢迎小伙伴们 点赞👍、收藏⭐、留言💬 第二十四章：法律法规与标准规范 商标专利法网络安全法 商标专利法 授…
阅读更多...
【Linux | C++ 】基于环形队列的多生产者多消费者模型（Linux系统下C++ 代码模拟实现）

【Linux | C++ 】基于环形队列的多生产者多消费者模型（Linux系统下C++ 代码模拟实现）

阅读导航 引言一、生产者消费者模型二、环形队列简介三、基于环形队列的生产者消费者模型（C 代码模拟实现）⭕Makefile文件⭕ . h 头文件✅sem.hpp✅ringQueue.hpp ⭕ . cpp 文件✅testMain.cpp 温馨提示 引言 在上一篇文章中，我们深入探讨了…
阅读更多...
408计算机网络--基础概论

408计算机网络--基础概论

学习计算机网络走以前需要首先明白一个大的概念，计算机网络通常分为通信子网（实现数据通信）和资源子网（实现资源共享/数据处理）七层妖塔 计算机网络：是一个将分散的、具有独立功能的计算机系统&#xff0…
阅读更多...
【Leetcode 2415】反转二叉树的奇数层 —— 回溯法 | BFS

【Leetcode 2415】反转二叉树的奇数层 —— 回溯法 | BFS

2415. 反转二叉树的奇数层 给你一棵 完美 二叉树的根节点root，请你反转这棵树中每个 奇数 层的节点值。 例如，假设第 3 层的节点值是[2,1,3,4,7,11,29,18]，那么反转后它应该变成[18,29,11,7,4,3,1,2]。 反转后，返回树的根节点。…
阅读更多...
【Redis,Java】Redis的两种序列化方式—nosql数据库

【Redis,Java】Redis的两种序列化方式—nosql数据库

redis和mysql的区别： redis是属于nosql的数据库，而mysql是属于sql数据库，redis是属于nosql数据库。mysql是存储在磁盘中的，redis是存储在内存中的，所以redis的读取书读快。这里所说的redis代表nosql，而mysq…
阅读更多...
【elk查日志 elastic（kibana）】

【elk查日志 elastic（kibana）】

文章目录 概要具体的使用方式一：查找接口调用历史二：查找自己的打印日志三：查找错误日志 概要 每次查日志，我都需要别人帮我，时间长了总觉得不好意思，所以这次下定决心好好的梳理一下，怎么查日…
阅读更多...
更改WordPress作者存档链接author和用户名插件Change Author Link Structure

更改WordPress作者存档链接author和用户名插件Change Author Link Structure

WordPress作者存档链接默认情况为/author/Administrator（用户名），为了防止用户名泄露，我们可以将其改为/author/1（用户ID），具体操作可参考『如何将WordPress作者存档链接中的用户名改为昵称或ID…
阅读更多...
【大模型 幻觉】CRAG：改进传统的 RAG，增加纠正机制提升生成文本的准确性

【大模型 幻觉】CRAG：改进传统的 RAG，增加纠正机制提升生成文本的准确性

CRAG：改进传统的 RAG，增加纠正机制提升生成文本的准确性 提出背景CRAG 框架轻量级检索评估器大规模网络搜索分解再重组算法 提出背景 论文：https://arxiv.org/abs/2401.15884 代码：https://github.com/HuskyInSalt/CRAG 大型语言…
阅读更多...
适合tiktok运营的云手机需要满足什么条件？

适合tiktok运营的云手机需要满足什么条件？

TikTok作为一款全球热门的社交媒体平台，具有无限的市场潜力。然而，卖家在运营过程中常常会面临到视频0播、账号被降权、限流等问题，甚至可能因为多人同时使用一个IP而导致封号的风险。为了规避这些问题，越来越多的卖家将目光投向了…
阅读更多...
k8s学习（RKE+k8s+rancher2.x）成长系列之简配版环境搭建（四）之Helm及cert-manager安装

k8s学习（RKE+k8s+rancher2.x）成长系列之简配版环境搭建（四）之Helm及cert-manager安装

安装Helm(三台都安装) 下载helm安装包并加入执行目录 tar zxf helm-v3.2.4-linux-amd64.tar.gz cd linux-amd64 cp helm /usr/bin/ helm version添加rancher稳定版仓库(三台都安装) helm repo add rancher-stable http://rancher-mirror.oss-cn-beijing.aliyuncs.com/serve…
阅读更多...
8.2 新特性 - 透明的读写分离

8.2 新特性 - 透明的读写分离

文章目录 前言1. 安装部署1.1 下载安装包1.2 MySQL Shell1.3 配置 MySQL 实例1.4 启动 ReplicaSet1.5 启动 8.2 Router 2. 测试路由总结 前言 MySQL 8.0 官方推出过一个高可用方案 ReplicaSet 主要由 Router、MySQL Shell、MySQL Server 三个组件组成。 MySQL Shell 负责管理…
阅读更多...
qt-双臂SCARA机器人动画

qt-双臂SCARA机器人动画

qt-双臂SCARA机器人动画 一、演示效果二、核心程序三、下载链接 在Qt opengl中完成的双臂SCARA机器人的简单模拟。 一、演示效果 二、核心程序 #include "glwidget.h"#include <GL/glu.h>GLWidget::GLWidget(QWidget *parent) :QGLWidget(parent),pitch(30.…
阅读更多...
Java集合框架-1

Java集合框架-1

目录 List集合 常见方法 迭代器&#xff08;Iterator&#xff09; List集合特有方法 List 的特点 创建 List 遍历List Java集合框架是Java编程语言提供的各种数据结构和算法的实现。它提供了不同类型的集合类&#xff0c;如列表(List)、集(Set)、映射(Map)等&#xff0c…
阅读更多...
iOS通过p12导出公钥失败

iOS通过p12导出公钥失败

通过p12文件导出证书crt文件一直报invalid password错误。 adminJiaozl Downloads % openssl pkcs12 -in ce.p12 -clcerts -nokeys -out MyCertificate.crt Enter Import Password: Mac verify error: invalid password?解决&#xff1a; 在 https://developer.apple.com/acc…
阅读更多...
MongoDB文档插入

MongoDB文档插入

文章目录 MongoDB文档插入对比增删改查文档插入 MongoDB写安全机制非确认式写入 MongoDB文档查询参数说明查询操作符比较查询操作符逻辑查询操作符元素查询操作符数组查询操作符 模糊查询区别:$regex操作符中的option选项 MongoDB游标介绍游标函数手动迭代游标示例游标介绍 Mon…
阅读更多...
AMC8美国数学思维竞赛2000-2024年真题练一练，你能做对几道？

AMC8美国数学思维竞赛2000-2024年真题练一练，你能做对几道？

为帮助备考AMC8美国数学竞赛的孩子们了解比赛的题型&#xff0c;掌握相关的知识&#xff0c;我会陆续分享2000-2024年的比赛真题&#xff0c;每道题都有解析&#xff0c;帮助孩子们不但会做题&#xff0c;还掌握背后的知识&#xff0c;从而达到举一反三的效果&#xff0c;提升比…
阅读更多...
QT-LCD模拟显示

QT-LCD模拟显示

QT-LCD模拟显示 一、演示效果二、关键程序三、下载链接 一、演示效果 二、关键程序 #include "lcd_widget.h" #include <QDebug> #include <QPainter>LCDWidget::LCDWidget(QWidget *parent) : QWidget(parent),display(nullptr), display_char_buffer(…
阅读更多...
LeetCode JS专栏刷题笔记（二）

LeetCode JS专栏刷题笔记（二）

一、前言 LeetCode - JavaScript 专栏刷题笔记第二篇。 第一篇刷题笔记详见&#xff1a;LeetCode JS专栏刷题笔记&#xff08;一&#xff09; 二、算法题目 1. 复合函数 LeetCode地址&#xff1a;2629. 复合函数 请你编写一个函数&#xff0c;它接收一个函数数组 [f1, f2, …
阅读更多...
Mac清理系统垃圾软件CleanMyMac X2025免费版本下载

Mac清理系统垃圾软件CleanMyMac X2025免费版本下载

嘿&#xff0c;Mac用户们&#xff0c;你是否经常感觉你的Mac就像是在背着一个沉重的包袱在跑步&#xff1f;是的&#xff0c;我在说那些堆积如山的系统垃圾。清理这些垃圾不仅可以让你的Mac跑得更快&#xff0c;还能让它“呼吸”更畅快。今天&#xff0c;让我们一起来探索如何M…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023