Java I/O编程

java i/o原理

基本概念:

I/O(Input/Output)数据源(Data Source)数据宿(Data Sink)

Java中把不同的数据源与程序间的数据传输都抽象表述为"流"(Stream),java.io包中定义了多种I/O流类型实现数据I/O功能。

I/O流分类:

输入流(Input Stream)和输出流(Output Stream)节点流(Node Stream)和处理流(Processing Stream)字符流(Character Stream)和字节流(Byte Stream)

输入流和输出流

按照数据流动的方向，java流可分为输入流(Input Stream)和输出流(Output Stream)

输入流只能从中读取数据,而不能向其写出数据;输出流则只能向其写出数据,而不能从中读取数据特例:java.io.RandomAccessFile类

节点流和处理流

根据数据流所关联的是数据源还是其他数据流,可分为节点流(Node Stream)和处理流(Processing Stream)

节点流直接连接到数据源处理流是对一个已存在的流的连接和封装,通过封装的流的功能调用实现增强的数据读/写功能,处理流并不直接连接到数据源.

字符流和字节流

按传输数据的"颗粒大小"划分,可分为字符流(Character Stream)和字节流(Byte Stream)

字节流以字节为单位进行数据传输,每次传送一个或多个字节;字符流以字符为单位进行数据传输，每次传送一个或多个字符.

Java命名惯例:

凡是以InputStream或OutputStream结尾的类型均为字节流,凡是以Reader或Writer结尾的均为字符流。

InputStream

抽象类java.io.InputStream是所有字节输入流类型的父类,该类中定义了以字节为单位读取数据的基本方法,并在其子类中进行了分化和实现.

三个基本的read方法:

int read()int read(byte[] buffer)int read(byte[] buffer,int offset,int length)

其他方法:

void close()int available()skip(long n)boolean markSupported()

InputStream类层次

OutputStream

java.io.OutputStream与java.io.InputStream对应,是所有字节输出流类型的抽象父类。

三个基本的write方法:

void write(int c)void write(byte[] buffer)void write(byte[] buffer,int offset,int length)

其他方法:

void close()void flush()

OutputStream类层次

Reader

抽象类java.io.Reader是所有字符输入流类型的父类,其中声明了用于读取字符流的有关方法.

三个基本的read方法:

int read()int read(char[] cbuf)int read(char[] cbuf,int offset,int length)

其他方法:

void close()boolean ready()skip(long n)boolean markSupported()void mark(int readAheadLimit)void reset()

Reader类层次

Writer

java.io.Writer与java.io.Reader类对应,是所有字符输出流类型的共同父类.

五个基本的write方法:

void write(int c)void write(char[] cbuf)void write(char[] cbuf,int offset,int leng)void write(String string)void write(String string,int offset,int length)

其它方法:

void close()void flush()

Writer类层次

常用I/O流类型

FileInputStream/FileOutputStream

FileInputStream用于读取本地文件中字节数据,FileOutputStram用于将字节数据写到文件.

使用字节流实现文件的复制

Java代码

importjava.io.FileInputStream;importjava.io.FileOutputStream;importjava.io.IOException;publicclassCopyFile{publicstaticvoidmain(String[]args){try{FileInputStreamfis=newFileInputStream("a.jpg");FileOutputStreamfos=newFileOutputStream("temp.jpg");intread=fis.read();while(read!=-1){fos.write(read);read=fis.read();}fis.close();fos.close();}catch(IOExceptione){e.printStackTrace();}}}

FileReader/FileWriter

FileReader用于以字符为单位读取文本文件,FileWriter类用于将字符数据写到文本文件中

使用字符流实现文件的复制

Java代码

importjava.io.*;publicclassTest{publicstaticvoidmain(String[]args){try{FileReaderinput=newFileReader("a.txt");FileWriteroutput=newFileWriter("temp.txt");intread=input.read();while(read!=-1){output.write(read);read=input.read();}input.close();output.close();}catch(IOExceptione){System.out.println(e);}}}

BufferedReader/BufferedWriter

BufferedReader用于缓冲读取字符,BufferedWriter则是供字符的缓存写出功能.

使用字符处理流实现文件的复制

Java代码

importjava.io.*;publicclassTest{publicstaticvoidmain(String[]args){try{FileReaderinput=newFileReader("Test.java");BufferedReaderbr=newBufferedReader(input);FileWriteroutput=newFileWriter("temp.txt");BufferedWriterbw=newBufferedWriter(output);Strings=br.readLine();while(s!=null){bw.write(s);bw.newLine();s=br.readLine();}br.close();bw.close();}catch(IOExceptione){e.printStackTrace();}}}

InputStreamReader

InputStreamReader可封装字节输入流并从中读取字节数据,然后将之转换为字符.转换时所使用的字符编码可以在构造方法中显示指定,也可以使用平台的默认字符编码,其构造方法格式为:public InputStreamReader(InputStream in)public InputStreamReader(InputStream in,String enc)

OutputStream Writer

与InputStreamReader对应,OutputStreamWriter可按照特定的字符编码规则把字符转化为字节并写出到它所封装的字节输出流.

PrintStream

PrintStream在OutputStream基础之上提供了增强的功能,即可以方便地输出各种类型数据(而不仅限于byte型)的格式化表示形式.PrintStream的方法从不抛出IOException

PrintWriter

PrintWriter提供了PrintStream的所有打印方法,其方法也从不抛出IOException、与PrintStream的区别:作为处理流使用时,PrintStream只能封装OutputStream类型的字节流,而PrintWriter既可以封装OutputStream,还能够封装writer类型字符输出流并增强其功能

DataInputStream/DataOutputStream

二者分别实现DataInput/DataOutput接口DataInputStream能够以一种与机器无关的方式,直接从底层字节输入流读取java基本类型和String类型的数据.DataOutputStream则能够直接将java基本类型和String类型数据写出到其他的字节输出流。Java代码

importjava.io.*;publicclassTest{publicstaticvoidmain(Stringargs[]){try{FileOutputStreamfos;DataOutputStreamdos;FileInputStreamfis;DataInputStreamdis;fos=newFileOutputStream("myfile.data");dos=newDataOutputStream(fos);dos.writeUTF("休.格兰特");dos.writeInt(40);dos.close();fis=newFileInputStream("myfile.data");dis=newDataInputStream(fis);System.out.println("name:"+dis.readUTF());System.out.println("age:"+dis.readInt());fis.close();}catch(IOExceptione){System.out.println(e);}}}

CharArrayReader/CharArrayWriter

charArrayReader实现了一个可用作字符输入流的字符缓冲区.CharArrayWriter实现了一个可当做Writer使用的字符输出缓存区.Java代码

importjava.io.*;publicclassMyReader{publicvoidgetInfo(Readerreader){try{intb=reader.read();while(b!=-1){System.out.print((char)b);b=reader.read();}System.out.println();}catch(IOExceptione){e.printStackTrace();}}}

Java代码

importjava.io.*;publicclassTestCharArrayReader{publicstaticvoidmain(String[]args){char[]b={‘I’,”,’a’,’m’,”,’S’,’a’,’i’,’l’,’i’,’n’,’g’,’!’};CharArrayReadercar=newCharArrayReader(b);MyReadermr=newMyReader();mr.getInfo(car);}}

Java代码

importjava.io.*;importjava.util.Date;publicclassTestCharArrayWriter{publicstaticvoidmain(String[]args){try{BufferedReaderbr=newBufferedReader(newFileReader("a.txt"));Strings;while((s=br.readLine())!=null){System.out.println(s);}}catch(IOExceptione){CharArrayWritercw=newCharArrayWriter();PrintWriterpw=newPrintWriter(cw,true);e.printStackTrace(pw);//char[]ca=cw.toCharArray();Stringinfo=cw.toString();Datetime=newDate();//将time和info信息写入数据库—System.out.println("出错时间:"+time);System.out.println("错误信息:\n"+info);}}}

标准I/O重定向

标准输入重定向

Java代码

importjava.io.*;publicclassTestSetInput{publicstaticvoidmain(String[]args){try{//FileInputStreamfis=newFileInputStream("source.txt");//System.setIn(fis);intavg=0;inttotal=0;intcount=0;intnum=0;inti;BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));Strings=br.readLine();while(s!=null&&!s.equals("over")){i=Integer.parseInt(s);num++;total+=i;avg=total/num;System.out.println("num="+num+"\ttotal="+total+"\tavg="+avg);s=br.readLine();}}catch(Exceptione){e.printStackTrace();}}}

标准输出/标准错误输出重定向

Java代码

importjava.io.*;importjava.util.Date;publicclassTestSetOutput{publicstaticvoidmain(String[]args){PrintStreamps=null;PrintStreamps_error=null;try{ps=newPrintStream(newFileOutputStream("output.txt",true));System.setOut(ps);ps_error=newPrintStream(newFileOutputStream("errorLog.txt",true));System.setErr(ps_error);intavg=0;inttotal=0;intcount=0;intnum=0;inti;BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in));Strings=br.readLine();while(s!=null&&!s.equals("over")){i=Integer.parseInt(s);num++;total+=i;avg=total/num;System.out.println("num="+num+"\ttotal="+total+"\tavg="+avg);s=br.readLine();}}catch(Exceptione){System.err.println("出错时间:"+newDate());System.err.print("错误信息:");e.printStackTrace(System.err);}finally{try{ps.close();ps_error.close();}catch(Exceptione1){System.err.println("出错时间:"+newDate());System.err.print("错误信息:");e1.printStackTrace(System.err);}}}}

属性导出/导入

Java代码

importjava.io.*;importjava.util.Properties;publicclassLoadProperties{publicstaticvoidmain(String[]args){try{Propertiesps=newProperties();FileReaderfr=newFileReader("props.txt");ps.load(fr);fr.close();ps.list(System.out);}catch(Exceptione){e.printStackTrace();}}}

Java代码

importjava.io.*;importjava.util.Properties;publicclassSaveProperties{publicstaticvoidmain(String[]args){try{Propertiesps=newProperties();ps.setProperty("name","Scott");ps.setProperty("password","Tiger");FileWriterfw=newFileWriter("props.txt");ps.store(fw,"loginfo");fw.close();}catch(Exceptione){e.printStackTrace();}}}

实现文件随即存/取操作

Java代码

importjava.io.File;importjava.io.IOException;importjava.io.RandomAccessFile;publicclassTestRandomAccessFile{privateFilefile;publicstaticvoidmain(String[]args){TestRandomAccessFiletraf=newTestRandomAccessFile();traf.init();traf.record("Billy",22);traf.listAllRecords();}publicvoidrecord(Stringrecord_breaker,inttimes){try{RandomAccessFileraf=newRandomAccessFile(file,"rw");booleanflag=false;while(raf.getFilePointer()<raf.length()){Stringname=raf.readUTF();if(record_breaker.equals(name)){raf.writeInt(times);flag=true;break;}else{raf.skipBytes(4);}}if(!flag){raf.writeUTF(record_breaker);raf.writeInt(times);}raf.close();}catch(Exceptione){e.printStackTrace();}}publicvoidinit(){if(file==null){file=newFile("record.txt");try{file.createNewFile();}catch(IOExceptione){e.printStackTrace();}}}publicvoidlistAllRecords(){try{RandomAccessFileraf=newRandomAccessFile(file,"r");while(raf.getFilePointer()<raf.length()){Stringname=raf.readUTF();inttimes=raf.readInt();System.out.println("name:"+name+"\trecord:"+times);}raf.close();}catch(Exceptione){e.printStackTrace();}}}

使用临时文件

Java代码

importjava.io.*;importjava.awt.event.*;importjavax.swing.*;publicclassTestTempFileimplementsActionListener{privateFiletempPath;publicstaticvoidmain(Stringargs[]){TestTempFilettf=newTestTempFile();ttf.init();ttf.createUI();}publicvoidcreateUI(){JFrameframe=newJFrame();JButtonjb=newJButton("创建临时文件");jb.addActionListener(this);frame.add(jb,"North");frame.setSize(200,100);frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);frame.setVisible(true);}publicvoidinit(){tempPath=newFile("temp");if(!tempPath.exists()||!tempPath.isDirectory()){tempPath.mkdir();//如果不存在，则创建该文件夹}}publicvoidactionPerformed(ActionEvente){try{//在tempPath路径下创建临时文件"mytempfileXXXX.tmp"//XXXX是系统自动产生的随机数,tempPath对应的路径应事先存在FiletempFile=File.createTempFile("mytempfile",".txt",null);System.out.println(tempFile.getAbsolutePath());FileWriterfout=newFileWriter(tempFile);PrintWriterout=newPrintWriter(fout);out.println("someinfo!");out.close();//注意：如无此关闭语句，文件将不能删除//tempFile.delete();tempFile.deleteOnExit();}catch(IOExceptione1){System.out.println(e1);}}}

对象序列化

基本概念

对象的持久性(Object Persistance)长久保持一个对象的状态并在需要时获取该对象的信息以重新构造一个状态完全相同的对象对象序列化(Object Serialization)通过写出对象的状态数据来记录一个对象对象序列化的主要任务，写出对象信息，并遍历该对象对象的引用，从而建立一个完整的序列化流。

实现对象序列化

要序列化一个对象,其所属的类必须实现一些两种接口之一:

java.io.Serializable

java.io.Externalizable

java.io.ObjectOutputStream/ObjectInputStream类分别提供了对象的序列化和反序列化功能。

对象序列化APi层次

对象序列化过程中的数据保护

标记性接口Serializable

在对象序列化过程中,其所属类的static属性和方法代码不会被序列化处理.

对于个别不希望被序列化的非static属性,可以在属性声明时使用transient关键字进行标明.

力微休负重，言轻莫劝人。