cn.ujava.common.io.stream

类 StreamReader

java.lang.Object

cn.ujava.common.io.stream.StreamReader

public class StreamReader
extends Object

InputStream读取器

作者:

ujava

构造器概要

构造器

构造器和说明
StreamReader(InputStream in, boolean closeAfterRead) 构造

方法概要

限定符和类型	方法和说明
static StreamReader	of(InputStream in, boolean closeAfterRead) 创建读取器
FastByteArrayOutputStream	read() 从流中读取内容，读到输出流中，读取完毕后可选是否关闭流
FastByteArrayOutputStream	read(int limit) 从流中读取内容，读到输出流中，读取完毕后可选是否关闭流
byte[]	readBytes() 从流中读取bytes
byte[]	readBytes(int length) 读取指定长度的byte数组
<T> T	readObj(Class<?>... acceptClasses) 从流中读取对象，即对象的反序列化 注意！！！

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

StreamReader

public StreamReader(InputStream in,
                    boolean closeAfterRead)

构造

参数:

in - InputStream

closeAfterRead - 读取结束后是否关闭输入流

方法详细资料

of

public static StreamReader of(InputStream in,
                              boolean closeAfterRead)

创建读取器

参数:

in - InputStream

closeAfterRead - 读取结束后是否关闭输入流

返回:

StreamReader

readBytes

public byte[] readBytes()
                 throws IORuntimeException

从流中读取bytes

返回:

bytes

抛出:

IORuntimeException - IO异常

readBytes

public byte[] readBytes(int length)
                 throws IORuntimeException

读取指定长度的byte数组

参数:

length - 长度，小于0表示读取全部

返回:

bytes

抛出:

IORuntimeException - IO异常

read

public FastByteArrayOutputStream read()
                               throws IORuntimeException

从流中读取内容，读到输出流中，读取完毕后可选是否关闭流

返回:

输出流

抛出:

IORuntimeException - IO异常

read

public FastByteArrayOutputStream read(int limit)
                               throws IORuntimeException

从流中读取内容，读到输出流中，读取完毕后可选是否关闭流

参数:

limit - 限制最大拷贝长度，-1表示无限制

返回:

输出流

抛出:

IORuntimeException - IO异常

readObj

public <T> T readObj(Class<?>... acceptClasses)
              throws IORuntimeException,
                     HutoolException

从流中读取对象，即对象的反序列化

注意！！！ 此方法不会检查反序列化安全，可能存在反序列化漏洞风险！！！

此方法使用了ValidateObjectInputStream中的黑白名单方式过滤类，用于避免反序列化漏洞
通过构造ValidateObjectInputStream，调用ValidateObjectInputStream.accept(Class[]) 或者ValidateObjectInputStream.refuse(Class[])方法添加可以被序列化的类或者禁止序列化的类。

类型参数:

T - 读取对象的类型

参数:

acceptClasses - 读取对象类型

返回:

输出流

抛出:

IORuntimeException - IO异常

HutoolException - ClassNotFoundException包装