IO流

IO流 - 图1

IO流引入

IO流之前我们的数据都是存在内存中的。内存中的数据程序结束就没有了。但是在实际开发中很多时候我们的数据是需要持久化保存的。持久化保存的数据需要保存在硬盘的文件上。那么如何才能将数据保存到文件上?如何才能如何文件上的数据呢?这就需要用到IO流了。

IO流

IO:Input/Output 输入输出

流(Stream):数据流。连续不断的数据。

操作系统本身就有IO功能。

但是今天我们学习的是使用java提供的IO流API操作文件数据。

JavaIO和系统IO的关系

IO流 - 图2

IO流的分类

根据数据的流向分类

  • 输入流:读数据
  • 输出流:写数据
    IO流 - 图3

根据操作数据的不同分类

  • 字节流:IO读写数据的单位是字节
  • 字符流:IO读写数据的单位是字符

综合以上两种分类就得到了JavaIO中的四大基本抽象流:

JavaIO中的四大基本抽象流:

  • 字节输入流(InputStream): 按照字节读数据
  • 字节输出流 (OutputStream):按照字节写数据
  • 字符输入流(Reader):按照字符读数据
  • 字符输出流(Writer): 按照字符写数据

OutputStream-字节输出流

  1. public abstract class OutputStream extends Object implements Closeable, Flushable

此抽象类是表示输出字节流的所有类的超类。

常用方法

方法摘要
void close()
关闭此输出流并释放与此流有关的所有系统资源。
void flush()
刷新此输出流并强制写出所有缓冲的输出字节。
void write(byte[] b)
b.length
个字节从指定的 byte 数组写入此输出流。
void write(byte[] b, int off, int len)
将指定 byte 数组中从偏移量 off
开始的 len
个字节写入此输出流。
abstract void write(int b)
将指定的字节写入此输出流。

OutputStream是一个抽象类,所以我们需要使用其子类来完成数据的写操作。

FileOutputStream - 文件字节输出流 ⭐⭐⭐

文件输出流是用于将数据写入 File 的输出流。

单字节写数据

  1. package com.powernode.p1;
  2. import java.io.File;
  3. import java.io.FileNotFoundException;
  4. import java.io.FileOutputStream;
  5. import java.io.IOException;
  6. /**
  7. * FileOutputStream类:
  8. *
  9. * 构造方法摘要
  10. * FileOutputStream(File file)
  11. * 创建一个向指定 File 对象表示的文件中写入数据的文件输出流。
  12. * FileOutputStream(File file, boolean append)
  13. * 创建一个向指定 File 对象表示的文件中写入数据的文件输出流。
  14. * FileOutputStream(String name)
  15. * 创建一个向具有指定名称的文件中写入数据的输出文件流。
  16. * FileOutputStream(String name, boolean append)
  17. * 创建一个向具有指定 name 的文件中写入数据的输出文件流
  18. *
  19. *
  20. * 方法摘要
  21. * void close()
  22. * 关闭此文件输出流并释放与此流有关的所有系统资源。
  23. * void write(byte[] b)
  24. * 将 b.length 个字节从指定 byte 数组写入此文件输出流中。
  25. * void write(byte[] b, int off, int len)
  26. * 将指定 byte 数组中从偏移量 off 开始的 len 个字节写入此文件输出流。
  27. * void write(int b)
  28. * 将指定字节写入此文件输出流。
  29. *
  30. *
  31. */
  32. public class Demo01 {
  33. public static void main(String[] args) {
  34. FileOutputStream fos = null;
  35. try {
  36. // 1. 创建对象
  37. // 创建文件流对象的时候,如果文件不存在会创建文件
  38. // 创建文件流对象的时候,如果文件存在,就要根据参数append来决定:
  39. // 如果append是true就在原有文件内容末尾追加;false就是覆盖原有文件
  40. // 如果文件路径中的文件夹不存在就会抛出FileNotFoundException
  41. fos = new FileOutputStream(new File("D://a.txt"),true);
  42. // 2. 让对象干活 -- 调用对象的相关方法
  43. // 单字节写数据
  44. fos.write(97); // a
  45. fos.write(57); // 9
  46. fos.write(55); // 7
  47. } catch (FileNotFoundException exception) {
  48. exception.printStackTrace();
  49. } catch (IOException exception) {
  50. exception.printStackTrace();
  51. }finally {
  52. if(fos != null){
  53. try {
  54. fos.close();
  55. } catch (IOException exception) {
  56. exception.printStackTrace();
  57. }
  58. // 以下的代码非必需,这样做的目的是让对象变成垃圾,方便垃圾回收
  59. fos = null;
  60. }
  61. }
  62. }
  63. }

按照字节数组写数据

  1. package com.powernode.p1;
  2. import java.io.FileNotFoundException;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.util.Arrays;
  6. /**
  7. * 演示: 按照字节数组写数据
  8. *
  9. * void write(byte[] b)
  10. * 将 b.length 个字节从指定 byte 数组写入此文件输出流中。
  11. * void write(byte[] b, int off, int len)
  12. * 将指定 byte 数组中从偏移量 off 开始的 len 个字节写入此文件输出流。
  13. */
  14. public class Demo03 {
  15. public static void main(String[] args) {
  16. FileOutputStream fos = null;
  17. try {
  18. // 1. 创建对象
  19. fos = new FileOutputStream("D://b.txt");
  20. // 2. 干活
  21. byte[] bs = "ai,ya高考,我好紧张".getBytes();
  22. System.out.println(Arrays.toString(bs));
  23. // 将字节数组的数据全部写入文件
  24. // fos.write(bs);
  25. // 将字节数组的一部分数据写入文件
  26. fos.write(bs,5,21); // 高考,我好紧张
  27. } catch (IOException exception) {
  28. exception.printStackTrace();
  29. }finally {
  30. if(fos != null){
  31. try {
  32. fos.close();
  33. } catch (IOException exception) {
  34. exception.printStackTrace();
  35. }
  36. fos = null;
  37. }
  38. }
  39. }
  40. }

InputStream-字节输入流

  1. public abstract class InputStream extends Object implements Closeable

此抽象类是表示字节输入流的所有类的超类。

常用方法

abstract int read()
从输入流中读取数据的下一个字节。
int read(byte[] b)
从输入流中读取一定数量的字节,并将其存储在缓冲区数组 b
中。
int read(byte[] b, int off, int len)
将输入流中最多 len
个数据字节读入 byte 数组。返回读取到的字节总数的长度
void close()
关闭此输入流并释放与该流关联的所有系统资源。

InputStream是一个抽象类,需要使用其子类完成数据的读取。

FileInputStream-文件字节输入流⭐⭐⭐

  1. public class FileInputStream extends InputStream

FileInputStream 从文件系统中的某个文件中获得输入字节.

单字节读取数据

  1. package com.powernode.p1;
  2. import java.io.File;
  3. import java.io.FileInputStream;
  4. import java.io.FileNotFoundException;
  5. import java.io.IOException;
  6. /**
  7. * FileInputStream类:
  8. *
  9. * 构造方法摘要
  10. * FileInputStream(File file)
  11. * 通过打开一个到实际文件的连接来创建一个 FileInputStream,该文件通过文件系统中的 File 对象 file 指定。
  12. * FileInputStream(String name)
  13. * 通过打开一个到实际文件的连接来创建一个 FileInputStream,该文件通过文件系统中的路径名 name 指定。
  14. *
  15. * 方法摘要
  16. * int available()
  17. * 返回下一次对此输入流调用的方法可以不受阻塞地从此输入流读取(或跳过)的估计剩余字节数。
  18. * void close()
  19. * 关闭此文件输入流并释放与此流有关的所有系统资源。
  20. * int read()
  21. * 从此输入流中读取一个数据字节。
  22. * int read(byte[] b)
  23. * 从此输入流中将最多 b.length 个字节的数据读入一个 byte 数组中。
  24. * int read(byte[] b, int off, int len)
  25. * 从此输入流中将最多 len 个字节的数据读入一个 byte 数组中。
  26. * long skip(long n)
  27. * 从输入流中跳过并丢弃 n 个字节的数据。
  28. */
  29. public class Demo04 {
  30. public static void main(String[] args) {
  31. FileInputStream fis = null;
  32. try {
  33. // 1. 创建对象
  34. fis = new FileInputStream(new File("D://a.txt"));
  35. // 2. 干活 -- 读取数据
  36. // read() 按照单字节读取数据;返回读取到的字节数据,如果读取到文件末尾返回-1
  37. int b;
  38. while((b = fis.read()) != -1){
  39. System.out.println(b);
  40. }
  41. } catch (FileNotFoundException exception) {
  42. exception.printStackTrace();
  43. } catch (IOException exception) {
  44. exception.printStackTrace();
  45. }finally {
  46. // 3. 释放资源
  47. if(fis != null){
  48. try {
  49. fis.close();
  50. } catch (IOException exception) {
  51. exception.printStackTrace();
  52. }
  53. fis = null;
  54. }
  55. }
  56. }
  57. }

按照字节数据读取数据

  1. package com.powernode.p1;
  2. import java.io.FileInputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.IOException;
  5. import java.util.Arrays;
  6. /**
  7. * FileInputStream类:
  8. *
  9. * int read(byte[] b)
  10. * 从此输入流中将最多 b.length 个字节的数据读入一个 byte 数组中。
  11. * int read(byte[] b, int off, int len)
  12. * 从此输入流中将最多 len 个字节的数据读入一个 byte 数组中。
  13. */
  14. public class Demo05 {
  15. public static void main(String[] args) {
  16. FileInputStream fis = null;
  17. try {
  18. fis = new FileInputStream("D://b.txt");
  19. byte[] bs = new byte[1024];
  20. // 按照字节数组读取数据,将数据读取到字节数组(缓冲区)中
  21. // 返回读取到的字节总数,也就是读取到的字节长度;如果到了文件末尾返回-1
  22. int len;
  23. while((len = fis.read(bs)) != -1){
  24. System.out.print(new String(bs,0,len));
  25. }
  26. } catch (FileNotFoundException exception) {
  27. exception.printStackTrace();
  28. } catch (IOException exception) {
  29. exception.printStackTrace();
  30. }finally {
  31. if(fis != null){
  32. try {
  33. fis.close();
  34. } catch (IOException exception) {
  35. exception.printStackTrace();
  36. }
  37. fis = null;
  38. }
  39. }
  40. }
  41. }

其他方法

  1. package com.powernode.p1;
  2. import java.io.FileInputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.IOException;
  5. /**
  6. * FileInputStream类:
  7. *
  8. * int available()
  9. * 可用的剩余字节数
  10. * long skip(long n)
  11. * 从输入流中跳过 n 个字节的数据。
  12. */
  13. public class Demo06 {
  14. public static void main(String[] args) {
  15. FileInputStream fis = null;
  16. try {
  17. fis = new FileInputStream("D://b.txt");
  18. // 可用的剩余字节数
  19. int count = fis.available();
  20. System.out.println(count);
  21. // 表示跳过2个字节
  22. fis.skip(2);
  23. int b = fis.read();
  24. System.out.println(b);
  25. } catch (FileNotFoundException exception) {
  26. exception.printStackTrace();
  27. } catch (IOException exception) {
  28. exception.printStackTrace();
  29. }finally {
  30. if(fis != null){
  31. try {
  32. fis.close();
  33. } catch (IOException exception) {
  34. exception.printStackTrace();
  35. }
  36. fis = null;
  37. }
  38. }
  39. }
  40. }

拷贝文件

  1. package com.powernode.p1;
  2. import java.io.FileInputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.FileOutputStream;
  5. import java.io.IOException;
  6. /**
  7. * 演示:使用字节流拷贝文件
  8. * 分析:
  9. * 1. 字节输入流读取源文件数据
  10. * 2. 字节输出流写数据到目标文件
  11. * 3. 边读边写
  12. * 4. 关闭资源
  13. *
  14. * 字节流是万能流,什么类型的文件都可以读写(复制),因为任何数据在计算机中都是字节。
  15. *
  16. */
  17. public class CopyFileDemo {
  18. public static void main(String[] args) {
  19. String src = "D://video/228.泛型和集合_LinkedHashMap集合的概述.avi";
  20. String dest ="E://b.avi";
  21. // copyFileBySingleByte(src,dest); // 耗时:121738
  22. copyFileByByteArray(src,dest);// 耗时:162 105 77 45
  23. }
  24. /**
  25. * 使用字节数组的方式拷贝文件
  26. * @param srcPath 源文件路径
  27. * @param destPath 目标文件路径
  28. */
  29. public static void copyFileByByteArray(String srcPath,String destPath){
  30. // 创建输入流和输出流对象
  31. FileInputStream fis = null;
  32. FileOutputStream fos = null;
  33. try {
  34. fis = new FileInputStream(srcPath);
  35. fos = new FileOutputStream(destPath);
  36. // 边读边写
  37. int len; // 存储读取到的字节总数
  38. byte[] bs = new byte[1024];
  39. long start = System.currentTimeMillis();
  40. while((len = fis.read(bs)) != -1){
  41. fos.write(bs,0,len);
  42. }
  43. long end = System.currentTimeMillis();
  44. System.out.println("耗时:" + (end - start));
  45. } catch (IOException exception) {
  46. exception.printStackTrace();
  47. }finally {
  48. // 释放资源
  49. if(fos != null){
  50. try {
  51. fos.close();
  52. } catch (IOException exception) {
  53. exception.printStackTrace();
  54. }
  55. fos = null;
  56. }
  57. if(fis != null){
  58. try {
  59. fis.close();
  60. } catch (IOException exception) {
  61. exception.printStackTrace();
  62. }
  63. fis = null;
  64. }
  65. }
  66. }
  67. /**
  68. * 使用单字节的方式拷贝文件
  69. * @param srcPath 源文件路径
  70. * @param destPath 目标文件路径
  71. */
  72. public static void copyFileBySingleByte(String srcPath,String destPath){
  73. // 创建输入流和输出流对象
  74. FileInputStream fis = null;
  75. FileOutputStream fos = null;
  76. try {
  77. fis = new FileInputStream(srcPath);
  78. fos = new FileOutputStream(destPath);
  79. // 边读边写
  80. int b; // 存储读取到的字节数据
  81. long start = System.currentTimeMillis();
  82. while((b = fis.read()) != -1){
  83. fos.write(b);
  84. }
  85. long end = System.currentTimeMillis();
  86. System.out.println("耗时:" + (end - start));
  87. } catch (IOException exception) {
  88. exception.printStackTrace();
  89. }finally {
  90. // 释放资源
  91. if(fos != null){
  92. try {
  93. fos.close();
  94. } catch (IOException exception) {
  95. exception.printStackTrace();
  96. }
  97. fos = null;
  98. }
  99. if(fis != null){
  100. try {
  101. fis.close();
  102. } catch (IOException exception) {
  103. exception.printStackTrace();
  104. }
  105. fis = null;
  106. }
  107. }
  108. }
  109. }

通过以上文件拷贝的案例测试,我们发现使用数组拷贝的方式比单字节拷贝效率高很多。使用字节数组拷贝的时候,自己数组的大小不是越大越好,一般在1024-8192字节区间设置,效率逐渐提高。增加更大的字节数组大小反而造成效率下降了。

jdk中其实已经帮我们设计好了一个IO流,这个IO流就可以帮助我们提高读写数据的效率。这个IO流就是缓冲流。

字节缓冲流

BufferedInputStream-字节缓冲输入流⭐⭐⭐

  1. public class BufferedInputStream extends FilterInputStream

BufferedInputStream为另一个输入流添加一些功能,即缓冲输入以及支持 markreset 方法的能力。

单字节读取数据

  1. package com.powernode.p2;
  2. import java.io.BufferedInputStream;
  3. import java.io.FileInputStream;
  4. import java.io.FileNotFoundException;
  5. import java.io.IOException;
  6. /**
  7. * BufferedInputStream 缓冲字节输入流
  8. *
  9. * 构造方法摘要
  10. * BufferedInputStream(InputStream in)
  11. * 创建一个 BufferedInputStream 并保存其参数,即输入流 in,以便将来使用。
  12. * BufferedInputStream(InputStream in, int size)
  13. * 创建具有指定缓冲区大小的 BufferedInputStream 并保存其参数,即输入流 in,以便将来使用。
  14. *
  15. * 节点流(普通流):可以直接从数据源或目的地读写数据。
  16. * 处理流(包装流、包裹流):不直接连接到数据源或目的地,是“处理流的流”。通过对其它流进行封装,目的主要是简化操作和提高程序的性能。
  17. *
  18. * 缓冲就是一种处理流(包装流、包裹流),在节点流的基础上添加了缓冲的功能。
  19. */
  20. public class Demo01 {
  21. public static void main(String[] args) {
  22. BufferedInputStream bis = null;
  23. try {
  24. bis = new BufferedInputStream(new FileInputStream("D://a.txt"));
  25. int b;
  26. while((b = bis.read()) != -1){
  27. System.out.println(b);
  28. }
  29. } catch (IOException exception) {
  30. exception.printStackTrace();
  31. }finally {
  32. if(bis != null){
  33. try {
  34. bis.close();
  35. } catch (IOException exception) {
  36. exception.printStackTrace();
  37. }
  38. }
  39. }
  40. }
  41. }

缓冲流单字节读取数据的原理

IO流 - 图4

按照字节数组读取数据

  1. package com.powernode.p2;
  2. import java.io.BufferedInputStream;
  3. import java.io.FileInputStream;
  4. import java.io.FileNotFoundException;
  5. import java.io.IOException;
  6. public class Demo02 {
  7. public static void main(String[] args) {
  8. BufferedInputStream bis = null;
  9. try {
  10. bis = new BufferedInputStream(new FileInputStream("D://a.txt"));
  11. // 按照字节数组读取
  12. int len;
  13. byte[] bs = new byte[1024];
  14. while((len = bis.read(bs))!= -1){
  15. System.out.println( new String(bs,0,len));
  16. }
  17. } catch (FileNotFoundException exception) {
  18. exception.printStackTrace();
  19. } catch (IOException exception) {
  20. exception.printStackTrace();
  21. }finally {
  22. // close
  23. }
  24. }
  25. }

缓冲流字节数组读取数据的原理

IO流 - 图5

BufferedOutputStream-字节缓冲输出流⭐⭐⭐

  1. public class BufferedOutputStream extends FilterOutputStream

该类实现缓冲的输出流。通过设置这种输出流,应用程序就可以将各个字节写入底层输出流中,而不必针对每次字节写入调用底层系统。

单字节写数据

  1. package com.powernode.p1;
  2. import java.io.BufferedOutputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.FileOutputStream;
  5. import java.io.IOException;
  6. /**
  7. * BufferedOutputStream-字节缓冲输出流
  8. * 该类实现缓冲的输出流。通过设置这种输出流,应用程序就可以将各个字节写入底层输出流中,而不必针对每次字节写入调用底层系统。
  9. *
  10. * 构造方法摘要
  11. * BufferedOutputStream(OutputStream out)
  12. * 创建一个新的缓冲输出流,以将数据写入指定的底层输出流。
  13. * BufferedOutputStream(OutputStream out, int size)
  14. * 创建一个新的缓冲输出流,以将具有指定缓冲区大小的数据写入指定的底层输出流
  15. *
  16. * 方法摘要
  17. * void flush()
  18. * 刷新此缓冲的输出流。
  19. * void write(byte[] b, int off, int len)
  20. * 将指定 byte 数组中从偏移量 off 开始的 len 个字节写入此缓冲的输出流。
  21. * void write(int b)
  22. * 将指定的字节写入此缓冲的输出流。
  23. *
  24. */
  25. public class Demo01 {
  26. public static void main(String[] args) {
  27. BufferedOutputStream bos = null;
  28. try {
  29. // 创建对象
  30. bos = new BufferedOutputStream(new FileOutputStream("D://out.txt"));
  31. // 干活
  32. bos.write(97);
  33. // 手动将缓冲区中的数据刷写到文件
  34. bos.flush();
  35. } catch (IOException exception) {
  36. exception.printStackTrace();
  37. }finally {
  38. if(bos != null){
  39. try {
  40. bos.close(); // 缓冲流释放资源的时候会调用flush
  41. } catch (IOException exception) {
  42. exception.printStackTrace();
  43. }
  44. bos = null;
  45. }
  46. }
  47. }
  48. }

IO流 - 图6

按照字节数组写数据

  1. package com.powernode.p1;
  2. import java.io.BufferedOutputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.FileOutputStream;
  5. import java.io.IOException;
  6. public class Demo02 {
  7. public static void main(String[] args) {
  8. BufferedOutputStream bos = null;
  9. try {
  10. bos = new BufferedOutputStream(new FileOutputStream("D://c.txt"),12);
  11. // 按照字节数组写数据
  12. byte[] bs = "好好学习".getBytes();
  13. bos.write(bs);
  14. bos.flush();
  15. } catch (IOException exception) {
  16. exception.printStackTrace();
  17. }finally {
  18. if(bos != null){
  19. try {
  20. bos.close();
  21. } catch (IOException exception) {
  22. exception.printStackTrace();
  23. }
  24. bos= null;
  25. }
  26. }
  27. }
  28. }

IO流 - 图7

缓冲流的好处

  • 减少了对磁盘读写的频率,提高了效率
  • 站在代码设计的角度考虑,使用了装饰者设计模式,增强了流的功能。(简化代码)
  • 支持了mark和reset方法

字符流

字符流 = 字节流 + 字符编码

因为计算机中的数据是字节,所以读写数据还是需要使用字节流。但是读取中文的时候,由于中文的编码格式不一样,所以字节转中文的时候就比较麻烦,jdk帮我们设计了字符流,我们只需要在字节流的基础上添加对应的字符编码就可以将字节转成中文。方便我们操作中文。

Writer

  1. public abstract class Writer extends Object implements Appendable, Closeable, Flushable

写入字符流的抽象类。

OutputStreamWriter-转换流(字符输出流)⭐⭐⭐

OutputStreamWriter 是字符流通向字节流的桥梁。

IO流 - 图8

单字符写数据

  1. package com.powernode.p2;
  2. import java.io.FileNotFoundException;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.OutputStreamWriter;
  6. import java.util.Arrays;
  7. /**
  8. * OutputStreamWriter: 字符输出流
  9. * 构造方法摘要
  10. * OutputStreamWriter(OutputStream out)
  11. * 创建使用默认字符编码的 OutputStreamWriter。
  12. * OutputStreamWriter(OutputStream out, Charset cs)
  13. * 创建使用给定字符集的 OutputStreamWriter。
  14. * OutputStreamWriter(OutputStream out, CharsetEncoder enc)
  15. * 创建使用给定字符集编码器的 OutputStreamWriter。
  16. * OutputStreamWriter(OutputStream out, String charsetName)
  17. * 创建使用指定字符集的 OutputStreamWriter。
  18. *
  19. * 常用方法:
  20. * void write(char[] cbuf)
  21. * 写入字符数组。
  22. * void write(char[] cbuf, int off, int len)
  23. * 写入字符数组的某一部分。
  24. * void write(int c)
  25. * 写入单个字符。
  26. * void write(String str)
  27. * 写入字符串。
  28. * void write(String str, int off, int len)
  29. * 写入字符串的某一部分。
  30. */
  31. public class Demo01 {
  32. public static void main(String[] args) {
  33. OutputStreamWriter writer = null;
  34. try {
  35. // 创建使用默认字符编码的 OutputStreamWriter。
  36. writer = new OutputStreamWriter(new FileOutputStream("D://a.txt"));
  37. writer.write('我');
  38. // 注意:使用字符流需要flush()
  39. writer.flush();
  40. } catch (IOException exception) {
  41. exception.printStackTrace();
  42. }finally {
  43. if(writer != null){
  44. try {
  45. writer.close(); // close也会flush
  46. } catch (IOException exception) {
  47. exception.printStackTrace();
  48. }
  49. writer = null;
  50. }
  51. }
  52. }
  53. }

按照字符数组写数据

  1. package com.powernode.p2;
  2. import java.io.*;
  3. public class Demo02 {
  4. public static void main(String[] args) {
  5. OutputStreamWriter writer = null;
  6. try {
  7. // 创建字符流对象,指定字符编码格式
  8. writer = new OutputStreamWriter(new FileOutputStream("D://b.txt",true), "GBK");
  9. // 按照字符数组写数据
  10. writer.write("好好学习".toCharArray());
  11. // 按照字符串写数据
  12. writer.write("天天向上");
  13. // 写入一个换行符,windows环境的换行符是 \r\n
  14. writer.write("\r\n");
  15. writer.flush();
  16. } catch (UnsupportedEncodingException e) {
  17. e.printStackTrace();
  18. } catch (IOException exception) {
  19. exception.printStackTrace();
  20. }finally {
  21. // close
  22. }
  23. }
  24. }

Reader

  1. public abstract class Reader extends Object implements Readable, Closeable

用于读取字符流的抽象类。

InputStreamReader-转换流(字符输入流)⭐⭐⭐

InputStreamReader 是字节流通向字符流的桥梁。

单字符读取数据

  1. package com.powernode.p2;
  2. import java.io.FileInputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. /**
  7. * InputStreamReader:
  8. *
  9. * 构造方法摘要:
  10. * InputStreamReader(InputStream in)
  11. * 创建一个使用默认字符集的 InputStreamReader。
  12. * InputStreamReader(InputStream in, Charset cs)
  13. * 创建使用给定字符集的 InputStreamReader。
  14. * InputStreamReader(InputStream in, CharsetDecoder dec)
  15. * 创建使用给定字符集解码器的 InputStreamReader。
  16. * InputStreamReader(InputStream in, String charsetName)
  17. * 创建使用指定字符集的 InputStreamReader。
  18. *
  19. * 常用方法:
  20. * int read()
  21. * 读取单个字符。读取的字符,如果已到达流的末尾,则返回 -1
  22. * int read(char[] cbuf)
  23. * 按照字符数组读取。读取的字符,如果已到达流的末尾,则返回 -1
  24. * int read(char[] cbuf, int offset, int length)
  25. * 将字符读入数组中的某一部分。读取的字符,如果已到达流的末尾,则返回 -1
  26. */
  27. public class Demo03 {
  28. public static void main(String[] args) {
  29. InputStreamReader reader = null;
  30. try {
  31. /*
  32. * InputStreamReader对象的字符编码指定成什么,应该根据读取的文件
  33. * 内容的字符编码决定。
  34. */
  35. reader = new InputStreamReader(new FileInputStream("D://a.txt"),"GBK");
  36. int c;
  37. while((c = reader.read()) != -1){
  38. System.out.println((char)c);
  39. }
  40. } catch (FileNotFoundException exception) {
  41. exception.printStackTrace();
  42. } catch (IOException exception) {
  43. exception.printStackTrace();
  44. }finally {
  45. // close
  46. }
  47. }
  48. }

按照字符数组读取数据

  1. package com.powernode.p2;
  2. import java.io.FileInputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. // 按照字符数组读取数据
  7. public class Demo04 {
  8. public static void main(String[] args) {
  9. InputStreamReader reader = null;
  10. try {
  11. /*
  12. * InputStreamReader对象的字符编码指定成什么,应该根据读取的文件
  13. * 内容的字符编码决定。
  14. */
  15. reader = new InputStreamReader(new FileInputStream("D://a.txt"),"GBK");
  16. // 按照字符数组读取数据
  17. int len;
  18. char[] cs= new char[1024];
  19. while((len = reader.read(cs)) != -1){
  20. System.out.println(new String(cs,0,len));
  21. }
  22. } catch (FileNotFoundException exception) {
  23. exception.printStackTrace();
  24. } catch (IOException exception) {
  25. exception.printStackTrace();
  26. }finally {
  27. // close
  28. }
  29. }
  30. }

注意

字符流不是万能的。

字符流可以读写哪些格式的文件?

文件使用操作系统的记事本打开后没有出现乱码,字符流就可以。

便捷类

FileWriter ⭐⭐⭐

  1. public class FileWriter extends OutputStreamWriter

用来写入字符文件的便捷类。

  1. package com.powernode.p2;
  2. import java.io.FileOutputStream;
  3. import java.io.FileWriter;
  4. import java.io.IOException;
  5. import java.io.OutputStreamWriter;
  6. /**
  7. * FileWriter类:
  8. *构造方法摘要
  9. *
  10. * FileWriter(File file)
  11. * 根据给定的 File 对象构造一个 FileWriter 对象。
  12. * FileWriter(File file, boolean append)
  13. * 根据给定的 File 对象构造一个 FileWriter 对象。
  14. * FileWriter(String fileName)
  15. * 根据给定的文件名构造一个 FileWriter 对象。
  16. * FileWriter(String fileName, boolean append)
  17. * 根据给定的文件名以及指示是否附加写入数据的 boolean 值来构造 FileWriter 对象。
  18. *
  19. *
  20. */
  21. public class Demo06 {
  22. public static void main(String[] args) {
  23. FileWriter writer = null;
  24. try {
  25. /*
  26. * 便捷类:便捷体现在:
  27. * 1. 构造中不再需要手动创建OutputStream对象,
  28. * FileWriter底层源码中自动帮我们创建了FileOutputStream对象
  29. *
  30. * 2. 不需要手动指定字符编码格式了,会自动使用默认的字符编码
  31. *
  32. * 缺点:
  33. * 字符编码格式固定了,也就是便捷类只能操作一种编码格式。
  34. *
  35. */
  36. writer = new FileWriter("D://c.txt");
  37. writer.write("真的是好便捷哦");
  38. writer.flush();
  39. } catch (IOException exception) {
  40. exception.printStackTrace();
  41. }finally {
  42. // close
  43. }
  44. }
  45. }

FileReader ⭐⭐⭐

  1. public class FileReader extends InputStreamReader

用来读取字符文件的便捷类。

  1. package com.powernode.p2;
  2. import java.io.FileNotFoundException;
  3. import java.io.FileReader;
  4. import java.io.IOException;
  5. /**
  6. * FileReader类:
  7. *
  8. * 构造方法摘要
  9. * FileReader(File file)
  10. * 在给定从中读取数据的 File 的情况下创建一个新 FileReader。
  11. * FileReader(String fileName)
  12. * 在给定从中读取数据的文件名的情况下创建一个新 FileReader。
  13. */
  14. public class Demo07 {
  15. public static void main(String[] args) {
  16. FileReader reader = null;
  17. try {
  18. /*
  19. * 使用FileReader的前提是:
  20. * 文件的字符编码和平台的默认编码格式一致才能使用;否则中文乱码
  21. */
  22. reader = new FileReader("D://a.txt");
  23. int len;
  24. char[] cs = new char[1024];
  25. while((len = reader.read(cs)) != -1){
  26. System.out.println(new String(cs,0,len));
  27. }
  28. } catch (IOException exception) {
  29. exception.printStackTrace();
  30. }finally {
  31. // close
  32. }
  33. }
  34. }

BufferedWriter-缓冲字符输出流 ⭐⭐⭐

将文本写入字符输出流,缓冲各个字符,从而提供单个字符、数组和字符串的高效写入。

该类提供了 newLine() 方法,它使用平台自己的行分隔符概念。(跨平台分隔符)

  1. package com.powernode.p3;
  2. import java.io.*;
  3. /**
  4. * BufferedWriter-缓冲字符输出流
  5. *
  6. * 构造方法摘要
  7. * BufferedWriter(Writer out)
  8. * 创建一个使用默认大小输出缓冲区的缓冲字符输出流。
  9. * BufferedWriter(Writer out, int sz)
  10. * 创建一个使用给定大小输出缓冲区的新缓冲字符输出流。
  11. *
  12. * 方法摘要
  13. * void close()
  14. * 关闭此流,但要先刷新它。
  15. * void flush()
  16. * 刷新该流的缓冲。
  17. * void newLine()
  18. * 写入一个行分隔符。
  19. * void write(char[] cbuf, int off, int len)
  20. * 写入字符数组的某一部分。
  21. * void write(int c)
  22. * 写入单个字符。
  23. * void write(String s, int off, int len)
  24. * 写入字符串的某一部分。
  25. */
  26. public class Demo01 {
  27. public static void main(String[] args) {
  28. BufferedWriter writer = null;
  29. try {
  30. writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("D://x.txt",true)));
  31. writer.write("java是世界上最好的语言");
  32. // newLine() 根据系统的分隔符来决定
  33. writer.newLine();
  34. writer.flush();
  35. } catch (IOException exception) {
  36. exception.printStackTrace();
  37. }finally {
  38. // close
  39. }
  40. }
  41. }

BufferedReader-缓冲字符输入流 ⭐⭐⭐

从字符输入流中读取文本,缓冲各个字符,从而实现字符、数组和行的高效读取。

  1. package com.powernode.p3;
  2. import java.io.*;
  3. /**
  4. * BufferedReader-缓冲字符输入流
  5. *
  6. * 构造方法摘要
  7. * BufferedReader(Reader in)
  8. * 创建一个使用默认大小输入缓冲区的缓冲字符输入流。
  9. * BufferedReader(Reader in, int sz)
  10. * 创建一个使用指定大小输入缓冲区的缓冲字符输入流。
  11. *
  12. * 方法摘要
  13. * void close()
  14. * 关闭该流并释放与之关联的所有资源。
  15. * int read()
  16. * 读取单个字符。
  17. * int read(char[] cbuf, int off, int len)
  18. * 将字符读入数组的某一部分。
  19. * String readLine()
  20. * 读取一个文本行。如果已到达流末尾,则返回 null
  21. */
  22. public class Demo02 {
  23. public static void main(String[] args) {
  24. BufferedReader reader = null;
  25. try {
  26. reader = new BufferedReader(new InputStreamReader(new FileInputStream("D://x.txt")));
  27. String line;
  28. while((line = reader.readLine()) != null){
  29. System.out.println(line);
  30. }
  31. } catch (IOException exception) {
  32. exception.printStackTrace();
  33. }finally {
  34. // close
  35. }
  36. }
  37. }

什么情况使用字节流;什么情况使用字符流

  • 字节流是万能的,什么情况下都可以使用。
  • 字符流只能用于记事本打开后不乱码的文件。
  • 如果字节流和字符流都可以操作文件的时候,想读取文件中的内容使用字符流。因为字节流读取出来的是字节,遇到中文的时候,我们自己处理会很麻烦的。

数据流

DataOutputStream-数据字节输出流

数据输出流允许应用程序以适当方式将基本 Java 数据类型写入输出流中。然后,应用程序可以使用数据输入流将数据读入。

  1. package com.powernode.p3;
  2. import java.io.DataOutputStream;
  3. import java.io.FileNotFoundException;
  4. import java.io.FileOutputStream;
  5. import java.io.IOException;
  6. /**
  7. * DataOutputStream-数据字节输出流
  8. * 数据输出流允许应用程序以适当方式将基本 Java 数据类型写入输出流中
  9. *
  10. * 构造方法摘要
  11. * DataOutputStream(OutputStream out)
  12. * 创建一个新的数据输出流,将数据写入指定基础输出流。
  13. *
  14. * 方法摘要
  15. * void writeBoolean(boolean v)
  16. * 将一个 boolean 值以 1-byte 值形式写入基础输出流。
  17. * void writeByte(int v)
  18. * 将一个 byte 值以 1-byte 值形式写出到基础输出流中。
  19. * void writeChar(int v)
  20. * 将一个 char 值以 2-byte 值形式写入基础输出流中,先写入高字节。
  21. * void writeDouble(double v)
  22. * 使用 Double 类中的 doubleToLongBits 方法将 double 参数转换为一个 long 值,然后将该 long 值以 8-byte 值形式写入基础输出流中,先写入高字节。
  23. * void writeFloat(float v)
  24. * 使用 Float 类中的 floatToIntBits 方法将 float 参数转换为一个 int 值,然后将该 int 值以 4-byte 值形式写入基础输出流中,先写入高字节。
  25. * void writeInt(int v)
  26. * 将一个 int 值以 4-byte 值形式写入基础输出流中,先写入高字节。
  27. * void writeLong(long v)
  28. * 将一个 long 值以 8-byte 值形式写入基础输出流中,先写入高字节。
  29. * void writeShort(int v)
  30. * 将一个 short 值以 2-byte 值形式写入基础输出流中,先写入高字节。
  31. * void writeUTF(String str)
  32. * 以与机器无关方式使用 UTF-8 修改版编码将一个字符串写入基础输出流。
  33. */
  34. public class Demo04 {
  35. public static void main(String[] args) {
  36. DataOutputStream dos = null;
  37. try {
  38. dos = new DataOutputStream(new FileOutputStream("D://data.txt"));
  39. // DataOutputStream 是将数据按照每一个字节的方式写入文件的
  40. dos.writeByte(97);
  41. dos.writeShort(100);
  42. dos.writeInt(200);
  43. dos.writeLong(1000);
  44. dos.writeChar('我');
  45. dos.writeFloat(3.14f);
  46. dos.writeDouble(13.14);
  47. dos.writeBoolean(true);
  48. // writeUTF写入的字符串字节总数不能超过65535
  49. dos.writeUTF("你说啥呢");
  50. } catch (IOException exception) {
  51. exception.printStackTrace();
  52. }finally {
  53. // close
  54. }
  55. }
  56. }

DataInputStream-数据字节输入流

数据输入流允许应用程序以与机器无关方式从底层输入流中读取基本 Java 数据类型。应用程序可以使用数据输出流写入稍后由数据输入流读取的数据。

  1. package com.powernode.p3;
  2. import java.io.DataInputStream;
  3. import java.io.FileInputStream;
  4. import java.io.FileNotFoundException;
  5. import java.io.IOException;
  6. /**
  7. * DataInputStream-数据字节输入流
  8. * 构造方法摘要
  9. * DataInputStream(InputStream in)
  10. * 使用指定的底层 InputStream 创建一个 DataInputStream。
  11. *
  12. * 方法摘要
  13. * boolean readBoolean()
  14. * byte readByte()
  15. * char readChar()
  16. * double readDouble()
  17. * float readFloat()
  18. * int readInt()
  19. * long readLong()
  20. * short readShort()
  21. * String readUTF()
  22. *
  23. */
  24. public class Demo05 {
  25. public static void main(String[] args) {
  26. DataInputStream dis = null;
  27. try {
  28. dis = new DataInputStream(new FileInputStream("D://data.txt"));
  29. // 读取数据的顺序必须和写数据的顺序一致;否则数据错乱
  30. System.out.println(dis.readByte());
  31. System.out.println(dis.readShort());
  32. System.out.println(dis.readInt());
  33. System.out.println(dis.readLong());
  34. System.out.println(dis.readChar());
  35. System.out.println(dis.readFloat());
  36. System.out.println(dis.readDouble());
  37. System.out.println(dis.readBoolean());
  38. System.out.println(dis.readUTF());
  39. } catch (IOException exception) {
  40. exception.printStackTrace();
  41. }finally {
  42. // close
  43. }
  44. }
  45. }

数据流的作用:

  1. 可以使用IO流直接操作基本数据类型的数据
  2. 可以用来将基本类型的数据和字符串数据进行序列化

序列化:将数据转字节的过程

反序列化:将字节转数据的过程

将数据持久化存储或者在网络中传输,数据是必须序列化的。

对象流⭐⭐⭐

当两个程序通信时,彼此可以发送任意数据类型的数据。 无论是何种类型的数据,都会以二进制序列的形式在网络上传送(序列化)。比如,我们可以通过发送字符串、基本数据类型的数据信息,我们也可以在网络上直接发送Java对象。发送方需要把这个Java对象转换为字节序列(序列化),才能在网络上传送;接收方则需要把字节序列再恢复为Java对象(反序列)。

ObjectOutputStream-对象序列化流

对象序列化:将对象转字节的过程

只能将支持 java.io.Serializable 接口的对象写入流中。每个 serializable 对象的类都被编码,编码内容包括类名和类签名、对象的字段值和数组值,以及从初始对象中引用的其他所有对象。

注意:java中的对象要序列化必须实现Serializable 接口。

  1. package com.powernode.p4;
  2. import java.io.Serializable;
  3. /**
  4. * 如果一个接口只有声明,没有任何成员信息,那么这个接口叫做标记接口
  5. * 也就是说这个接口的作用仅仅是用作标记。
  6. *
  7. * 对象的默认序列化机制写入的内容是:对象的类,类签名,以及非瞬态和非静态字段的值。
  8. *
  9. * 瞬态字段和静态字段是不会被序列化的。
  10. *
  11. * 瞬态字段:被关键字transient修饰的字段
  12. * transient:表示短暂的意思
  13. *
  14. * 如果对象中的某些字段不希望被持久化,那么可以这些字段可以变成瞬态字段和静态字段
  15. *
  16. */
  17. public class Student implements Serializable {
  18. /*
  19. * serialVersionUID是根据当前类的信息生成的值
  20. * 如果序列化和反序列后serialVersionUID不一致会出现无效类的异常
  21. *
  22. * 在开发中我们都是手动显式的给出serialVersionUID值,这样就可以避免无效类的异常的发生
  23. */
  24. private static final long serialVersionUID = -3174090006999218597L;
  25. // 瞬态字段
  26. private transient String name;
  27. // 静态字段
  28. private static int age;
  29. private String sex;
  30. public Student() {
  31. }
  32. public Student(String name, int age, String sex) {
  33. this.name = name;
  34. this.age = age;
  35. this.sex = sex;
  36. }
  37. public String getName() {
  38. return name;
  39. }
  40. public void setName(String name) {
  41. this.name = name;
  42. }
  43. public int getAge() {
  44. return age;
  45. }
  46. public void setAge(int age) {
  47. this.age = age;
  48. }
  49. public String getSex() {
  50. return sex;
  51. }
  52. public void setSex(String sex) {
  53. this.sex = sex;
  54. }
  55. @Override
  56. public String toString() {
  57. return "Student{" +
  58. "name='" + name + '\'' +
  59. ", age=" + age +
  60. ", sex='" + sex + '\'' +
  61. '}';
  62. }
  63. }
  1. package com.powernode.p4;
  2. import java.io.FileOutputStream;
  3. import java.io.IOException;
  4. import java.io.ObjectOutputStream;
  5. /**
  6. * ObjectOutputStream对象序列化流
  7. * 作用: 将对象转字节
  8. *
  9. * 构造方法摘要
  10. * ObjectOutputStream(OutputStream out)
  11. * 创建写入指定 OutputStream 的 ObjectOutputStream。
  12. *
  13. * 常用方法:
  14. * void writeObject(Object obj)
  15. * 将指定的对象写入 ObjectOutputStream。
  16. *
  17. */
  18. public class Demo01 {
  19. public static void main(String[] args) {
  20. ObjectOutputStream oos = null;
  21. try {
  22. oos = new ObjectOutputStream(new FileOutputStream("D://obj.txt"));
  23. Student student = new Student("张三", 22, "male");
  24. // java中的对象要序列化必须实现Serializable 接口
  25. oos.writeObject(student);
  26. } catch (IOException exception) {
  27. exception.printStackTrace();
  28. }finally {
  29. // close
  30. }
  31. }
  32. }

ObjectInputStream-对象反序列化流

ObjectInputStream 对以前使用 ObjectOutputStream 写入的基本数据和对象进行反序列化。

  1. package com.powernode.p4;
  2. import java.io.FileInputStream;
  3. import java.io.IOException;
  4. import java.io.ObjectInputStream;
  5. /**
  6. * ObjectInputStream对象反序列化流
  7. * 作用:将字节数据转对象
  8. *
  9. */
  10. public class Demo02 {
  11. public static void main(String[] args) {
  12. ObjectInputStream ois = null;
  13. try {
  14. ois = new ObjectInputStream(new FileInputStream("D://obj.txt"));
  15. Student obj = (Student) ois.readObject();
  16. System.out.println(obj);
  17. } catch (IOException exception) {
  18. exception.printStackTrace();
  19. } catch (ClassNotFoundException e) {
  20. e.printStackTrace();
  21. }finally {
  22. // close
  23. }
  24. }
  25. }

serialVersionUID

serialVersionUID是根据当前类的信息生成的值
如果序列化和反序列后serialVersionUID不一致会出现无效类的异常
在开发中我们都是手动显式的给出serialVersionUID值,这样就可以避免无效类的异常的发生

transient关键字

transient:表示短暂的意思

瞬态字段:被关键字transient修饰的字段

瞬态字段不能被序列化

字节数组流(内存流)

ByteArrayOutputStream 内存输出流 ⭐⭐

此类实现了一个输出流,其中的数据被写入一个 byte 数组。缓冲区会随着数据的不断写入而自动增长。可使用 toByteArray()toString() 获取数据。

关闭 ByteArrayOutputStream 无效。此类中的方法在关闭此流后仍可被调用,而不会产生任何 IOException

  1. package com.powernode.p1;
  2. import java.io.ByteArrayOutputStream;
  3. import java.io.IOException;
  4. /**
  5. * 构造方法摘要
  6. * ByteArrayOutputStream()
  7. * 创建一个新的 byte 数组输出流。
  8. * ByteArrayOutputStream(int size)
  9. * 创建一个新的 byte 数组输出流,它具有指定大小的缓冲区容量(以字节为单位)。
  10. *
  11. *方法摘要
  12. * int size()
  13. * 返回缓冲区的当前大小。
  14. * byte[] toByteArray()
  15. * 创建一个新分配的 byte 数组。
  16. * String toString()
  17. * 使用平台默认的字符集,通过解码字节将缓冲区内容转换为字符串。
  18. * String toString(String charsetName)
  19. * 使用指定的 charsetName,通过解码字节将缓冲区内容转换为字符串。
  20. * void write(byte[] b, int off, int len)
  21. * 将指定 byte 数组中从偏移量 off 开始的 len 个字节写入此 byte 数组输出流。
  22. * void write(int b)
  23. * 将指定的字节写入此 byte 数组输出流。
  24. *
  25. */
  26. public class Demo01 {
  27. public static void main(String[] args) {
  28. // 缓冲区的最大值 2G
  29. ByteArrayOutputStream bos = new ByteArrayOutputStream();
  30. try {
  31. bos.write("好嗨哟".getBytes());
  32. } catch (IOException exception) {
  33. exception.printStackTrace();
  34. }
  35. // 可使用 toByteArray() 和 toString() 获取数据。
  36. System.out.println(bos.toString());
  37. }
  38. }

使用场景演示

  1. package com.powernode.p1;
  2. import java.io.*;
  3. /**
  4. * 需求: 将图片显示加载(微信头像,朋友圈)
  5. *
  6. * 本地有一张图,需要将这个图片加载显示
  7. * 1. 将图片读取出来 --- 字节缓冲输入流
  8. * 2. 字节数据转图片,需要获取到整张图片的字节数据后再转图片
  9. * 不能拿到图片的一部分数据就开始转图片,这样图片会损坏的。
  10. *
  11. */
  12. public class Demo02 {
  13. public static void main(String[] args) {
  14. ByteArrayOutputStream baos = null;
  15. BufferedInputStream bis = null;
  16. try {
  17. bis = new BufferedInputStream(new FileInputStream("D://mm.webp"));
  18. baos = new ByteArrayOutputStream();
  19. int len;
  20. byte[] bs = new byte[1024];
  21. while((len = bis.read(bs)) != -1){
  22. // 读取图片数据 -- 将图片的字节数据保存到内存流中
  23. baos.write(bs,0,len);
  24. }
  25. /*
  26. * while循环完成后,内存流中就保存了整张图片的字节数据
  27. */
  28. // 获取图片的字节数据
  29. byte[] bytes = baos.toByteArray();
  30. // 我们就可以使用相关的工具类将字节数组转图片显示
  31. } catch (IOException exception) {
  32. exception.printStackTrace();
  33. }finally {
  34. // bis close
  35. }
  36. }
  37. }

ByteArrayInputStream 内存输入流

ByteArrayInputStream 包含一个内部缓冲区,该缓冲区包含从流中读取的字节。

关闭 ByteArrayInputStream 无效。此类中的方法在关闭此流后仍可被调用,而不会产生任何 IOException

  1. package com.powernode.p1;
  2. import java.io.ByteArrayInputStream;
  3. import java.io.ByteArrayOutputStream;
  4. import java.io.IOException;
  5. /**
  6. * ByteArrayInputStream 内存输入流
  7. *
  8. *构造方法摘要
  9. * ByteArrayInputStream(byte[] buf)
  10. * 创建一个 ByteArrayInputStream,使用 buf 作为其缓冲区数组。
  11. * ByteArrayInputStream(byte[] buf, int offset, int length)
  12. * 创建 ByteArrayInputStream,使用 buf 作为其缓冲区数组。
  13. *
  14. * 方法摘要
  15. * int read()
  16. * 从此输入流中读取下一个数据字节。
  17. * int read(byte[] b, int off, int len)
  18. * 将最多 len 个数据字节从此输入流读入 byte 数组。
  19. */
  20. public class Demo03 {
  21. public static void main(String[] args) {
  22. // 缓冲区的最大值 2G
  23. ByteArrayOutputStream bos = new ByteArrayOutputStream();
  24. try {
  25. bos.write("abc".getBytes());
  26. // 读取内存流中的数据
  27. ByteArrayInputStream bais = new ByteArrayInputStream(bos.toByteArray());
  28. int b = bais.read();
  29. System.out.println(b);
  30. } catch (IOException exception) {
  31. exception.printStackTrace();
  32. }
  33. }
  34. }

打印流

打印流只有输出流没有输入流。

PrintStream 字节打印流

  1. public class PrintStream extends FilterOutputStream implements Appendable, Closeable

PrintStream 为其他输出流添加了功能,使它们能够方便地打印各种数据值表示形式。

与其他输出流不同,PrintStream 永远不会抛出 IOException

  1. package com.powernode.p1;
  2. import java.io.*;
  3. /**
  4. * PrintStream 字节打印流
  5. *
  6. * 构造方法摘要
  7. * PrintStream(File file)
  8. * 创建具有指定文件且不带自动行刷新的新打印流。。
  9. * PrintStream(OutputStream out)
  10. * 创建新的打印流。
  11. * PrintStream(OutputStream out, boolean autoFlush)
  12. * 创建新的打印流。
  13. * PrintStream(String fileName)
  14. * 创建具有指定文件名称且不带自动行刷新的新打印流。
  15. */
  16. public class Demo04 {
  17. public static void main(String[] args) {
  18. PrintStream ps = null;
  19. try {
  20. // autoFlush表示自动刷新,字节打印流中需要配合缓冲字节输出流使用。节点流使用该参数无效。
  21. ps = new PrintStream(new BufferedOutputStream(new FileOutputStream("D://a.txt")),true);
  22. ps.print("这是字节打印流");
  23. } catch (FileNotFoundException exception) {
  24. exception.printStackTrace();
  25. }finally {
  26. // ps.close();
  27. }
  28. }
  29. }

PrintWriter 字符打印流

  1. public class PrintWriter extends Writer

[PrintStream](../../java/io/PrintStream.html) 类不同,如果启用了自动刷新,则只有在调用 printlnprintfformat 的其中一个方法时才可能完成此操作。

PrintWriter 构造中既能接受字节流也能接受字符流。

  1. package com.powernode.p1;
  2. import java.io.FileWriter;
  3. import java.io.IOException;
  4. import java.io.PrintWriter;
  5. /**
  6. * PrintWriter字符打印流
  7. *
  8. * 与 PrintStream 类不同,如果启用了自动刷新,则只有在调用 println、printf 或 format 的其中一个方法时才可能完成此操作。
  9. */
  10. public class Demo05 {
  11. public static void main(String[] args) {
  12. PrintWriter pw = null;
  13. try {
  14. pw = new PrintWriter(new FileWriter("D://b.txt"), true);
  15. // 如果启用了自动刷新,则只有在调用 println、printf 或 format 的其中一个方法时才可能完成此操作。
  16. pw.println("字符打印流");
  17. } catch (IOException exception) {
  18. exception.printStackTrace();
  19. }finally {
  20. pw.close(); // close也会刷新数据
  21. }
  22. }
  23. }

标准流

标准输入流(System.in):计算机中的最重要的输入设备是键盘,所以标准输入流就是读取键盘输入的数据

标准输出流(System.out):计算机中的最重要的输出设备是显示器,所以标准输出流就是将数据写到显示器上(控制台输出)

static PrintStream **err**
“标准”错误输出流。
static InputStream **in**
“标准”输入流。
static PrintStream **out**
“标准”输出流。
  1. package com.powernode.p1;
  2. import java.io.*;
  3. /**
  4. * 需求:接受键盘录入的数据。不允许使用Scanner类。
  5. *
  6. * 1. 接受键盘录入的数据需要用到标准输入流
  7. * System.in --> InputStream
  8. * 2. 假设键盘录入的数据是中文,字节流处理起来有点麻烦。
  9. * 键盘录入的数据只会是字符串,不可能出现图片、音频、视频
  10. * 所以这里使用字符流会更合适
  11. */
  12. public class Demo06 {
  13. public static void main(String[] args) {
  14. System.out.println("请输入数据:");
  15. InputStream in = System.in;
  16. BufferedReader reader = null;
  17. BufferedWriter writer = null;
  18. try {
  19. reader = new BufferedReader(new InputStreamReader(in));
  20. writer = new BufferedWriter(new FileWriter("D://in.txt"));
  21. String line = reader.readLine();
  22. System.out.println(line);
  23. // 将键盘录入的数据保存到文件中
  24. writer.write(line);
  25. writer.flush();
  26. } catch (IOException exception) {
  27. exception.printStackTrace();
  28. }finally {
  29. // close
  30. }
  31. }
  32. }

IO流关闭的工具类

  1. package com.powernode.p1;
  2. /**
  3. * IO工具类
  4. *
  5. */
  6. public class IOUtils {
  7. private IOUtils(){}
  8. /**
  9. * 关闭流,释放资源
  10. */
  11. public static void close(AutoCloseable... closeable){
  12. for (AutoCloseable autoCloseable : closeable) {
  13. try {
  14. autoCloseable.close();
  15. } catch (Exception e) {
  16. e.printStackTrace();
  17. }
  18. }
  19. }
  20. }

Properties-属性集⭐⭐⭐

  1. public class Properties extends Hashtable<Object,Object>

通过以上的继承关系我们可以知道,Properties中的数据是kv键值对格式的。

Properties 类表示了一个持久的属性集。Properties 可保存在流中或从流中加载。

属性列表中每个键及其对应值都是一个字符串。

将属性集的数据持久化

  1. package com.powernode.p2;
  2. import java.io.FileWriter;
  3. import java.io.IOException;
  4. import java.util.Properties;
  5. /**
  6. * 构造方法摘要
  7. * Properties()
  8. * 创建一个无默认值的空属性列表。
  9. *
  10. * 方法摘要
  11. * --------------------------------- 操作kv的方法
  12. * String getProperty(String key)
  13. * 用指定的键在此属性列表中搜索属性。
  14. * String getProperty(String key, String defaultValue)
  15. * 用指定的键在属性列表中搜索属性。
  16. * Object setProperty(String key, String value)
  17. * 调用 Hashtable 的方法 put。
  18. * Set<String> stringPropertyNames()
  19. * 返回此属性列表中的键集,其中该键及其对应值是字符串,如果在主属性列表中未找到同名的键,则还包括默认属性列表中不同的键。
  20. *
  21. * --------------------------------- 读取数据到属性集中
  22. * void load(InputStream inStream)
  23. * 从输入流中读取属性列表(键和元素对)。
  24. * void load(Reader reader)
  25. * 按简单的面向行的格式从输入字符流中读取属性列表(键和元素对)。
  26. *
  27. * --------------------------------- 将集合中的数据保存成文件
  28. * void store(OutputStream out, String comments)
  29. * 以适合使用 load(InputStream) 方法加载到 Properties 表中的格式,将此 Properties 表中的属性列表(键和元素对)写入输出流。
  30. * void store(Writer writer, String comments)
  31. * 以适合使用 load(Reader) 方法的格式,将此 Properties 表中的属性列表(键和元素对)写入输出字符。
  32. *
  33. *
  34. */
  35. public class Demo01 {
  36. public static void main(String[] args) {
  37. Properties prop = new Properties();
  38. // 设置kv数据
  39. prop.setProperty("name","zhangsan");
  40. prop.setProperty("age","20");
  41. prop.setProperty("sex","male");
  42. // 将属性集中的数据持久化,文件的扩展名就是.properties
  43. // .properties文件中使用#表示注释
  44. try {
  45. // 第二个参数是文件的说明信息
  46. prop.store(new FileWriter("day23/user.properties"),"用户信息");
  47. } catch (IOException exception) {
  48. exception.printStackTrace();
  49. }
  50. }
  51. }

将文件的数据加载到属性集中

  1. package com.powernode.p2;
  2. import java.io.FileReader;
  3. import java.io.IOException;
  4. import java.util.Properties;
  5. import java.util.Set;
  6. public class Demo02 {
  7. public static void main(String[] args) {
  8. Properties properties = new Properties();
  9. try {
  10. properties.load(new FileReader("day23/user.properties"));
  11. System.out.println(properties);
  12. // 如果name1不存在,就返回默认值abc
  13. System.out.println(properties.getProperty("name1","abc"));
  14. Set<String> set = properties.stringPropertyNames();
  15. for (String key : set) {
  16. System.out.println(key+"->"+properties.getProperty(key));
  17. }
  18. } catch (IOException exception) {
  19. exception.printStackTrace();
  20. }
  21. }
  22. }

复制多级文件夹

  1. package com.powernode.p2;
  2. import com.powernode.p1.IOUtils;
  3. import java.io.*;
  4. /**
  5. * 复制多级文件夹
  6. *
  7. * 分析:
  8. * 1. 判断源文件路径是文件还是文件夹
  9. * 文件:直接复制
  10. * 文件夹:
  11. * a. 在目标路径上创建该文件夹
  12. * b. 获取文件夹下的所有内容
  13. * 回到1
  14. *
  15. * 用过以上的分析发现需要使用递归
  16. */
  17. public class CopyFloderDemo {
  18. public static void main(String[] args) {
  19. copyFloder(new File("D://a"),new File("E://"));
  20. }
  21. /**
  22. * 复制多级文件夹
  23. * @param src 源路径
  24. * @param dest 目标路径
  25. */
  26. private static void copyFloder(File src, File dest){
  27. // 1. 判断源文件路径是文件还是文件夹
  28. // src = D://a.txt dest = E://
  29. if(src.isFile()){
  30. // 文件:直接复制
  31. // 将目标路径和源文件的文件名组成新的文件路径
  32. // newFile = E://a.txt
  33. File newFile = new File(dest,src.getName());
  34. copyFile(src,newFile);
  35. }else{
  36. // 是 文件夹:
  37. // src = D://a dest = E://
  38. // a. 在目标路径上创建该文件夹
  39. // newFloder = E://a
  40. File newFloder = new File(dest,src.getName());
  41. // 创建文件夹
  42. newFloder.mkdirs();
  43. // b. 获取源文件夹下的所有内容
  44. File[] files = src.listFiles();
  45. for (File file : files) {
  46. // file = D://a/a.txt newFloder = E://a
  47. // 回到1
  48. copyFloder(file,newFloder);
  49. }
  50. }
  51. }
  52. /**
  53. * 复制文件
  54. * @param src 源路径
  55. * @param dest 目标路径
  56. */
  57. private static void copyFile(File src, File dest){
  58. BufferedInputStream bis = null;
  59. BufferedOutputStream bos = null;
  60. try {
  61. bis = new BufferedInputStream(new FileInputStream(src));
  62. bos = new BufferedOutputStream(new FileOutputStream(dest));
  63. int len;
  64. byte[] bs = new byte[1024];
  65. while((len = bis.read(bs)) != -1){
  66. bos.write(bs,0,len);
  67. }
  68. bos.flush();
  69. } catch (IOException exception) {
  70. exception.printStackTrace();
  71. }finally {
  72. IOUtils.close(bos,bis);
  73. }
  74. }
  75. }