前言:
目前我们对“java 流处理”大体比较注意,朋友们都需要了解一些“java 流处理”的相关内容。那么小编同时在网络上汇集了一些有关“java 流处理””的相关内容,希望大家能喜欢,咱们快快来了解一下吧!Java I/O流按是否直接读写数据,可以分为节点流(Node Streams)与处理流(Processing Streams)两大类。
节点流
节点流是直接读写数据的流,一般应该与物理存储或网络资源交互,代表数据的实际来源(Source)或目标(Sink)。节点流仅负责原始数据的读取或写入操作,不提供附加的数据处理功能。例如文件操作的节点流FileInputStream和FileOutputStream直接与文件系统交互,分别用于从文件读取字节和向文件写入字节,仅提供简单的字节或字节数组的read()方法和write()方法。
处理流
也称为装饰器流(Decorator Streams),需要建立在节点流或其他处理流之上,为原始数据流增添额外的包括缓冲、数据格式转换、数据压缩或解压缩等处理功能。处理流不直接连接到物理存储,而是对底层流的操作进行了增强。典型的处理流如增加缓冲功能的BufferedInputStream和BufferedOutputStream、数据格式转换DataInputStream和DataOutputStream等。
节点流与处理流的区别
节点流直接与物理介质交互,是数据传输的基础层,也是最终读写数据的流。
处理流是对节点流的封装,提供了数据处理功能,如提高读写效率的缓冲、字符编码转换等。
处理流可以连接在节点流或其他处理流之后,形成处理流链,灵活地组合多种数据处理能力。
实例:使用节点流与处理流结合复制文件
以下是一个结合使用节点流与处理流(增加缓冲功能)来复制文本文件的示例。
首先创建了直接与文件交互的节点流FileReader和FileWriter。然后,为了提高读写效率,用BufferedReader和PrintWriter(处理流)包裹了这两个节点流。这样,在复制文件的过程中,不再是使用节点流方式的只能按字符方式读写,而可以使用处理流中的readLine()和println()方法按字符串读写了,提高了文件复制的速度和效率。
/* 使用处理流实现文本文件的复制 输出流一定要关闭,否则可能会出现数据丢失*/import java.io.*;public class TestBufferedStreams { public static void main(String[] args) { if (args.length != 2){ System.out.println( "Usage: java TestBufferedStreams inputFile outpouFile"); System.exit(0); } try { //节点流 FileReader input = new FileReader(args[0]); //处理流 BufferedReader bufInput = new BufferedReader(input); //节点流 //在文件不存在时会创建文件,文件存在时默认会覆盖原文件内容 FileWriter output = new FileWriter(args[1]); //追加内容需要使用如下构造方法: //FileWriter(String fileName, boolean append) //处理流 PrintWriter printOutput = new PrintWriter(output); // 读取第一行:处理流 String line = bufInput.readLine(); while ( line != null ) { // 将读取的行写入输出流:处理流 printOutput.println(line); // 读取下一行:处理流 line = bufInput.readLine(); } bufInput.close(); //Why CLOSE is NEEDED? printOutput.close(); } catch (IOException e) { e.printStackTrace(); } }}
标签: #java 流处理