4hutool实战:IoUtil 流操作工具类（toStream转为流）

秒速五厘米 2022-10-05 06:52 626阅读 0赞

技术活，该赏
    关注+一键三连（点赞，评论，收藏）再看，养成好习惯

[hutool实战（带你掌握里面的各种工具）目录][hutool]

--------------------

# 用途：IO工具类（toStream转为流） #

## 使用场景 ##

IO工具类只是辅助流的读写，并不负责关闭流。原因是流可能被多次读写，读写关闭后容易造成问题。

（String 转为流）

（文件转为流）

（byte\[\]转为流）

（不同类型的流互转）

## 项目引用 ##

此博文的依据：hutool-5.6.5版本源码

<dependency>
    			<groupId>cn.hutool</groupId>
    			<artifactId>hutool-core</artifactId>
    			<version>5.6.5</version>
    		</dependency>

## 方法摘要 ##

<table> 
 <thead> 
  <tr> 
   <th>方法</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toStream(java.lang.String, java.lang.String)</a></td> 
   <td align="left"> 
    <div>
      String 转为流 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toStream(java.lang.String, java.nio.charset.Charset)</a></td> 
   <td align="left"> 
    <div>
      String 转为流 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toUtf8Stream(java.lang.String)</a></td> 
   <td align="left"> 
    <div>
      String 转为UTF-8编码的字节流流 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toStream(java.io.File)</a></td> 
   <td align="left"> 
    <div>
      文件转为{@link FileInputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toStream(byte[])</a></td> 
   <td align="left"> 
    <div>
      byte[] 转为{@link ByteArrayInputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toStream(java.io.ByteArrayOutputStream)</a></td> 
   <td align="left"> 
    <div>
      {@link ByteArrayOutputStream}转为{@link ByteArrayInputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.InputStream)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedInputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.InputStream, int)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedInputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.OutputStream)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedOutputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.OutputStream, int)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedOutputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.Reader)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedReader} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.Reader, int)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedReader} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.Writer)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedWriter} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toBuffered(java.io.Writer, int)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link BufferedWriter} 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toMarkSupportStream(java.io.InputStream)</a></td> 
   <td align="left"> 
    <div>
      将{@link InputStream}转换为支持mark标记的流&lt;br&gt; 若原流支持mark标记，则返回原流，否则使用{@link BufferedInputStream} 包装之 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toPushbackStream(java.io.InputStream, int)</a></td> 
   <td align="left"> 
    <div>
      转换为{@link PushbackInputStream}&lt;br&gt; 如果传入的输入流已经是{@link PushbackInputStream}，强转返回，否则新建一个 
    </div></td> 
  </tr> 
  <tr> 
   <td><a rel="nofollow">cn.hutool.core.io.IoUtil.toAvailableStream(java.io.InputStream)</a></td> 
   <td align="left"> 
    <div>
      将指定{@link InputStream} 转换为{@link InputStream#available()}方法可用的流。 
     <br> 在Socket通信流中，服务端未返回数据情况下{@link InputStream#available()}方法始终为{@code 0} 
     <br> 因此，在读取前需要调用{@link InputStream#read()}读取一个字节（未返回会阻塞），一旦读取到了，{@link InputStream#available()}方法就正常了。 
     <br> 需要注意的是，在网络流中，是按照块来传输的，所以 {@link InputStream#available()} 读取到的并非最终长度，而是此次块的长度。 
     <br> 此方法返回对象的规则为： 
     <ul> 
      <li>FileInputStream 返回原对象，因为文件流的available方法本身可用</li> 
      <li>其它InputStream 返回PushbackInputStream</li> 
     </ul> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toStream(java.lang.String, java.lang.String) ###

### 方法描述 ###

String 转为流

### 支持版本及以上 ###

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>String content</td> 
   <td> 
    <div>
      content 内容 
    </div></td> 
  </tr> 
  <tr> 
   <td>String charsetName</td> 
   <td> 
    <div>
      charsetName 编码 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

字节流

### 参考案例: ###

//内存读写流 不用回收关闭
    		ByteArrayInputStream byteArrayInputStream = IoUtil.toStream("1hello 小虚竹\n2hello 小虚竹","UTF-8");
    		String str = IoUtil.read(byteArrayInputStream,"UTF-8");
    		System.out.println(str);

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toStream(java.lang.String, java.nio.charset.Charset) ###

### 方法描述 ###

String 转为流

### 支持版本及以上 ###

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>String content</td> 
   <td> 
    <div>
      content 内容 
    </div></td> 
  </tr> 
  <tr> 
   <td>Charset charset</td> 
   <td> 
    <div>
      charset 编码 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

字节流

### 参考案例: ###

//内存读写流 不用回收关闭
    		ByteArrayInputStream byteArrayInputStream = IoUtil.toStream("1hello 小虚竹\n2hello 小虚竹","UTF-8");
    		String str = IoUtil.read(byteArrayInputStream,CharsetUtil.UTF_8);
    		System.out.println(str);

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toUtf8Stream(java.lang.String) ###

### 方法描述 ###

String 转为UTF-8编码的字节流流

### 支持版本及以上 ###

4.5.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>String content</td> 
   <td> 
    <div>
      content 内容 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

字节流

### 参考案例: ###

//内存读写流 不用回收关闭
    		ByteArrayInputStream byteArrayInputStream = IoUtil.toUtf8Stream("1hello 小虚竹\n2hello 小虚竹");
    		String str = IoUtil.read(byteArrayInputStream,CharsetUtil.UTF_8);
    		System.out.println(str);

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toStream(java.io.File) ###

### 方法描述 ###

文件转为\{@link FileInputStream\}

### 支持版本及以上 ###

### 参数描述: ###

### 返回值: ###

\{@link FileInputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toStreamTest4.txt") ;
    		FileInputStream fileInputStream =  null;
    		try { 
    			//创建流
    			fileInputStream = IoUtil.toStream(src);
    			String str = IoUtil.read(fileInputStream,CharsetUtil.UTF_8);
    			System.out.println(str);
    		} catch (Exception e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		} finally { 
    			try { 
    				//如果是空的 说明流创建失败 失败了不需要关闭
    				if (fileInputStream != null) { 
    					fileInputStream.close();
    				}
    			} catch (Exception e) { 
    				//关闭资源失败 停止程序
    				throw new RuntimeException("关闭资源失败");
    			}
    		}

![在这里插入图片描述][20210607200910940.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toStream(byte\[\]) ###

### 方法描述 ###

byte\[\] 转为\{@link ByteArrayInputStream\}

### 支持版本及以上 ###

4.1.8

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>byte[] content</td> 
   <td> 
    <div>
      content 内容bytes 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

字节流

### 参考案例: ###

String str = "1hello 小虚竹\n2hello 小虚竹";
    		byte[] sb = str.getBytes();
    		//内存读写流 不用回收关闭
    		ByteArrayInputStream byteArrayInputStream = IoUtil.toStream(sb);
    		String str1 = IoUtil.read(byteArrayInputStream,CharsetUtil.UTF_8);
    		System.out.println(str1);

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toStream(java.io.ByteArrayOutputStream) ###

### 方法描述 ###

\{@link ByteArrayOutputStream\}转为\{@link ByteArrayInputStream\}

### 支持版本及以上 ###

5.3.6

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>ByteArrayOutputStream out</td> 
   <td> 
    <div>
      out {@link ByteArrayOutputStream} 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

字节流

### 参考案例: ###

try { 
    			内存读写流 不用回收关闭
    			ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
    			String str = "1hello 小虚竹\n2hello 小虚竹";
    			byte[] sb = str.getBytes();
    			byteArrayOutputStream.write(sb);
    			ByteArrayInputStream byteArrayInputStream = IoUtil.toStream(byteArrayOutputStream);
    			String str1 = IoUtil.read(byteArrayInputStream,CharsetUtil.UTF_8);
    			System.out.println(str1);
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}

![在这里插入图片描述][20210607200929385.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.InputStream) ###

### 方法描述 ###

转换为\{@link BufferedInputStream\}

### 支持版本及以上 ###

4.0.10

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InputStream in</td> 
   <td> 
    <div>
      in {@link InputStream} 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedInputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest1.txt") ;
    		FileInputStream fileInputStream =  null;
    		BufferedInputStream bufferedInputStream = null;
    		try { 
    			fileInputStream = new FileInputStream(src);
    			bufferedInputStream = IoUtil.toBuffered(fileInputStream);
    			String str = IoUtil.read(bufferedInputStream,"UTF-8");
    			System.out.println(str);
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(fileInputStream);
    			IoUtil.close(bufferedInputStream);
    		}

![在这里插入图片描述][20210607200945576.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.InputStream, int) ###

### 方法描述 ###

转换为\{@link BufferedInputStream\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InputStream in</td> 
   <td> 
    <div>
      in {@link InputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td>int bufferSize</td> 
   <td> 
    <div>
      bufferSize buffer size 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedInputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest1.txt") ;
    		FileInputStream fileInputStream =  null;
    		BufferedInputStream bufferedInputStream = null;
    		try { 
    			fileInputStream = new FileInputStream(src);
    			bufferedInputStream = IoUtil.toBuffered(fileInputStream,8192);
    			String str = IoUtil.read(bufferedInputStream,"UTF-8");
    			System.out.println(str);
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(fileInputStream);
    			IoUtil.close(bufferedInputStream);
    		}

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.OutputStream) ###

### 方法描述 ###

转换为\{@link BufferedOutputStream\}

### 支持版本及以上 ###

4.0.10

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>OutputStream out</td> 
   <td> 
    <div>
      out {@link OutputStream} 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedOutputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest3.txt") ;
    		OutputStream outputStream =  null;
    		BufferedOutputStream bufferedOutputStream = null;
    		try { 
    			//创建流
    			outputStream = new FileOutputStream(src);
    			bufferedOutputStream = IoUtil.toBuffered(outputStream);
    			String str = "toBufferedTest3内容1 \ntoBufferedTest3内容2";
    			byte[] sb = str.getBytes();
    			bufferedOutputStream.write(sb);
    			bufferedOutputStream.flush();
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(outputStream);
    			IoUtil.close(bufferedOutputStream);
    		}

![在这里插入图片描述][20210607201003838.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.OutputStream, int) ###

### 方法描述 ###

转换为\{@link BufferedOutputStream\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>OutputStream out</td> 
   <td> 
    <div>
      out {@link OutputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td>int bufferSize</td> 
   <td> 
    <div>
      bufferSize buffer size 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedOutputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest3.txt") ;
    		OutputStream outputStream =  null;
    		BufferedOutputStream bufferedOutputStream = null;
    		try { 
    			//创建流
    			outputStream = new FileOutputStream(src);
    			bufferedOutputStream = IoUtil.toBuffered(outputStream,8192);
    			String str = "toBufferedTest3内容1 \ntoBufferedTest3内容2";
    			byte[] sb = str.getBytes();
    			bufferedOutputStream.write(sb);
    			bufferedOutputStream.flush();
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(outputStream);
    			IoUtil.close(bufferedOutputStream);
    		}

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.Reader) ###

### 方法描述 ###

转换为\{@link BufferedReader\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Reader reader</td> 
   <td> 
    <div>
      reader {@link Reader} 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedReader\}

### 参考案例: ###

Reader reader =  null;
    		BufferedReader bufferedReader = null;
    		try { 
    			reader = new StringReader("1hello 小虚竹\n2hello 小虚竹");
    			bufferedReader = IoUtil.toBuffered(reader);
    			//读第一行数据
    			String str = "";
    			while (str != null){ 
    				str = bufferedReader.readLine();
    				if(str !=null){ 
    					System.out.println(str);
    				}
    			}
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(reader);
    			IoUtil.close(bufferedReader);
    		}

![在这里插入图片描述][20210607201026135.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.Reader, int) ###

### 方法描述 ###

转换为\{@link BufferedReader\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Reader reader</td> 
   <td> 
    <div>
      reader {@link Reader} 
    </div></td> 
  </tr> 
  <tr> 
   <td>int bufferSize</td> 
   <td> 
    <div>
      bufferSize buffer size 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedReader\}

### 参考案例: ###

Reader reader =  null;
    		BufferedReader bufferedReader = null;
    		try { 
    			reader = new StringReader("1hello 小虚竹\n2hello 小虚竹");
    			bufferedReader = IoUtil.toBuffered(reader,8192);
    			//读第一行数据
    			String str = "";
    			while (str != null){ 
    				str = bufferedReader.readLine();
    				if(str !=null){ 
    					System.out.println(str);
    				}
    			}
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(reader);
    			IoUtil.close(bufferedReader);
    		}

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.Writer) ###

### 方法描述 ###

转换为\{@link BufferedWriter\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Writer writer</td> 
   <td> 
    <div>
      writer {@link Writer} 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedWriter\}

### 参考案例: ###

File dest = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest7.txt") ;
    		FileWriter fw = null;
    		BufferedWriter bufferedWriter = null;
    		try { 
    			//创建流
    			fw = new FileWriter(dest);
    			bufferedWriter = IoUtil.toBuffered(fw);
    			String str = "toBufferedTest7 \ntoBufferedTest7";
    			bufferedWriter.write(str);
    			bufferedWriter.flush();
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(fw);
    			IoUtil.close(bufferedWriter);
    		}

![在这里插入图片描述][20210607201048421.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toBuffered(java.io.Writer, int) ###

### 方法描述 ###

转换为\{@link BufferedWriter\}

### 支持版本及以上 ###

5.6.1

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Writer writer</td> 
   <td> 
    <div>
      writer {@link Writer} 
    </div></td> 
  </tr> 
  <tr> 
   <td>int bufferSize</td> 
   <td> 
    <div>
      bufferSize buffer size 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link BufferedWriter\}

### 参考案例: ###

File dest = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toBufferedTest7.txt") ;
    		FileWriter fw = null;
    		BufferedWriter bufferedWriter = null;
    		try { 
    			//创建流
    			fw = new FileWriter(dest);
    			bufferedWriter = IoUtil.toBuffered(fw,8192);
    			String str = "toBufferedTest7 \ntoBufferedTest7";
    			bufferedWriter.write(str);
    			bufferedWriter.flush();
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(fw);
    			IoUtil.close(bufferedWriter);
    		}

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toMarkSupportStream(java.io.InputStream) ###

### 方法描述 ###

将\{@link InputStream\}转换为支持mark标记的流<br>  
若原流支持mark标记，则返回原流，否则使用\{@link BufferedInputStream\} 包装之

### 支持版本及以上 ###

4.0.9

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InputStream in</td> 
   <td> 
    <div>
      in 流 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link InputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toMarkSupportStreamTest1.txt") ;
    		FileInputStream input = null;
    		InputStream inputStream = null;
    		try { 
    			//创建流
    			input =  new FileInputStream(src);
    			inputStream = IoUtil.toMarkSupportStream(input);
    			inputStream.mark(10);
    			int c = 0;
    			int index = 0;
    			//避免陷入死循环
    			int breakRead = 0;
    			StringBuilder stringBuilder = new StringBuilder();
    			while ((c = inputStream.read()) != -1 && breakRead<2){ 
    				index++;
    				stringBuilder.append((char) c);
    				if(index>7){ 
    					index=0;
    					breakRead++;
    					//支持mark标记，则返回原流
    					inputStream.reset();
    				}
    			}
    			System.out.println(stringBuilder.toString());
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(inputStream);
    			IoUtil.close(input);
    		}

![在这里插入图片描述][20210607201105474.png_pic_center]

![在这里插入图片描述][20210607201119695.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toPushbackStream(java.io.InputStream, int) ###

### 方法描述 ###

转换为\{@link PushbackInputStream\}<br>  
如果传入的输入流已经是\{@link PushbackInputStream\}，强转返回，否则新建一个

### 支持版本及以上 ###

3.1.0

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InputStream in</td> 
   <td> 
    <div>
      in {@link InputStream} 
    </div></td> 
  </tr> 
  <tr> 
   <td>int pushBackSize</td> 
   <td> 
    <div>
      pushBackSize 推后的byte数 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

\{@link PushbackInputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toPushbackStreamTest.txt") ;
    		FileInputStream input = null;
    		PushbackInputStream pushbackInputStream = null;
    		try { 
    			//创建流
    			input =  new FileInputStream(src);
    			//在输入流中某个不需要的内容,可以通过pushbackInputStream（回退输入流）处理掉
    			pushbackInputStream = IoUtil.toPushbackStream(input,1);
    			System.out.print("读取之后的数据为：") ;
    			int temp = 0 ;
    			while((temp=pushbackInputStream.read())!=-1) {     // 读取内容
    				if (temp == 'P') {     // 判断是否读取到了“.”
    					pushbackInputStream.unread(temp);    // 放回到缓冲区之中
    					temp = pushbackInputStream.read();    // 再读一遍
    					System.out.print("（退回" + (char) temp + "）");
    				} else { 
    					System.out.print((char) temp);    // 输出内容
    				}
    			}
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(pushbackInputStream);
    			IoUtil.close(input);
    		}

![在这里插入图片描述][20210607201138444.png_pic_center]

![在这里插入图片描述][20210607201151869.png_pic_center]

### 源码解析： ###

链接：待补充

## 方法明细 ##

### 方法名称:cn.hutool.core.io.IoUtil.toAvailableStream(java.io.InputStream) ###

### 方法描述 ###

将指定\{@link InputStream\} 转换为\{@link InputStream\#available()\}方法可用的流。  
  
在Socket通信流中，服务端未返回数据情况下\{@link InputStream\#available()\}方法始终为\{@code 0\}  
  
因此，在读取前需要调用\{@link InputStream\#read()\}读取一个字节（未返回会阻塞），一旦读取到了，\{@link InputStream\#available()\}方法就正常了。  
  
需要注意的是，在网络流中，是按照块来传输的，所以 \{@link InputStream\#available()\} 读取到的并非最终长度，而是此次块的长度。  
  
此方法返回对象的规则为：

*  FileInputStream 返回原对象，因为文件流的available方法本身可用
 *  其它InputStream 返回PushbackInputStream

### 支持版本及以上 ###

5.5.3

### 参数描述: ###

<table> 
 <thead> 
  <tr> 
   <th>参数名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>InputStream in</td> 
   <td> 
    <div>
      in 被转换的流 
    </div></td> 
  </tr> 
 </tbody> 
</table>

### 返回值: ###

转换后的流，可能为\{@link PushbackInputStream\}

### 参考案例: ###

File src = new File("C:\\Users\\Administrator\\Desktop\\xuzhu/toAvailableStreamTest.txt") ;
    		FileInputStream fileInputStream = null;
    		InputStream inputStream = null;
    		BufferedInputStream bufferedInputStream = null;
    		try { 
    			//创建流
    			fileInputStream =  new FileInputStream(src);
    			//返回原对象 FileInputStream
    			inputStream = IoUtil.toAvailableStream(fileInputStream);
    
    			int c = 0;
    			StringBuilder stringBuilder = new StringBuilder();
    			while ((c = inputStream.read())!= -1){ 
    				stringBuilder.append((char) c);
    			}
    			System.out.println(stringBuilder.toString());
    			System.out.print("----------------------------") ;
    
    			fileInputStream = new FileInputStream(src);
    			//其它InputStream 返回PushbackInputStream
    			bufferedInputStream = IoUtil.toBuffered(fileInputStream);
    			inputStream = IoUtil.toAvailableStream(bufferedInputStream);
    			int temp = 0;
    			while ((temp=((PushbackInputStream)inputStream).read())!=-1){ 
    				if (temp == 'A') {     // 判断是否读取到了“.”
    					((PushbackInputStream)inputStream).unread(temp);    // 放回到缓冲区之中
    					temp = inputStream.read();    // 再读一遍
    					System.out.print("（退回" + (char) temp + "）");
    				} else { 
    					System.out.print((char) temp);    // 输出内容
    				}
    			}
    		} catch (IOException e) { 
    			//抛出一个运行时异常(直接停止掉程序)
    			throw new RuntimeException("运行时异常",e);
    		}finally { 
    			IoUtil.close(fileInputStream);
    			IoUtil.close(inputStream);
    			IoUtil.close(bufferedInputStream);
    
    		}

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 2]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 3]

### 源码解析： ###

链接：待补充

[hutool]: https://blog.csdn.net/shi_hong_fei_hei/article/details/117253917
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center]: /images/20221005/c6f65e9527674f41ad27117e27a0eeba.png
[20210607200910940.png_pic_center]: /images/20221005/bdbbfb8765a0469f8f48466bb93b41c4.png
[20210607200929385.png_pic_center]: /images/20221005/cd21407d7de440f79837f3c36bfc1cc9.png
[20210607200945576.png_pic_center]: /images/20221005/8ba2660b219040348419165f196536f8.png
[20210607201003838.png_pic_center]: /images/20221005/8df5211a20e743608e4cecbc0b253530.png
[20210607201026135.png_pic_center]: /images/20221005/718878a181cb4646a72c5ab1e30774a5.png
[20210607201048421.png_pic_center]: /images/20221005/828875c7bac243ed9cbce65ecca62357.png
[20210607201105474.png_pic_center]: /images/20221005/10b041c681d744c496ed3489b11d2229.png
[20210607201119695.png_pic_center]: /images/20221005/0123faaf6b86437e852fa11a046c5cfb.png
[20210607201138444.png_pic_center]: /images/20221005/4625e55b168f4dbab40b3edbb4b3f753.png
[20210607201151869.png_pic_center]: /images/20221005/c3068da66ce843a4aa6c081d13c29bef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221005/068f944cd9494ab084eecb6b277a9dca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221005/9d70efedace54e678678d7a4504318ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NoaV9ob25nX2ZlaV9oZWk_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221005/40e9778d76d04a03a32047ea09f06754.png