当前位置: 首页 > news >正文

8、SequenceInputStream的源码和Vector.class的一些函数说明(windows操作系统,JDK8)

一、SequenceInputStream源码——可以顺序读取多个输入Stream的装饰器类

  SequenceInputStream.class 的UML关系图,如下所示:
clipboard

  SequenceInputStream.class的源码,如下所示:

package java.io;
import java.io.InputStream;
import java.util.Enumeration;
import java.util.Vector;public
class SequenceInputStream extends InputStream {//顺序(序列化)装载多个被装饰输入Stream的集合,一般是Vector实例Enumeration<? extends InputStream> e;InputStream in;//顺序(序列化)装载多个被装饰输入Stream的集合中当前正在被SequenceInputStream 对象使用的被装饰的输入Stream//构造函数,传入一个顺序(序列化)装载多个被装饰输入Stream的集合public SequenceInputStream(Enumeration<? extends InputStream> e) {this.e = e;try {nextStream();} catch (IOException ex) {// This should never happenthrow new Error("panic");}}//构造函数,可以将2个被装饰的输入Stream放入到集合中public SequenceInputStream(InputStream s1, InputStream s2) {Vector<InputStream> v = new Vector<>(2);v.addElement(s1);v.addElement(s2);e = v.elements();try {nextStream();} catch (IOException ex) {// This should never happenthrow new Error("panic");}}//获取集合中下一个被装饰的输入Streamfinal void nextStream() throws IOException {if (in != null) {in.close();//先关闭当前被装饰的输入Stream}if (e.hasMoreElements()) {//如果集合中还有被装饰的输入Streamin = (InputStream) e.nextElement();//获取集合中下一个被装饰的输入Streamif (in == null)throw new NullPointerException();//如果集合中下一个被装饰的输入Stream为null,抛出一个NullPointerException}else in = null;//如果集合中没有了被装饰的输入Stream,将当前正在使用的被装饰的输入Stream置为null}//判断当前正在使用的被装饰的输入Stream是否还有可以读取的字节数据public int available() throws IOException {if (in == null) {return 0; // no way to signal EOF from available()}return in.available();}//从SequenceInputStream 对象的集合(该集合放着多个被装饰的输入Stream)中读取1个字节public int read() throws IOException {while (in != null) {//如果in!=null,则说明当前这个SequenceInputStream 对象的集合中还有被装饰的输入Stream没有关闭int c = in.read();//从当前正在使用的被装饰的被装饰输入Stream中读取1个字节if (c != -1) {//c != -1说明从当前正在使用的被装饰输入Stream中读取到了字节return c;//返回读取到的这个字节}nextStream();//如果c==-1说明当前正在使用的被装饰输入Stream中字节(byte)数据已经读完,获取SequenceInputStream 对象的集合中下一个被装饰的输入Stream}return -1;//如果SequenceInputStream 对象的集合中所有被装饰的输入Stream中的字节(byte)数据都已经读完,返回-1}//从SequenceInputStream 对象的集合(该集合放着多个被装饰的输入Stream)中读取len个字节,放入到byte[]数组b的[off,off+len)(左闭右开,不包括off+len)索引位置public int read(byte b[], int off, int len) throws IOException {if (in == null) {//如果in==null,则说明当前这个SequenceInputStream 对象的集合中所有被装饰的输入Stream都已经关闭return -1;} else if (b == null) {throw new NullPointerException();//如果byte[]数组b==null,抛出一个NullPointerException} else if (off < 0 || len < 0 || len > b.length - off) {//相当于off + len > b.length(源码中这样写代码的好处我没看出来)throw new IndexOutOfBoundsException();} else if (len == 0) {return 0;//要从SequenceInputStream 对象的集合(该集合放着至少2个被装饰的输入Stream)中读取的len个字节==0时,返回0}do {int n = in.read(b, off, len);//从当前正在使用的被装饰的输入Stream中读取len个字节,放入到byte[]数组b的[off,off+len)(左闭右开,不包括off+len)索引位置if (n > 0) {return n;//只要能从当前正在使用的被装饰的输入Stream中读取到字节,则返回读取的数量}nextStream();//此时n==-1,说明当前正在使用的被装饰的输入Stream中字节(byte)数据已经读完,获取SequenceInputStream 对象的集合中下一个被装饰的输入Stream} while (in != null);//SequenceInputStream 对象的集合中下一个被装饰的输入Stream为null时,跳出循环,返回-1return -1;}//顺序关闭SequenceInputStream 对象的集合中所有被装饰的输入Streampublic void close() throws IOException {do {nextStream();} while (in != null);}
}
1.1、SequenceInputStream的read()函数和nextStream()函数
package java.io;
import java.io.InputStream;
import java.util.Enumeration;
import java.util.Vector;public
class SequenceInputStream extends InputStream {...省略部分代码...//顺序(序列化)存储多个被装饰的输入Stream的集合,一般是Vector实例Enumeration<? extends InputStream> e;InputStream in;//顺序(序列化)装载多个被装饰输入Stream的集合中当前正在被SequenceInputStream 对象使用的被装饰的输入Stream//获取集合中下一个被装饰的输入Streamfinal void nextStream() throws IOException {if (in != null) {in.close();//先关闭当前被装饰的输入Stream}if (e.hasMoreElements()) {//如果集合中还有被装饰的输入Streamin = (InputStream) e.nextElement();//获取集合中下一个被装饰的输入Streamif (in == null)throw new NullPointerException();//如果集合中下一个被装饰的输入Stream为null,抛出一个NullPointerException}else in = null;//如果集合中没有了被装饰的输入Stream,将当前正在使用的被装饰的输入Stream置为null}//从SequenceInputStream 对象的集合(该集合放着多个被装饰的输入Stream)中读取1个字节public int read() throws IOException {while (in != null) {//如果in!=null,则说明当前这个SequenceInputStream 对象的集合中还有被装饰的输入Stream没有关闭int c = in.read();//从当前正在使用的被装饰的被装饰输入Stream中读取1个字节if (c != -1) {//c != -1说明从当前正在使用的被装饰输入Stream中读取到了字节return c;//返回读取到的这个字节}nextStream();//如果c==-1说明当前正在使用的被装饰输入Stream中字节(byte)数据已经读完,获取SequenceInputStream 对象的集合中下一个被装饰的输入Stream}return -1;//如果SequenceInputStream 对象的集合中所有被装饰的输入Stream中的字节(byte)数据都已经读完,返回-1}...省略部分代码...
}

如果使用者用的是2个被装饰的输入Stream(此处为FileInputStream),构造的SequenceInputStream的对象,如下所示(伪代码):

is1 = new FileInputStream("D:\\data1.txt");
is2 = new FileInputStream("D:\\data2.txt");
sequenceInputStream = new SequenceInputStream(is1, is2);

那么,SequenceInputStream对象中Vector集合的容量是2,如果此时执行SequenceInputStream.class::read()函数。

//伪代码
int readByte = -1;
while ((readByte = sequenceInputStream.read()) != -1) {System.out.print((char) readByte);
}

过程如下(假设2个被装饰的输入Stream(此处为FileInputStream)中的字节数据如下):
clipboard

①、先执行第1个被装饰的输入Stream(也是Vector集合的第1个元素)的read()函数,直到该函数返回-1,如下所示:
clipboard
clipboard

②、关闭第1个被装饰的输入Stream(也是Vector集合的第1个元素),再执行第2个被装饰的输入Stream(也是Vector集合的第2个元素)的read()函数,直到该函数返回-1,如下所示:
clipboard
clipboard

1.1.1、使用举例

  下面这个例子就恰当的使用SequenceInputStream的read()函数;

  • 我的windows操作系统的D盘根目录下有2个txt文件,一个是data1.txt,另一个是data2.txt文件,这2个文件中总共有30个字节,如下所示:
    clipboard
    clipboard

  • 使用者可以用一个SequenceInputStream对象装饰2个被装饰的输入Stream(此处为FileInputStream),如下代码所示:

package com.chelong.StreamAndReader;import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.SequenceInputStream;public class SequenceInputStreamTest {public static void main(String[] args) {InputStream is1 = null;InputStream is2 = null;SequenceInputStream sequenceInputStream = null;try {is1 = new FileInputStream("D:\\data1.txt");is2 = new FileInputStream("D:\\data2.txt");sequenceInputStream = new SequenceInputStream(is1, is2);int readByte = -1;while ((readByte = sequenceInputStream.read()) != -1) {System.out.print((char) readByte);}} catch (IOException e) {e.printStackTrace();} finally {//此处省略关闭所有的Stream的代码}}
}

程序运行结果,如下所示:
clipboard

1.2、SequenceInputStream的read(byte b[], int off, int len)函数和nextStream()函数
package java.io;
import java.io.InputStream;
import java.util.Enumeration;
import java.util.Vector;public
class SequenceInputStream extends InputStream {...省略部分代码...//顺序(序列化)装载多个被装饰输入Stream的集合,一般是Vector实例Enumeration<? extends InputStream> e;InputStream in;//顺序(序列化)装载多个被装饰输入Stream的集合中当前正在被SequenceInputStream 对象使用的被装饰的输入Stream//获取集合中下一个被装饰的输入Streamfinal void nextStream() throws IOException {if (in != null) {in.close();//先关闭当前被装饰的输入Stream}if (e.hasMoreElements()) {//如果集合中还有被装饰的输入Streamin = (InputStream) e.nextElement();//获取集合中下一个被装饰的输入Streamif (in == null)throw new NullPointerException();//如果集合中下一个被装饰的输入Stream为null,抛出一个NullPointerException}else in = null;//如果集合中没有了被装饰的输入Stream,将当前正在使用的被装饰的输入Stream置为null}//从SequenceInputStream 对象的集合(该集合放着多个被装饰的输入Stream)中读取len个字节,放入到byte[]数组b的[off,off+len)(左闭右开,不包括off+len)索引位置public int read(byte b[], int off, int len) throws IOException {if (in == null) {//如果in==null,则说明当前这个SequenceInputStream 对象的集合中所有被装饰的输入Stream都已经关闭return -1;} else if (b == null) {throw new NullPointerException();//如果byte[]数组b==null,抛出一个NullPointerException} else if (off < 0 || len < 0 || len > b.length - off) {//相当于off + len > b.length(源码中这样写代码的好处我没看出来)throw new IndexOutOfBoundsException();} else if (len == 0) {return 0;//要从SequenceInputStream 对象的集合(该集合放着至少2个被装饰的输入Stream)中读取的len个字节==0时,返回0}do {int n = in.read(b, off, len);//从当前正在使用的被装饰的输入Stream中读取len个字节,放入到byte[]数组b的[off,off+len)(左闭右开,不包括off+len)索引位置if (n > 0) {return n;//只要能从当前正在使用的被装饰的输入Stream中读取到字节,则返回读取的数量}nextStream();//此时n==-1,说明当前正在使用的被装饰的输入Stream中字节(byte)数据已经读完,获取SequenceInputStream 对象的集合中下一个被装饰的输入Stream} while (in != null);//SequenceInputStream 对象的集合中下一个被装饰的输入Stream为null时,跳出循环,返回-1return -1;}...省略部分代码...
}

如果使用者用的是2个被装饰的输入Stream(此处为FileInputStream),构造的SequenceInputStream的对象,如下所示(伪代码):

is1 = new FileInputStream("D:\\data1.txt");
is2 = new FileInputStream("D:\\data2.txt");
sequenceInputStream = new SequenceInputStream(is1, is2);

那么,SequenceInputStream对象中Vector集合的容量是2,并且假设这2个被装饰的输入Stream(此处为FileInputStream)中的字节数据如下:
clipboard

如果此时执行SequenceInputStream.class::read()函数。接下来使用SequenceInputStream对象读取字节数据到使用者创建的byte[]数组,如果使用者创建的字节数组byte[]的长度>=第1个被装饰的输入Stream中的所有字节个数,比如,使用者创建的byte[]数组的长度为12,如下所示(伪代码):

int readByte = -1;
byte[] buff = new byte[12];
while ((readByte = sequenceInputStream.read(buff, 0, buff.length)) != -1) {for (int i = 0; i < readByte; i++) {System.out.print((char) buff[i]);}
}

整个执行过程如下:
①、第1次进入read()函数
clipboard

②、第2次进入read()函数(重点是当前正在使用的被装饰的输入Stream中的字节数据已经读取完了时,再次读取,会返回-1,不会返回0
clipboard

③、第3次进入read()函数
clipboard

④、第4次进入read()函数(重点是当前正在使用的被装饰的输入Stream中的字节数据已经读取完了时,再次读取,会返回-1,不会返回0
clipboard

最终使用者创建的byte[]数组中的字节(byte)数据,如下所示:
clipboard

1.2.1、使用举例

  下面这个例子就恰当的使用SequenceInputStream的read()函数;

  • 我的windows操作系统的D盘根目录下有2个txt文件,一个是data1.txt,另一个是data2.txt文件,这2个文件中总共有30个字节,如下所示:
    clipboard
    clipboard

  • 使用者可以用一个SequenceInputStream对象装饰2个被装饰的输入Stream(此处为FileInputStream),如下代码所示:

package com.chelong.StreamAndReader;import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.SequenceInputStream;
import java.util.Vector;public class SequenceInputStreamTest {public static void main(String[] args) {InputStream is1 = null;InputStream is2 = null;SequenceInputStream sequenceInputStream = null;try {is1 = new FileInputStream("D:\\data1.txt");is2 = new FileInputStream("D:\\data2.txt");Vector<InputStream> vector = new Vector<InputStream>();vector.addElement(is1);vector.addElement(is2);sequenceInputStream = new SequenceInputStream(vector.elements());int readByte = -1;byte[] buff = new byte[12];while ((readByte = sequenceInputStream.read(buff, 0, buff.length)) != -1) {for (int i = 0; i < readByte; i++) {System.out.print((char) buff[i]);}}System.out.println();System.out.println("最终留在byte[]数组buff中的字节:");for (byte b : buff) {System.out.print((char) b);}} catch (IOException e) {e.printStackTrace();} finally {try {if (is1 != null) is1.close();if (is2 != null) is1.close();if (sequenceInputStream != null) sequenceInputStream.close();} catch (IOException e) {e.printStackTrace();}}}
}

程序运行结果,如下所示:
clipboard

二、Vector.class的一些函数说明

  Vector 与 ArrayList 一样,也是通过数组实现的,不同的是它支持线程的同步,即某一时刻只有一个线程能够写 Vector,避免多线程同时写而引起的不一致性,但实现同步需要很高的花费,因此,访问它比访问 ArrayList慢。Vector的UML图,如下所示:
clipboard

2.1、构造函数
函数名 函数说明
public Vector() 此构造函数创建的Vector中,Object[]数组的初始长度为10,capacityIncrement=0(capacityIncrement表示扩容时Object[]数组增加的长度,如果等于0的话,当Object[]数组需要扩容时,新的数组长度=2*旧数组的长度,但是新的数组长度最大为2^31-8)
public Vector(int initialCapacity) 此构造函数创建的Vector中,Object[]数组的初始长度为initialCapacity,capacityIncrement=0(capacityIncrement表示扩容时Object[]数组增加的长度,如果等于0的话,当Object[]数组需要扩容时,新的数组长度=2*旧数组的长度,但是新的数组长度最大为2^31-8)
public Vector(int initialCapacity, int capacityIncrement) 此构造函数创建的Vector中,Object[]数组的初始长度为initialCapacity,capacityIncrement=capacityIncrement(capacityIncrement表示扩容时Object[]数组增加的长度,如果等于0的话,当Object[]数组需要扩容时,新的数组长度=2*旧数组的长度,但是新的数组长度最大为2^31-8)
public Vector(Collection<? extends E> c) 此构造函数创建的Vector中,Object[]数组的初始长度为传入集合Collection<? extends E> c的长度,capacityIncrement=0(capacityIncrement表示扩容时Object[]数组增加的长度,如果等于0的话,当Object[]数组需要扩容时,新的数组长度=2*旧数组的长度,但是新的数组长度最大为2^31-8)

2.2、常用函数

函数名 函数说明
boolean add(E o) 此函数将指定的元素追加到此Vector的末尾,该函数与addElement()函数的区别是,该()函数是List.interface接口规定的函数,addElement()函数是Vector自己实现的(接口中没有规定addElement()函数)
void add(int index, E element) 此函数将指定的元素插入此Vector中的指定索引位置
boolean addAll(Collection<? extends E> c) 此函数将指定Collection中的所有元素追加到此Vector的末尾
boolean addAll(int index, Collection<? extends E> c) 此函数将指定Collection中的所有元素插入到此Vector中的指定索引位置
void addElement(E obj) 此函数将指定的元素追加到此Vector的末尾,这个函数与add()函数的区别是,add()函数是List.interface接口规定的函数,这个函数是Vector自己实现的(接口中没有规定该函数)
int capacity() 此函数返回此Vector的当前容量
void clear() 此函数从此Vector中删除所有元素
Object clone() 此函数返回此Vector的克隆对象
boolean contains(Object elem) 如果此Vector包含指定的元素,则此函数返回true
boolean containsAll(Collection<?> c) 如果此Vector包含指定Collection中的所有元素,则此函数返回true
void copyInto(Object[] anArray) 此方法将此向量的组件复制到指定的数组中
E elementAt(int index) 此函数返回Vector指定索引处的元素
Enumeration elements() 此函数返回此Vector中所包含的所有元素的枚举。
void ensureCapacity(int minCapacity) 此函数可增加此Vector的容量,以确保它至少可以保存最小容量元素个数
boolean equals(Object o) 此函数将指定的Object与此Vector进行比较以获得相等性
E firstElement() 返回此Vector的第一个元素(位于Object[]数组索引 0 处的元素)
E get(int index) 返回Vector中指定索引位置的元素
int indexOf(Object elem) 搜索给定参数的第一个匹配项,使用 equals ()函数测试相等性
int indexOf(Object elem, int index) 搜索给定参数的第一个匹配项,从 index 处开始搜索,并使用 equals()函数测试其相等性
void insertElementAt(E obj, int index) 将指定对象作为此Vector中的元素插入到指定的 索引位置
boolean isEmpty() 测试此Vector中的是否不包含任何元素
E lastElement() 返回此Vector的最后一个元素(位于Object[]数组索引 Object[].length-1 处的元素)
int lastIndexOf(Object elem) 返回指定的对象在此Vector中最后一个匹配项的索引
int lastIndexOf(Object elem, int index) 从指定的索引处开始向后搜索指定的对象,并返回搜索到的最后一个索引
E remove(int index) 移除此Vector中指定索引位置的元素
boolean remove(Object o) 移除此Vector中指定元素的第一个匹配项,如果此Vector不包含该元素,则所有元素保持不变,并返回false
boolean removeAll(Collection<?> c) 从此Vector中移除包含在指定 Collection 中的所有元素
void removeAllElements() 从此Vector中移除全部元素,并设置elementCount=0(该变量表示此Vector对象中有效元素的数量),Object[]数组的长度不变。
void removeElementAt(int index) 删除指定索引处的元素
protected void removeRange(int fromIndex, int toIndex) 从此 Vector 中移除索引位于 [fromIndex, toIndex)(左闭右开)之间的所有元素
boolean retainAll(Collection<?> c) 如果此Vector中包含指定 Collection 中的所有元素,此函数返回true
E set(int index, E element) 用指定的元素替换此Vector中指定索引处的元素
void setElementAt(E obj, int index) 将此Vector指定 索引处的元素设置为指定的另一个元素
void setSize(int newSize) 设置此Vector的大小
int size() 返回此Vector中的元素数
List subList(int fromIndex, int toIndex) 返回此 Vector的子集,该子集的元素范围为 [fromIndex, toIndex)(左闭右开)索引位置的所有元素
Object[] toArray() 返回一个Object[]数组,包含此Vector中以正确顺序存放的所有元素
String toString() 返回此Vector的字符串表示形式,其中包含每个元素的 String 表示形式
http://www.jsqmd.com/news/385289/

相关文章:

  • 2025年主流项目管理工具对比:10款 Jira 替代方案清单
  • Spring AI学习
  • 2026最新口碑协商律所贷款/信用卡分期协商机构榜单(负债人实测版) - 代码非世界
  • 大模型技术:深入理解预训练与微调,为什么需要预训练,什么是微调?
  • 2026年口碑优选:哪些保健品品牌值得信赖?保健饮品/养胃颗粒/保健品,保健品品牌哪个好 - 品牌推荐师
  • AI Agent智能体解析-7种Agent框架对比!
  • Vue.js 起步指南
  • 使用 TypeScript 的指数退避机制包装异步请求
  • 深入研究大数据领域 Hadoop 的 HBase 数据库
  • Games202(一):实时阴影(Real-time Shadows)
  • 苹果充值卡回收常见问题解答 - 京顺回收
  • Go基础:Go的函数和方法详解
  • 负债逾期别乱投医!2026最新贷款+信用卡分期协商机构口碑榜单,实测靠谱助你上岸 - 代码非世界
  • 2025金融AI智能体投资决策的落地趋势:架构师的判断与建议
  • SVG 文本:图形与文本的完美融合
  • MongoDB 更新文档
  • SQL RIGHT JOIN
  • AI原生应用领域微服务集成的服务发现机制
  • Java 发送邮件
  • JavaScript Navigator
  • C 标准库 - `<errno.h>`
  • AI辅助编程工具(八) - Cursor配合通义干问
  • 从获客到流失:完整用户生命周期价值建模方法
  • jQuery UI 如何使用部件库
  • DOM 遍历
  • zhuyifan 的考试
  • 题解:洛谷 P11641 【MX-X8-T0】「TAOI-3」分数
  • 15分钟带你搞懂AI Agent、LLM和RAG那些事儿,小学生都能看懂!!
  • 【AI大模型】Embedding技术:Sentence-BERT句嵌入模型介绍和实践
  • 深度理解RAG中的嵌入模型Embedding Model,看这一篇就够了!!