百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

5分钟课堂:Java 节点流与处理流 java使用流处理数据

yuyutoo 2024-10-14 16:21 4 浏览 0 评论

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();
    }
  }
}

相关推荐

自卑的人容易患抑郁症吗?(自卑会导致抑郁吗)

Filephoto[Photo/IC]Lowself-esteemmakesusfeelbadaboutourselves.Butdidyouknowthatovert...

中考典型同(近)义词组(同义词考题)

中考典型同(近)义词组...

WPF 消息传递简明教程(wpf messagebox.show)

...

BroadcastReceiver的原理和使用(broadcast-suppression)

一、使用中注意的几点1.动态注册、静态注册的优先级在AndroidManifest.xml中静态注册的receiver比在代码中用registerReceiver动态注册的优先级要低。发送方在send...

Arduino通过串口透传ESP 13板与java程序交互

ESP13---是一个无线板子,配置通过热点通信Arduino通过串口透传ESP13板与java程序交互...

zookeeper的Leader选举源码解析(zookeeper角色选举角色包括)

作者:京东物流梁吉超zookeeper是一个分布式服务框架,主要解决分布式应用中常见的多种数据问题,例如集群管理,状态同步等。为解决这些问题zookeeper需要Leader选举进行保障数据的强一致...

接待外国人英文口语(接待外国友人的英语口语对话)

接待外国人英文口语询问访客身份:  MayIhaveyourname,please?  请问您贵姓?  Whatcompanyareyoufrom?  您是哪个公司的?  Could...

一文深入理解AP架构Nacos注册原理

Nacos简介Nacos是一款阿里巴巴开源用于管理分布式微服务的中间件,能够帮助开发人员快速实现动态服务发现、服务配置、服务元数据及流量管理等。这篇文章主要剖析一下Nacos作为注册中心时其服务注册与...

Android面试宝典之终极大招(android面试及答案)

以下内容来自兆隆IT云学院就业部,根据多年成功就业服务经验,以及职业素养课程部分内容,归纳总结:18.请描述一下Intent和IntentFilter。Android中通过Intent...

除了Crontab,Swoole Timer也可以实现定时任务的

一般的定时器是怎么实现的呢?我总结如下:1.使用Crontab工具,写一个shell脚本,在脚本中调用PHP文件,然后定期执行该脚本;2.ignore_user_abort()和set_time_li...

Spark源码阅读:DataFrame.collect 作业提交流程思维导图

本文分为两个部分:作业提交流程思维导图关键函数列表作业提交流程思维导图...

使用Xamarin和Visual Studio开发Android可穿戴设备应用

搭建开发环境我们需要做的第一件事情是安装必要的工具。因此,你需要首先安装VisualStudio。如果您使用的是VisualStudio2010,2012或2013,那么请确保它是一个专业版本或...

Android开发者必知的5个开源库(android 开发相关源码精编解析)

过去的时间里,Android开发逐步走向成熟,一个个与Android相关的开发工具也层出不穷。不过,在面对各种新鲜事物时,不要忘了那些我们每天使用的大量开源库。在这里,向大家介绍的就是,在这个任劳任怨...

Android事件总线还能怎么玩?(android实现事件处理的步骤)

顾名思义,AndroidEventBus是一个Android平台的事件总线框架,它简化了Activity、Fragment、Service等组件之间的交互,很大程度上降低了它们之间的耦合,使我们的代码...

Android 开发中文引导-应用小部件

应用小部件是可以嵌入其它应用(例如主屏幕)并收到定期更新的微型应用视图。这些视图在用户界面中被叫做小部件,并可以用应用小部件提供者发布。可以容纳其他应用部件的应用组件叫做应用部件的宿主(1)。下面的截...

取消回复欢迎 发表评论: