Java中的InputStreamReader和OutputStreamWriter源码分析_动力节点Java学院整理

InputStreamReader和OutputStreamWriter源码分析

1. InputStreamReader 源码(基于jdk1.7.40)

package java.io;
 import java.nio.charset.Charset;
 import java.nio.charset.CharsetDecoder;
 import sun.nio.cs.StreamDecoder;
 // 将“字节输入流”转换成“字符输入流”
 public class InputStreamReader extends Reader {
  private final StreamDecoder sd;
  // 根据in创建InputStreamReader，使用默认的编码
  public InputStreamReader(InputStream in) {
   super(in);
   try {
    sd = StreamDecoder.forInputStreamReader(in, this, (String)null); // ## check lock object
   } catch (UnsupportedEncodingException e) {
    // The default encoding should always be available
    throw new Error(e);
   }
  }
  // 根据in创建InputStreamReader，使用编码charsetName(编码名)
  public InputStreamReader(InputStream in, String charsetName)
   throws UnsupportedEncodingException
  {
   super(in);
   if (charsetName == null)
    throw new NullPointerException("charsetName");
   sd = StreamDecoder.forInputStreamReader(in, this, charsetName);
  }
  // 根据in创建InputStreamReader，使用编码cs
  public InputStreamReader(InputStream in, Charset cs) {
   super(in);
   if (cs == null)
    throw new NullPointerException("charset");
   sd = StreamDecoder.forInputStreamReader(in, this, cs);
  }
  // 根据in创建InputStreamReader，使用解码器dec
  public InputStreamReader(InputStream in, CharsetDecoder dec) {
   super(in);
   if (dec == null)
    throw new NullPointerException("charset decoder");
   sd = StreamDecoder.forInputStreamReader(in, this, dec);
  }
  // 获取解码器
  public String getEncoding() {
   return sd.getEncoding();
  }
  // 读取并返回一个字符
  public int read() throws IOException {
   return sd.read();
  }
  // 将InputStreamReader中的数据写入cbuf中，从cbuf的offset位置开始写入，写入长度是length
  public int read(char cbuf[], int offset, int length) throws IOException {
   return sd.read(cbuf, offset, length);
  }
  // 能否从InputStreamReader中读取数据
  public boolean ready() throws IOException {
   return sd.ready();
  }
  // 关闭InputStreamReader
  public void close() throws IOException {
   sd.close();
  }
 }

2. OutputStreamWriter 源码(基于jdk1.7.40)

package java.io;
 import java.nio.charset.Charset;
 import java.nio.charset.CharsetEncoder;
 import sun.nio.cs.StreamEncoder;
 // 将“字节输出流”转换成“字符输出流”
 public class OutputStreamWriter extends Writer {
  private final StreamEncoder se;
  // 根据out创建OutputStreamWriter，使用编码charsetName(编码名)
  public OutputStreamWriter(OutputStream out, String charsetName)
   throws UnsupportedEncodingException
  {
   super(out);
   if (charsetName == null)
    throw new NullPointerException("charsetName");
   se = StreamEncoder.forOutputStreamWriter(out, this, charsetName);
  }
  // 根据out创建OutputStreamWriter，使用默认的编码
  public OutputStreamWriter(OutputStream out) {
   super(out);
   try {
    se = StreamEncoder.forOutputStreamWriter(out, this, (String)null);
   } catch (UnsupportedEncodingException e) {
    throw new Error(e);
   }
  }
  // 根据out创建OutputStreamWriter，使用编码cs
  public OutputStreamWriter(OutputStream out, Charset cs) {
   super(out);
   if (cs == null)
    throw new NullPointerException("charset");
   se = StreamEncoder.forOutputStreamWriter(out, this, cs);
  }
  // 根据out创建OutputStreamWriter，使用编码器enc
  public OutputStreamWriter(OutputStream out, CharsetEncoder enc) {
   super(out);
   if (enc == null)
    throw new NullPointerException("charset encoder");
   se = StreamEncoder.forOutputStreamWriter(out, this, enc);
 }java io系列01之 "目录"
  // 获取编码器enc
  public String getEncoding() {
   return se.getEncoding();
  }
  // 刷新缓冲区
  void flushBuffer() throws IOException {
   se.flushBuffer();
  }
  // 将单个字符写入到OutputStreamWriter中
  public void write(int c) throws IOException {
   se.write(c);
  }
  // 将字符数组cbuf从off开始的数据写入到OutputStreamWriter中，写入长度是len
  public void write(char cbuf[], int off, int len) throws IOException {
   se.write(cbuf, off, len);
  }
  // 将字符串str从off开始的数据写入到OutputStreamWriter中，写入长度是len
  public void write(String str, int off, int len) throws IOException {
   se.write(str, off, len);
 }java io系列01之 "目录"
  // 刷新“输出流”
  // 它与flushBuffer()的区别是：flushBuffer()只会刷新缓冲，而flush()是刷新流，flush()包括了flushBuffer。
  public void flush() throws IOException {
   se.flush();
  }
  // 关闭“输出流”
  public void close() throws IOException {
   se.close();
  }
 }

说明：

OutputStreamWriter 作用和原理都比较简单。

作用就是将“字节输出流”转换成“字符输出流”。它的原理是，我们创建“字符输出流”对象时，会指定“字节输出流”以及“字符编码”。 

示例程序

InputStreamReader和OutputStreamWriter的使用示例，参考源码(StreamConverter.java)： 

 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
 import java.io.OutputStreamWriter;;
 import java.io.InputStreamReader;
 import java.io.IOException;
 /**
 * InputStreamReader 和 OutputStreamWriter 测试程序
 *
 * 
 */
 public class StreamConverter {
  private static final String FileName = "file.txt";
  private static final String CharsetName = "utf-8";
  //private static final String CharsetName = "gb2312";
  public static void main(String[] args) {
   testWrite();
   testRead();
  }
  /**
  * OutputStreamWriter 演示函数
  *
  */
  private static void testWrite() {
   try {
    // 创建文件“file.txt”对应File对象
    File file = new File(FileName);
    // 创建FileOutputStream对应OutputStreamWriter：将字节流转换为字符流，即写入out的数据会自动由字节转换为字符。
    OutputStreamWriter out1 = new OutputStreamWriter(new FileOutputStream(file), CharsetName);
   // 写入10个汉字
   out.write("字节流转为字符流示例");
   // 向“文件中”写入"0123456789"+换行符
    out1.write("0123456789\n");
    out1.close();
   } catch(IOException e) {
    e.printStackTrace();
   }
  }
  /**
  * InputStreamReader 演示程序
  */
  private static void testRead() {
   try {
    // 方法1：新建FileInputStream对象
   // 新建文件“file.txt”对应File对象
    File file = new File(FileName);
    InputStreamReader in = new InputStreamReader(new FileInputStream(file), CharsetName);
    // 测试read()，从中读取一个字符
   char c1 = (char)in1.read();
    System.out.println("c1="+c1);
   // 测试skip(long byteCount)，跳过4个字符
   in1.skip(6);
    // 测试read(char[] cbuf, int off, int len)
    char[] buf = new char[10];
   in1.read(buf, 0, buf.length);
    System.out.println("buf="+(new String(buf)));
    in.close();
   } catch(IOException e) {
    e.printStackTrace();
   }
  }
 }

运行结果：

c1=字
buf=流示例0123456

结果说明：

(01) testWrite() 的作用是将“内容写入到输出流”。写入的时候，会将写入的内容转换utf-8编码并写入。

(02) testRead() 的作用是将“内容读取到输入流”。读取的时候，会将内容转换成utf-8的内容转换成字节并读出来。

生成的文件utf-8的file.txt的16进制效果图如下： 

将StreamConverter.java中的CharsetName修改为"gb2312"。运行程序，生产的file.txt的16进制效果图如下：

以上所述是小编给大家介绍的Java中的InputStreamReader和OutputStreamWriter源码分析，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

# inputstreamreader和outputstreamwriter  # Java转换流(InputStreamReader/OutputStreamWriter)的使用  # 一文详解JAVA中InputStreamReader流  # Java之InputStreamReader类的实现  # Java中的转换流InputStreamReader解读  # 转换成  # 会将  # 小编  # 在此  # 只会  # 给大家  # 转换为  # 所述  # 它与  # 跳过  # 给我留言  # 感谢大家  # 疑问请  # 有任何  # 换行符  # lock  # final  # object  # forInputStreamReader  # catch 

相关文章： 阿里云网站制作公司,阿里云快速搭建网站好用吗？  北京网站制作公司哪家好一点,北京租房网站有哪些？  教育培训网站制作流程,请问edu教育网站的域名怎么申请？  网站制作中优化长尾关键字挖掘的技巧,建一个视频网站需要多少钱？  PHP 500报错的快速解决方法  如何在云主机快速搭建网站站点？  如何在Windows服务器上快速搭建网站？  合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？  h5网站制作工具有哪些,h5页面制作工具有哪些？  建站主机选哪家性价比最高？  如何通过VPS建站实现广告与增值服务盈利？  Android自定义listview布局实现上拉加载下拉刷新功能  建站之星安装步骤有哪些常见问题？  娃派WAP自助建站：免费模板+移动优化，快速打造专业网站  中山网站推广排名,中山信息港登录入口？  如何构建满足综合性能需求的优质建站方案？  如何快速辨别茅台真假？关键步骤解析  模具网站制作流程,如何找模具客户？  如何快速打造个性化非模板自助建站？  英语简历制作免费网站推荐,如何将简历翻译成英文？  东莞市网站制作公司有哪些,东莞找工作用什么网站好？  如何制作网站标识牌,动态网站如何制作（教程）？  网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话？  定制建站模板如何实现SEO优化与智能系统配置？18字教程  如何在沈阳梯子盘古建站优化SEO排名与功能模块？  学校免费自助建站系统：智能生成+拖拽设计+多端适配  网页设计与网站制作内容,怎样注册网站？  如何在橙子建站上传落地页？操作指南详解  广东企业建站网站优化与SEO营销核心策略指南  如何快速搭建二级域名独立网站？  如何选购建站域名与空间？自助平台全解析  如何通过免费商城建站系统源码自定义网站主题与功能？  打鱼网站制作软件,波克捕鱼官方号怎么注册？  如何通过商城免费建站系统源码自定义网站主题？  建站之星安装后如何自定义网站颜色与字体？  公司门户网站制作流程,华为官网怎么做？  如何在万网ECS上快速搭建专属网站？  如何设置并定期更换建站之星安全管理员密码？  建站主机选购指南与交易推荐：核心配置解析  实现点击下箭头变上箭头来回切换的两种方法【推荐】  如何在Windows环境下新建FTP站点并设置权限？  如何在宝塔面板创建新站点？  北京专业网站制作设计师招聘,北京白云观官方网站？  天河区网站制作公司,广州天河区如何办理身份证？需要什么资料有预约的网站吗？  青岛网站设计制作公司,查询青岛招聘信息的网站有哪些？  建站之星如何取消后台验证码生成？  外汇网站制作流程,如何在工商银行网站上做外汇买卖？  专业网站建设制作报价,网页设计制作要考什么证？  如何在腾讯云服务器快速搭建个人网站？  网站专业制作公司有哪些,做一个公司网站要多少钱？