Java中的BufferedInputStream与BufferedOutputStream使用示例
BufferedInputStream
BufferedInputStream是缓冲输入流。它继承于FilterInputStream。
BufferedInputStream的作用是为另一个输入流添加一些功能,例如,提供“缓冲功能”以及支持“mark()标记”和“reset()重置方法”。
BufferedInputStream本质上是通过一个内部缓冲区数组实现的。例如,在新建某输入流对应的BufferedInputStream后,当我们通过read()读取输入流的数据时,BufferedInputStream会将该输入流的数据分批的填入到缓冲区中。每当缓冲区中的数据被读完之后,输入流会再次填充数据缓冲区;如此反复,直到我们读完输入流数据位置。
BufferedInputStream函数列表:
BufferedInputStream(InputStreamin) BufferedInputStream(InputStreamin,intsize) synchronizedintavailable() voidclose() synchronizedvoidmark(intreadlimit) booleanmarkSupported() synchronizedintread() synchronizedintread(byte[]buffer,intoffset,intbyteCount) synchronizedvoidreset() synchronizedlongskip(longbyteCount)
示例代码:
关于BufferedInputStream中API的详细用法,参考示例代码(BufferedInputStreamTest.java):
importjava.io.BufferedInputStream; importjava.io.ByteArrayInputStream; importjava.io.File; importjava.io.InputStream; importjava.io.FileInputStream; importjava.io.IOException; importjava.io.FileNotFoundException; importjava.lang.SecurityException; /** *BufferedInputStream测试程序 * *@authorskywang */ publicclassBufferedInputStreamTest{ privatestaticfinalintLEN=5; publicstaticvoidmain(String[]args){ testBufferedInputStream(); } /** *BufferedInputStream的API测试函数 */ privatestaticvoidtestBufferedInputStream(){ //创建BufferedInputStream字节流,内容是ArrayLetters数组 try{ Filefile=newFile("bufferedinputstream.txt"); InputStreamin= newBufferedInputStream( newFileInputStream(file),512); //从字节流中读取5个字节。“abcde”,a对应0x61,b对应0x62,依次类推... for(inti=0;i<LEN;i++){ //若能继续读取下一个字节,则读取下一个字节 if(in.available()>=0){ //读取“字节流的下一个字节” inttmp=in.read(); System.out.printf("%d:0x%s\n",i,Integer.toHexString(tmp)); } } //若“该字节流”不支持标记功能,则直接退出 if(!in.markSupported()){ System.out.println("makenotsupported!"); return; } //标记“当前索引位置”,即标记第6个位置的元素--“f” //1024对应marklimit in.mark(1024); //跳过22个字节。 in.skip(22); //读取5个字节 byte[]buf=newbyte[LEN]; in.read(buf,0,LEN); //将buf转换为String字符串。 Stringstr1=newString(buf); System.out.printf("str1=%s\n",str1); //重置“输入流的索引”为mark()所标记的位置,即重置到“f”处。 in.reset(); //从“重置后的字节流”中读取5个字节到buf中。即读取“fghij” in.read(buf,0,LEN); //将buf转换为String字符串。 Stringstr2=newString(buf); System.out.printf("str2=%s\n",str2); in.close(); }catch(FileNotFoundExceptione){ e.printStackTrace(); }catch(SecurityExceptione){ e.printStackTrace(); }catch(IOExceptione){ e.printStackTrace(); } } }
程序中读取的bufferedinputstream.txt的内容如下:
abcdefghijklmnopqrstuvwxyz 0123456789 ABCDEFGHIJKLMNOPQRSTUVWXYZ
运行结果:
0:0x61 1:0x62 2:0x63 3:0x64 4:0x65 str1=01234 str2=fghij
BufferedOutputStream
BufferedOutputStream是缓冲输出流。它继承于FilterOutputStream。
BufferedOutputStream的作用是为另一个输出流提供“缓冲功能”。
BufferedOutputStream函数列表:
BufferedOutputStream(OutputStreamout) BufferedOutputStream(OutputStreamout,intsize) synchronizedvoidclose() synchronizedvoidflush() synchronizedvoidwrite(byte[]buffer,intoffset,intlength) synchronizedvoidwrite(intoneByte)
示例代码:
关于BufferedOutputStream中API的详细用法,参考示例代码(BufferedOutputStreamTest.java):
importjava.io.BufferedOutputStream; importjava.io.File; importjava.io.OutputStream; importjava.io.FileOutputStream; importjava.io.IOException; importjava.io.FileNotFoundException; importjava.lang.SecurityException; importjava.util.Scanner; /** *BufferedOutputStream测试程序 * *@authorskywang */ publicclassBufferedOutputStreamTest{ privatestaticfinalintLEN=5; //对应英文字母“abcddefghijklmnopqrsttuvwxyz” privatestaticfinalbyte[]ArrayLetters={ 0x61,0x62,0x63,0x64,0x65,0x66,0x67,0x68,0x69,0x6A,0x6B,0x6C,0x6D,0x6E,0x6F, 0x70,0x71,0x72,0x73,0x74,0x75,0x76,0x77,0x78,0x79,0x7A }; publicstaticvoidmain(String[]args){ testBufferedOutputStream(); } /** *BufferedOutputStream的API测试函数 */ privatestaticvoidtestBufferedOutputStream(){ //创建“文件输出流”对应的BufferedOutputStream //它对应缓冲区的大小是16,即缓冲区的数据>=16时,会自动将缓冲区的内容写入到输出流。 try{ Filefile=newFile("out.txt"); OutputStreamout= newBufferedOutputStream( newFileOutputStream(file),16); //将ArrayLetters数组的前10个字节写入到输出流中 out.write(ArrayLetters,0,10); //将“换行符\n”写入到输出流中 out.write('\n'); //TODO! //out.flush(); readUserInput(); out.close(); }catch(FileNotFoundExceptione){ e.printStackTrace(); }catch(SecurityExceptione){ e.printStackTrace(); }catch(IOExceptione){ e.printStackTrace(); } } /** *读取用户输入 */ privatestaticvoidreadUserInput(){ System.out.println("pleaseinputatext:"); Scannerreader=newScanner(System.in); //等待一个输入 Stringstr=reader.next(); System.out.printf("theinputis:%s\n",str); } }
运行结果:
生成文件“out.txt”,文件的内容是“abcdefghij”。
分步测试:分别按照下面3种步骤测试程序,来查看缓冲区大小以及flush()的作用。
第1种:原始程序
(1)运行程序。在程序等待用户输入时,查看“out.txt”的文本内容;发现:内容为空。
(2)运行程序。在用户输入之后,查看“out.txt”的文本内容;发现:内容为“abcdefghij”。
从中,我们发现(01)和(02)的结果不同;之所以(01)中的out.txt内容为空,是因为out.txt对应的缓冲区大小是16字节,而我们只写入了11个字节,所以,它不会执行清空缓冲操作(即,将缓冲数据写入到输出流中)。
而(02)对应out.txt的内容是“abcdefghij”,是因为执行了out.close(),它会关闭输出流;在关闭输出流之前,会将缓冲区的数据写入到输出流中。
注意:重新测试时,要先删除out.txt。
第2种:在readUserInput()前添加如下语句
out.flush();
这句话的作用,是将“缓冲区的内容”写入到输出流中。
(1)运行程序。在程序等待用户输入时,查看“out.txt”的文本内容;发现:内容为“abcdefghij”。
(2)运行程序。在用户输入之后,查看“out.txt”的文本内容;发现:内容为“abcdefghij”。
从中,我们发现(01)和(02)结果一样,对应out.txt的内容都是“abcdefghij”。这是因为执行了flush()操作,它的作用是将缓冲区的数据写入到输出流中。
注意:重新测试时,要先删除out.txt!
第3种:在第1种的基础上,将
out.write(ArrayLetters,0,10);
修改为
out.write(ArrayLetters,0,20);
(1)运行程序。在程序等待用户输入时,查看“out.txt”的文本内容;发现:内容为“abcdefghijklmnopqrst”(不含回车)。
(02)运行程序。在用户输入之后,查看“out.txt”的文本内容;发现:内容为“abcdefghijklmnopqrst”(含回车)。
从中,我们发现(01)运行结果是“abcdefghijklmnopqrst”(不含回车)。这是因为,缓冲区的大小是16,而我们通过out.write(ArrayLetters,0,20)写入了20个字节,超过了缓冲区的大小;这时,会直接将全部的输入都写入都输出流中,而不经过缓冲区。
(3)运行结果是“abcdefghijklmnopqrst”(含回车),这是因为执行out.close()时,将回车符号'\n'写入了输出流中。
注意:重新测试时,要先删除out.txt!