Java基础知识中ByteArrayOutputStream流的使用方法是什么,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
API说明:此类实现一个字节输出流、其中数据被写入到字节数组中, 缓冲区在数据写入时会自动增长,关闭该流无效,关闭此流后调用方法不会有异常
/** * 存储数据的缓冲区 */ protected byte buf[]; /** * 缓冲区中的有效字节数 */ protected int count;
/** * 创建新的字节数组输出流、默认缓冲区大小是32个字节 */ public ByteArrayOutputStream() { this(32); } /** * 创建新的字节数组输出流,以指定的大小 */ public ByteArrayOutputStream(int size) { if (size < 0) { throw new IllegalArgumentException("Negative initial size: " + size); } buf = new byte[size]; }
1)write(int b)
:写入指定的字节到此字节输出流中
/** * 写入指定的字节到此字节输出流中 */ public synchronized void write(int b) { ensureCapacity(count + 1); buf[count] = (byte) b; count += 1; }
2)write(byte b[], int off, int len)
:从指定数组的下标off开始写入len个字节到该输出流中
/** * 从指定数组的下标off开始写入len个字节到该输出流中 */ public synchronized void write(byte b[], int off, int len) { if ((off < 0) || (off > b.length) || (len < 0) || ((off + len) - b.length > 0)) { throw new IndexOutOfBoundsException(); } ensureCapacity(count + len); System.arraycopy(b, off, buf, count, len); count += len; }
3)writeTo(OutputStream out)
:将此字节输出流的内容写入到指定的输出流中
/** * 将此字节输出流的内容写入到指定的输出流中 */ public synchronized void writeTo(OutputStream out) throws IOException { out.write(buf, 0, count); }
4)reset()
:重置此字节输出流,废弃此前存储的数据
/** * 重置此字节输出流,废弃此前存储的数据 */ public synchronized void reset() { count = 0; }
5)对输出流的数据进行检索
/** * 将此输出流转成字节数组输出 */ public synchronized byte toByteArray()[] { return Arrays.copyOf(buf, count); } /** * 将此输出流转成字符串输出 */ public synchronized String toString() { return new String(buf, 0, count); } /** * 通过指定编码格式将缓冲区内容转换为字符串 */ public synchronized String toString(String charsetName) throws UnsupportedEncodingException { return new String(buf, 0, count, charsetName); }
6) close()
:关闭流无效,关闭后调用其他方法不会有异常
/** * 关闭流无效,关闭后调用其他方法不会有异常 */ public void close() throws IOException { }
暂时未使用过、所以不清楚项目中什么地方使用,因此暂时了解其功能即可
第一次看到ByteArrayOutputStream的时候是在Nutch的部分源码,后来在涉及IO操作时频频发现这两个类的踪迹,觉得确实是很好用,所以把它们的用法总结一下。
以下是JDK中的记载:
public class ByteArrayOutputStream extends OutputStream
此类实现了一个输出流,其中的数据被写入一个 byte 数组。缓冲区会随着数据的不断写入而自动增长。可使用 toByteArray()和 toString()获取数据。
关闭 ByteArrayOutputStream 无效。此类中的方法在关闭此流后仍可被调用,而不会产生任何IOException。
我的个人理解是ByteArrayOutputStream是用来缓存数据的(数据写入的目标(output stream原义)),向它的内部缓冲区写入数据,缓冲区自动增长,当写入完成时可以从中提取数据。由于这个原因,ByteArrayOutputStream常用于存储数据以用于一次写入。
实例:
从文件中读取二进制数据,全部存储到ByteArrayOutputStream中。
FileInputStream fis=new FileInputStream("test"); BufferedInputStream bis=new BufferedInputStream(fis); ByteArrayOutputStream baos=new ByteArrayOutputStream(); int c=bis.read();//读取bis流中的下一个字节 while(c!=-1){ baos.write(c); c=bis.read(); } bis.close(); byte retArr[]=baos.toByteArray();
相对而言,ByteArrayInputStream比较少见。先看JDK文档中的介绍:
public class ByteArrayInputStreamextends InputStreamByteArrayInputStream
包含一个内部缓冲区,该缓冲区包含从流中读取的字节。内部计数器跟踪 read 方法要提供的下一个字节。
关闭 ByteArrayInputStream 无效。此类中的方法在关闭此流后仍可被调用,而不会产生任何 IOException。
构造函数:
ByteArrayInputStream(byte[] buf)
注意它需要提供一个byte数组作为缓冲区。
与大部分Inputstream的语义类似,可以从它的缓冲区中读取数据,所以我们可以在它的外面包装另一层的inputstream以使用我们需要的读取方法。
个人认为一个比较好的用途是在网络中读取数据包,由于数据包一般是定长的,我们可以先分配一个够大的byte数组,比如byte buf[]=new byte[1024];
然后调用某个方法得到网络中的数据包,例如:
Socket s=...; DataInputStream dis=new DataInputStream(s.getInputStream()); dis.read(buf);//把所有数据存到buf中 ByteArrayInputStream bais=new ByteArrayInputStream(buf); //把刚才的部分视为输入流 DataInputStream dis_2=new DataInputStream(bais); //现在可以使用dis_2的各种read方法,读取指定的字节
比如第一个字节是版本号,dis_2.readByte();
等等……
上面的示例的两次包装看上去有点多此一举,但使用ByteArrayInputStream的好处是关掉流之后它的数据仍然存在。
看完上述内容,你们掌握Java基础知识中ByteArrayOutputStream流的使用方法是什么的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。