InputStream此抽象类是表示字节输入流的所有类的超类。
我们从输入流中读取数据最常用的方法基本上就是如下3个read()方法了:
1、read()方法,这个方法从输入流中读取数据的下一个字节。返回 0到255范围内的int字节值。如果因为已经到达流末尾而没有可用的字节,则返回值-1。
2、read(byte[]b,intoff,intlen)方法,将输入流中最多 len个数据字节读入byte数组。尝试读取len个字节,但读取的字节也可能小于该值。以整数形式返回实际读取的字节数。
3、read(byte[]b)方法,从输入流中读取一定数量的字节,并将其存储在缓冲区数组 b中。以整数形式返回实际读取的字节数。
第一个方法典型的确定就是处理效率低,不是某些特殊情况,很少使用它,下面说说第2个方法跟第3个方法,第3个方法的本本质其实就是第2个方法的特殊情况,效果等同于:
read(b, 0, b.length)
所以这里把他们放着一起讨论。
从第2个方法的API文档说明来看:“将输入流中最多 len个数据字节读入byte数组。尝试读取len个字节,但读取的字节也可能小于该值。以整数形式返回实际读取的字节数。”,最多读取len个字节,这究竟是何意?API文档并没有详细说明。是不是就意味着有可能(注意这里是有可能而不是一定,)读取不到len个字节呢?答案是“是的”。虽然造成这种情况的原因是什么个人并不知道,但是我们可以通过例子来发现这种情况,下面是源代码(由于只是简单的示例,所以代码也就随便写了):
ServerSocket端:
- packagemyspider;
- importjava.io.File;
- importjava.io.FileOutputStream;
- importjava.io.IOException;
- importjava.io.InputStream;
- importjava.net.ServerSocket;
- importjava.net.Socket;
- /**
- *
- *@authormark
- */
- publicclassMyServerSocket{
- publicstaticvoidmain(String[]args)throwsIOException{
- ServerSocketss=newServerSocket(8888);
- System.out.println("runing");
- while(true){
- byte[]b=newbyte[22480];
- intreadBytes=0;
- Sockets=ss.accept();
- InputStreamis=s.getInputStream();
- while(readBytes<22480){
- intread=is.read(b,readBytes,22480-readBytes);
- System.out.println(read);
- if(read==-1){
- break;
- }
- readBytes+=read;
- }
- Filef=newFile("F:\project\bocln_nacec\xml\ey.xml");
- if(!f.exists()){
- f.createNewFile();
- System.out.println("creat"+f.toString());
- }
- FileOutputStreamfos=newFileOutputStream(f);
- fos.write(b,0,readBytes);
- fos.flush();
- fos.close();
- System.out.println("complete");
- is.close();
- s.close();
- }
- }
- }
Socket端:
- packagemyspider;
- importjava.io.File;
- importjava.io.FileInputStream;
- importjava.io.IOException;
- importjava.io.InputStream;
- importjava.io.OutputStream;
- importjava.net.Socket;
- importjava.net.UnknownHostException;
- /**
- *
- *@authormark
- */
- publicclassMySocket{
- publicstaticvoidmain(String[]args)throwsUnknownHostException,IOException{
- Sockets=newSocket("127.0.0.1",8888);
- OutputStreamos=s.getOutputStream();
- Filef=newFile("F:\project\bocln_nacec\xml\ye.xml");
- InputStreamis=newFileInputStream(f);
- byte[]b=newbyte[22480];
- inti=is.read(b);
- is.close();
- os.write(b,0,i);
- os.flush();
- os.close();
- s.close();
- }
- }
先运行MyServerSocket,让后多次运行MySocket,这是控制台的输出结果(ye.xml文件长度为20389):
- runing
- 20389
- -1
- creatF:projectocln_nacecxmley.xml
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 8760
- 11629
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 3760
- 620
- 16009
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 8760
- 11629
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 8760
- 11629
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 8760
- 11629
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
- 20389
- -1
- complete
通过观察发现,在大多数情况下,我们能够用is.read(b, readBytes, 22480 - readBytes)一次性就读完整个文件,但是还是有极少数情况,我们需要两次(如36、37两行)甚至两次以上(如58、59、60)调用is.read(b, readBytes, 22480 - readBytes)方法才能把整个文件读取完。这里由于文件最长只有20389,所以我们能读到的最大字节数也就是20389而不会是22480了。
那么我们怎样写代码才能保证在数据流没有到达末尾的情况下读取到自己想要的长度的字节数据呢?我们可以这样写: