JAVA系列:IO流

JAVA IO流

IO流图解

在这里插入图片描述

一、什么是IO流

I/O流是Java中用于执行输入和输出操作的抽象。它们被设计成类似于流水,可以在程序和外部源(如文件、网络套接字、键盘、显示器等)之间传输数据。

按处理数据单位分为:

1字符 = 2字节 、 1字节(byte) = 8位(bit)

  • 字节流:单位是字节,处理二进制数据,可以处理任何文件类型的数据,如图片、视频、文本等。
    • InputStreamInputStream是所有字节输入流的抽象基类,前面说过抽象类不能被实例化,实际上是作为模板而存在的,为所有实现类定义了处理输入流的方法。
    • FileInputSream:文件输入流,一个非常重要的字节输入流,用于对文件进行读取操作。
    • PipedInputStream:管道字节输入流,能实现多线程间的管道通信。
    • ByteArrayInputStream:字节数组输入流,从字节数组(byte[])中进行以字节为单位的读取,也就是将资源文件都以字节的形式存入到该类中的字节数组中去。
    • FilterInputStream:装饰者类,具体的装饰者继承该类,这些类都是处理类,作用是对节点类进行封装,实现一些特殊功能。
    • DataInputStream:数据输入流,它是用来装饰其它输入流,作用是“允许应用程序以与机器无关方式从底层输入流中读取基本 Java 数据类型”。
    • BufferedInputStream:缓冲流,对节点流进行装饰,内部会有一个缓存区,用来存放字节,每次都是将缓存区存满然后发送,而不是一个字节或两个字节这样发送,效率更高。
    • ObjectInputStream:对象输入流,用来提供对基本数据或对象的持久存储。通俗点说,也就是能直接传输对象,通常应用在反序列化中。它也是一种处理流,构造器的入参是一个InputStream的实例对象。
  • 字符流:单位是字符,只能对文本类型的数据进行处理。
    • InputStreamReader:从字节流到字符流的桥梁(InputStreamReader构造器入参是FileInputStream的实例对象),它读取字节并使用指定的字符集将其解码为字符。它使用的字符集可以通过名称指定,也可以显式给定,或者可以接受平台的默认字符集。
    • BufferedReader:从字符输入流中读取文本,设置一个缓冲区来提高效率。BufferedReader是对InputStreamReader的封装,前者构造器的入参就是后者的一个实例对象。
    • FileReader:用于读取字符文件的便利类,new FileReader(File file)等同于new InputStreamReader(new FileInputStream(file, true),"UTF-8"),但FileReader不能指定字符编码和默认字节缓冲区大小。
    • PipedReader :管道字符输入流。实现多线程间的管道通信。
    • CharArrayReader:从Char数组中读取数据的介质流。
    • StringReader :从String中读取数据的介质流。

WriterReader结构类似,方向相反 。

按数据流方向分为:

  • 输入流:从外部读取数据到内存中为我所有,为输入流,如读取磁盘的数据、网络的数据。
  • 输出流:从内存中将数据输出到外部,如输出到磁盘,输出到网络通信的数据。

按功能划分为:

  • 节点流:用来包装数据源,直接与数据源连接的流。
  • 处理流:用来包装节点流,利用节点流来连接,jdk利用的是装饰器模式进行编写。

二、基础方法

2.1、字节流方法

字节输入流InputStream主要方法:

  • read() :从此输入流中读取一个数据字节,返回-1表示读取完毕。
  • read(byte[] b) :从此输入流中将最多 b.length 个字节的数据读入一个 b 数组中,等同于下面的 read(byte[] b, 0, b.length)
  • read(byte[] b, int off, int len) :从此输入流中将最多 len 个字节的数据读入一个 b 数组中。
  • close():关闭此输入流并释放与该流关联的所有系统资源。

字节输出流OutputStream主要方法:

  • write(byte[] b) :将 b.length 个字节从指定 byte 数组写入此文件输出流中。
  • write(byte[] b, int off, int len) :将指定 byte 数组中从偏移量 off 开始的 len 个字节写入此文件输出流。
  • write(int b) :将指定字节写入此文件输出流。
  • close() :关闭此输入流并释放与该流关联的所有系统资源。

2.2、字符流方法

字符输入流Reader主要方法:

  • read():读取单个字符。
  • read(char[] cbuf) :将字符读入数组。
  • read(char[] cbuf, int off, int len) : 将字符读入数组的某一部分。
  • read(CharBuffer target) :试图将字符读入指定的字符缓冲区。
  • close() :关闭此流,但要先刷新它。

字符输出流Writer主要方法:

  • write(char[] cbuf) :写入字符数组。
  • write(char[] cbuf, int off, int len) :写入字符数组的某一部分。
  • write(int c) :写入单个字符。
  • write(String str) :写入字符串。
  • write(String str, int off, int len) :写入字符串的某一部分。
  • flush() :刷新该流的缓冲。
  • close() :关闭此流,会先刷新缓冲区它。

三、使用示例

字节流

3.1、FileInputStream / FileOutputStream

文件字节流:实现文件复制的功能

public static String inputPicturePath = "C:\\Users\\Administrator\\Desktop\\1.png";
public static String outPicturePath = "C:\\Users\\Administrator\\Desktop\\2.png";

// 实现文件复制功能,将inputPicturePath文件复制到outPicturePath路径。
public void fileStream() throws IOException {
        // 读取文件,这儿读取的是本地的图片
        FileInputStream fis = new FileInputStream(inputPicturePath);
        FileOutputStream fos = new FileOutputStream(outPicturePath);
        int readCount = 0;
        byte[] bytes = new byte[4];
    	// while循环直到等于-1为止,表明读取结束。
        while ((readCount = fis.read(bytes)) != -1) {
            fos.write(bytes, 0, readCount);
        }
        fis.close();
        fos.close();
    }
3.2、DataOutputStream / DataInputStream / ByteArrayOutputStream / ByteArrayInputStream

数据流,是一个处理流,封装节点流操作

数组流常用场景:

  • 内存中读取数据: ByteArrayInputStream 允许从内存中的字节数组读取数据,而无需借助磁盘或网络等外部存储设备。这在某些情况下可以提高读取速度和效率,特别是当数据已经存在于内存中时。

  • 方便数据传输: 使用 ByteArrayInputStream,可以方便地将字节数组传递给需要输入流的方法或组件,而无需将字节数组写入磁盘或进行网络传输。这样可以简化代码,并避免不必要的数据复制和存储开销。

  • 测试和调试: 在测试和调试过程中,可以使用 ByteArrayInputStream 来模拟输入流的行为,以便更容易对代码进行单元测试和调试。可以使用预定义的字节数组作为输入数据,并通过 ByteArrayInputStream 提供给待测试的方法。

  • 数据解析和处理: 有时,需要对二进制数据进行解析和处理。使用 ByteArrayInputStream 可以将字节数组转换为输入流,然后使用相应的读取方法从中读取数据。这对于处理二进制协议、解析图像或音频数据等场景非常有用。

   /**
     * 数据处理流
     * <p>
     * ByteArrayStream 字节数组流
     *
     * @return
     * @throws IOException
     */
    public void dataStream() throws IOException {
        // 字节数组流
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        DataOutputStream dos = new DataOutputStream(bos);
		// 真正调用的是 ByteArrayOutputStream的 write写入到数组中去。
        dos.writeBoolean(true);
        dos.writeInt(99);
        dos.writeShort(111);
        dos.writeDouble(3.14);

        // 读取数据流
        ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray());
        DataInputStream dis = new DataInputStream(bis);
        // 读取数据时,数据类型的顺序要与写入时一样。。。
        System.out.println(dis.readBoolean());
        System.out.println(dis.readInt());
        System.out.println(dis.readShort());
        System.out.println(dis.readDouble());
    }
3.3、ObjectOutputStream / ObjectInputStream

对象处理流,常用在JAVA对象的序列化与反序列化。

    public void objectStream() throws IOException, ClassNotFoundException {
        Person person = new Person();
        person.setId("1");
        person.setName("哇哈哈");
        person.setAge(32);
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        // 创建对象流,这儿用的是字节数组流进行装饰。
        ObjectOutputStream oos = new ObjectOutputStream(bos);
        // 写入对象。
        oos.writeObject(person);
        oos.writeBoolean(true);
        oos.flush();
        oos.close();
        ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray());
        ObjectInputStream ois = new ObjectInputStream(bis);
        // 获取对象。
        Person person1 = (Person) ois.readObject();
        boolean b = ois.readBoolean();
        System.out.println(b);
        System.out.println(JSONUtil.toJsonStr(person1));
    }

    @Data
    public static class Person implements Serializable {
        private String id;

        private String name;

        private Integer age;

    }
3.4、BufferedInputStream / BufferedOutputStream

缓冲处理流。内部设置了一个缓冲区,进行存储到内存中,减少直接读取的次数,以此来提高效率。

    public void bufferedStream() throws IOException {
        // 读取文件
        FileInputStream fis = new FileInputStream(filePath);
        // 新建,用文件流来进行装饰。
        BufferedInputStream bis = new BufferedInputStream(fis);

        FileOutputStream fos = new FileOutputStream(bufferOutputFilePath);
        // 用缓冲流复制文件,输出到 bufferOutputFilePath
        BufferedOutputStream bos = new BufferedOutputStream(fos);
        int readCount = 0;
        byte[] buffer = new byte[4];
        while ((readCount = bis.read(buffer)) != -1) {
            bos.write(buffer, 0, readCount);
        }
        fis.close();
        bis.close();
        bos.flush();
        bos.close();
        fos.close();
    }

字符流

3.1、FileReader / FileWriter

文件字符流

    public void fileStream() throws IOException {
	    // 文件字符流读取
        FileReader fileReader = new FileReader(filePath);
        FileWriter fileWriter = new FileWriter(fileWriterPath);
        int readCount = 0;
        // 复制文件到 fileWriterPath
        while ((readCount = fileReader.read()) != -1) {
            fileWriter.append((char) readCount);
        }
        fileReader.close();
        fileWriter.close();

    }
3.2、BufferedReader / BufferedWriter

字符缓冲流,是个处理流,内部用具体的流进行装饰。

    public void bufferStream() throws IOException {
        FileReader fr = new FileReader(filePath);
        // 用文件流进行装饰。
        BufferedReader br = new BufferedReader(fr);
        FileWriter fw = new FileWriter(bufferWriterPath);
        BufferedWriter bw = new BufferedWriter(fw);
        int readCount = 0;
        char[] buff = new char[4];
        // 复制文件
        while ((readCount = br.read(buff)) != -1) {
            bw.write(buff, 0, readCount);
        }
        bw.close();
        fw.close();
        br.close();
        fr.close();
    }
3.3、InputStreamReader / OutputStreamWriter

转换流,用于字节流转换为字符流。

    public void fileInputStream() throws IOException {
        // 创建文件字节输入流
        FileInputStream fis = new FileInputStream(filePath);
        // 装饰
        InputStreamReader isr = new InputStreamReader(fis);
        char[] chars = new char[4];
        int readCount = 0;
        // 创建文件字符输出流
        FileOutputStream fos = new FileOutputStream(inputStreamWriterPath);
        OutputStreamWriter osw = new OutputStreamWriter(fos);
        while ((readCount = isr.read(chars)) != -1) {
            // 输出到文件,复制
            osw.write(chars, 0, readCount);
        }
        isr.close();
        fis.close();
        osw.close();
        fos.close();
    }
3.4、CharArrayReader / CharArrayWriter

字符数组流

    public void charArrayStream() throws IOException {
        // 写入到数组中
        CharArrayWriter caw = new CharArrayWriter();
        caw.write("一");
        caw.write("二");
        caw.write("三");
        char[] charArray = caw.toCharArray();
        // 创建读取字符数组。
        CharArrayReader car = new CharArrayReader(charArray);
        int readCount = 0;
        while ((readCount = car.read()) != -1) {
            System.out.println((char) readCount);
        }
        car.close();
        caw.close();
    }

四、总结

1、字节流是原生的操作,字符流是处理之后的操作。

输入流都是:InputStreamReader的子类。

输出流都是:OutputStreamWriter的子类。

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Linux修炼之路之权限

目录 引言 一&#xff1a;Linux中用户的分类 二&#xff1a;在Linux中的权限 1.权限的两种属性 1.人的属性 2.事物属性 -主要以文件属性为主 3.文件权限值的两种表示方式方法 2.更改文件访问者(拥有者&#xff0c;所属组&#xff0c;其他人)权限属性 3.更改文件的拥有…

电子作业指导书系统如何提升医疗设备工厂的生产效率

在医疗设备工厂中&#xff0c;电子作业指导书&#xff08;ESOP&#xff09;正逐渐成为提升生产效率的关键因素。 一、电子作业指导书系统提供了即时可得的准确信息。 电子作业指导书系统与传统的纸质作业指导书相比&#xff0c;员工可以在工作现场通过电子设备随时查阅最新、最…

基于PSO优化的PV光伏发电系统simulink建模与仿真

目录 1.课题概述 2.系统仿真结果 3.核心程序与模型 4.系统原理简介 5.完整工程文件 1.课题概述 基于PSO优化的PV光伏发电系统simulink建模与仿真。其中PSO采用matlab编程实现&#xff0c;通过simulink的函数嵌入模块&#xff0c;将matlab调用进simulink中。 2.系统仿真结…

【Linux系统化学习】守护进程 | 序列化和反序列化

目录 前言 守护进程 会话 进程组 setsid系统调用 守护进程系统调用 再谈协议 序列化和反序列化 Json 前言 上两篇文章我们所编写的服务器&#xff0c;并算不上真正意义上的服务器一般的服务器都是要随时能够访问的&#xff0c;就像我们在任何时间段都可以打开抖音获取…

[C++核心编程-09]----C++类和对象之继承

&#x1f3a9; 欢迎来到技术探索的奇幻世界&#x1f468;‍&#x1f4bb; &#x1f4dc; 个人主页&#xff1a;一伦明悦-CSDN博客 ✍&#x1f3fb; 作者简介&#xff1a; C软件开发、Python机器学习爱好者 &#x1f5e3;️ 互动与支持&#xff1a;&#x1f4ac;评论 &…

【MQTT】paho.mqtt.cpp 库的 介绍、下载、交叉编译、MQTT客户端例子源码

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; ⏰发布时间⏰&#xff1a;2024-05-13 1…

实习大学生如何在Purple Pi OH鸿蒙开发板下调试Android串口?

本文适用于Purple Pi OH在Android固件后串口的开发与使用。触觉智能的Purple Pi OH鸿蒙开源主板&#xff0c;是华为Laval官方社区主荐的一款鸿蒙开发主板。 该主板主要针对学生党&#xff0c;极客&#xff0c;工程师&#xff0c;极大降低了开源鸿蒙开发者的入门门槛&#xff0c…

Ubuntu系统搭建Tipask开源问答系统并发布公网分享好友远程访问

文章目录 1. 前言2.Tipask网站搭建2.1 Tipask网站下载和安装2.2 Tipask网页测试2.3 cpolar的安装和注册 3. 本地网页发布3.1 Cpolar临时数据隧道3.2 Cpolar稳定隧道&#xff08;云端设置&#xff09;3.3 Cpolar稳定隧道&#xff08;本地设置&#xff09; 4. 公网访问测试5. 结语…

神经网络复习--数学相关基础知识

文章目录 矩阵范数卷积激活函数信息熵 矩阵 标量&#xff1a;一个标量就是一个单独的数向量&#xff1a;一个向量是一列数。这些数是有序排列的。通过次序中的索引&#xff0c;我们可以确定每个单独的数矩阵&#xff1a;矩阵是一个二维数组&#xff0c;其中的每个元素被两个索…

基于网络的无人海洋船舶控制

书籍&#xff1a;Network-Based Control of Unmanned Marine Vehicles 作者&#xff1a;Yu-Long Wang&#xff0c;Qing-Long Han&#xff0c;Chen Peng&#xff0c;Lang Ma 出版&#xff1a;Springer 书籍下载-《基于网络的无人海洋船舶控制》控制系统中的通信网络可能引起延…

IDC 权威认可!Aloudata 入选金融领域中数据管理分析服务最佳实践案例

近日&#xff0c;国际知名数据咨询机构 IDC 重磅发布了《IDC PeerScape&#xff1a;金融领域中数据管理分析服务最佳实践案例》报告&#xff0c;Aloudata 与招商银行联合打造的 DDH 数据研发运维一体化平台成功入选&#xff0c;Aloudata 的技术、产品实力&#xff0c;以及在金融…

英语学习笔记12——名词所有格的运用

Whose is this … ? This is my/your/his/her … 这……是谁的&#xff1f;这是我的 / 你的 / 他的 / 她的…… Whose is that … ? That is my/your/his/her … 那……是谁的&#xff1f;那是我的 / 你的 / 他的 / 她的…… 词汇 Vocabulary father n. 爸爸 口语&#xf…

【Java】引用

变量的实质是一小块内存单元&#xff0c;这一小块内存里存储着变量的值 而当变量指向一个对象时&#xff0c;这个变量就被称为引用变量 比如 A anew A(); a 就是引用变量&#xff0c;它指向了一个A对象&#xff0c;也可以说它引用了一个A对象 我们通过操纵这个a来操作A对象。…

【RabbitMQ】消息队列 - RabbitMQ的使用记录

目录 一、什么是消息队列 二、什么是RabbitMQ 三、安装RabbitMQ 3.1 安装Erlang环境 3.2 安装RabbitMQ 3.3 打开服务管理界面 3.4 常用命令 四、Python示例代码 4.1 发送数据 4.2 接收数据 一、什么是消息队列 消息队列(Message Queue)是一种用于在应用程序之间传递消…

Docker 部署 Prometheus 实现一个极简的 QPS 监控

背景 : Prometheus 是近年来最流行的开源监控框架, 其功能强大且易于使用, 拥有各种主流后端语言(Java/Go/Python/Node.js等)与各种场景(如web handler/ k8s/Nginx/MySQL等)的客户端, 并自带图形化显示页面。分享一个快速入门Prometheus 的教程, 实现一个极简的, 后端开发需要特…

ICRA 2024 成果介绍:基于 RRT* 的连续体机器人高效轨迹规划方法

近来&#xff0c;连续体机器人研究受到越来越多的关注。其灵活度高&#xff0c;可以调整形状适应动态环境&#xff0c;特别适合于微创手术、工业⽣产以及危险环境探索等应用。 连续体机器人拥有无限自由度&#xff08;DoF&#xff09;&#xff0c;为执行空间探索等任务提供了灵…

有了这玩意,分分钟开发公众号功能!

大家好&#xff0c;我是程序员鱼皮。 不论在企业、毕设还是个人练手项目中&#xff0c;很多同学或多或少都会涉及微信相关生态的开发&#xff0c;例如微信支付、开放平台、公众号等等。 一般情况下&#xff0c;我们需要到官网查阅这些模块对应的 API 接口&#xff0c;自己编写…

数据结构(Java实现):顺序表

目录 1. 线性表2.顺序表2.1自己实现一个List接口2.2 IList接口的实现2.3 测试代码 1. 线性表 线性表&#xff08;linear list&#xff09;是n个具有相同特性的数据元素的有限序列。 线性表是一种在实际中广泛使用的数据结构&#xff0c;常见的线性表&#xff1a;顺序表、链表、…

下载npm I就包错解决方案

npm i xxxx -S --legacy-peer-deps 如果包错就执行以上命令

【CSP CCF记录】202209-1 如此编码

题目 过程 C中"/"的使用 当a和被b均为int, long, char这样的整数类型&#xff0c;此时除法运算的结果为所得商的整数部分&#xff0c;例如&#xff1a;180/100&#xff0c;结果为1&#xff1b; int a 180;int b a / 100;cout << b << endl;#结果为1当…