java中的IO整理(3)----数据操作流---合并流--压缩流--输入输出重定向 - 老秋的日志 - 网易博客
java中的IO整理(3)----数据操作流---合并流--压缩流--输入输出重定向 - 老秋的日志 - 网易博客
输入输出重定向
01 import java.io.File;
02 import java.io.FileNotFoundException;
03 import java.io.FileOutputStream;
04 import java.io.PrintStream;
05
06 /**
07 * 为System.out.println()重定向输出
08 * */
09 public class systemDemo{
10 public static void main(String[] args){
11 // 此刻直接输出到屏幕
12 System.out.println("hello");
13 File file = new File("d:" + File.separator + "hello.txt");
14 try{
15 System.setOut(new PrintStream(new FileOutputStream(file)));
16 }catch(FileNotFoundException e){
17 e.printStackTrace();
18 }
19 System.out.println("这些内容在文件中才能看到哦！");
20 }
21 }
【运行结果】：
eclipse的控制台输出的是hello。然后当我们查看d盘下面的hello.txt文件的时候，会在里面看到：这些内容在文件中才能看到哦！
01 import java.io.File;
02 import java.io.FileNotFoundException;
03 import java.io.FileOutputStream;
04 import java.io.PrintStream;
05
06 /**
07 * System.err重定向 这个例子也提示我们可以使用这种方法保存错误信息
08 * */
09 public class systemErr{
10 public static void main(String[] args){
11 File file = new File("d:" + File.separator + "hello.txt");
12 System.err.println("这些在控制台输出");
13 try{
14 System.setErr(new PrintStream(new FileOutputStream(file)));
15 }catch(FileNotFoundException e){
16 e.printStackTrace();
17 }
18 System.err.println("这些在文件中才能看到哦！");
19 }
20 }
【运行结果】：
你会在eclipse的控制台看到红色的输出：“这些在控制台输出”，然后在d盘下面的hello.txt中会看到：这些在文件中才能看到哦！
01 import java.io.File;
02 import java.io.FileInputStream;
03 import java.io.FileNotFoundException;
04 import java.io.IOException;
05
06 /**
07 * System.in重定向
08 * */
09 public class systemIn{
10 public static void main(String[] args){
11 File file = new File("d:" + File.separator + "hello.txt");
12 if(!file.exists()){
13 return;
14 }else{
15 try{
16 System.setIn(new FileInputStream(file));
17 }catch(FileNotFoundException e){
18 e.printStackTrace();
19 }
20 byte[] bytes = new byte[1024];
21 int len = ;
22 try{
23 len = System.in.read(bytes);
24 }catch(IOException e){
25 e.printStackTrace();
26 }
27 System.out.println("读入的内容为：" + new String(bytes, , len));
28 }
29 }
30 }
【运行结果】：
前提是我的d盘下面的hello.txt中的内容是：“这些文件中的内容哦！”，然后运行程序，输出的结果为：读入的内容为：这些文件中的内容哦！
BufferedReader的小例子
注意： BufferedReader只能接受字符流的缓冲区，因为每一个中文需要占据两个字节，所以需要将System.in这个字节输入流变为字符输入流，采用：
BufferedReader buf = new BufferedReader(
new InputStreamReader(System.in));
下面给一个实例：
01 import java.io.BufferedReader;
02 import java.io.IOException;
03 import java.io.InputStreamReader;
04
05 /**
06 * 使用缓冲区从键盘上读入内容
07 * */
08 public class BufferedReaderDemo{
09 public static void main(String[] args){
10 BufferedReader buf = new BufferedReader(
11 new InputStreamReader(System.in));
12 String str = null;
13 System.out.println("请输入内容");
14 try{
15 str = buf.readLine();
16 }catch(IOException e){
17 e.printStackTrace();
18 }
19 System.out.println("你输入的内容是：" + str);
20 }
21 }
运行结果：
请输入内容
dasdas
你输入的内容是：dasdas
Scanner类
其实我们比较常用的是采用Scanner类来进行数据输入，下面来给一个Scanner的例子吧
01 import java.util.Scanner;
02
03 /**
04 * Scanner的小例子，从键盘读数据
05 * */
06 public class ScannerDemo{
07 public static void main(String[] args){
08 Scanner sca = new Scanner(System.in);
09 // 读一个整数
10 int temp = sca.nextInt();
11 System.out.println(temp);
12 //读取浮点数
13 float flo=sca.nextFloat();
14 System.out.println(flo);
15 //读取字符
16 //...等等的，都是一些太基础的，就不师范了。
17 }
18 }
其实Scanner可以接受任何的输入流
下面给一个使用Scanner类从文件中读出内容
01 import java.io.File;
02 import java.io.FileNotFoundException;
03 import java.util.Scanner;
04
05 /**
06 * Scanner的小例子，从文件中读内容
07 * */
08 public class ScannerDemo{
09 public static void main(String[] args){
10
11 File file = new File("d:" + File.separator + "hello.txt");
12 Scanner sca = null;
13 try{
14 sca = new Scanner(file);
15 }catch(FileNotFoundException e){
16 e.printStackTrace();
17 }
18 String str = sca.next();
19 System.out.println("从文件中读取的内容是：" + str);
20 }
21 }
【运行结果】：
从文件中读取的内容是：这些文件中的内容哦！
数据操作流DataOutputStream、DataInputStream类
01 import java.io.DataOutputStream;
02 import java.io.File;
03 import java.io.FileOutputStream;
04 import java.io.IOException;
05
06 public class DataOutputStreamDemo{
07 public static void main(String[] args) throws IOException{
08 File file = new File("d:" + File.separator + "hello.txt");
09 char[] ch = { 'A', 'B', 'C' };
10 DataOutputStream out = null;
11 out = new DataOutputStream(new FileOutputStream(file));
12 for(char temp : ch){
13 out.writeChar(temp);
14 }
15 out.close();
16 }
17 }
A B C
现在我们在上面例子的基础上，使用DataInputStream读出内容
01 import java.io.DataInputStream;
02 import java.io.File;
03 import java.io.FileInputStream;
04 import java.io.IOException;
05
06 public class DataOutputStreamDemo{
07 public static void main(String[] args) throws IOException{
08 File file = new File("d:" + File.separator + "hello.txt");
09 DataInputStream input = new DataInputStream(new FileInputStream(file));
10 char[] ch = new char[10];
11 int count = ;
12 char temp;
13 while((temp = input.readChar()) != 'C'){
14 ch[count++] = temp;
15 }
16 System.out.println(ch);
17 }
18 }
【运行结果】：
AB
合并流 SequenceInputStream
SequenceInputStream主要用来将2个流合并在一起，比如将两个txt中的内容合并为另外一个txt。下面给出一个实例：
01 import java.io.File;
02 import java.io.FileInputStream;
03 import java.io.FileOutputStream;
04 import java.io.IOException;
05 import java.io.InputStream;
06 import java.io.OutputStream;
07 import java.io.SequenceInputStream;
08
09 /**
10 * 将两个文本文件合并为另外一个文本文件
11 * */
12 public class SequenceInputStreamDemo{
13 public static void main(String[] args) throws IOException{
14 File file1 = new File("d:" + File.separator + "hello1.txt");
15 File file2 = new File("d:" + File.separator + "hello2.txt");
16 File file3 = new File("d:" + File.separator + "hello.txt");
17 InputStream input1 = new FileInputStream(file1);
18 InputStream input2 = new FileInputStream(file2);
19 OutputStream output = new FileOutputStream(file3);
20 // 合并流
21 SequenceInputStream sis = new SequenceInputStream(input1, input2);
22 int temp = ;
23 while((temp = sis.read()) != -1){
24 output.write(temp);
25 }
26 input1.close();
27 input2.close();
28 output.close();
29 sis.close();
30 }
31 }
【运行结果】
结果会在hello.txt文件中包含hello1.txt和hello2.txt文件中的内容。
文件压缩 ZipOutputStream类
先举一个压缩单个文件的例子吧：
01 import java.io.File;
02 import java.io.FileInputStream;
03 import java.io.FileOutputStream;
04 import java.io.IOException;
05 import java.io.InputStream;
06 import java.util.zip.ZipEntry;
07 import java.util.zip.ZipOutputStream;
08
09 public class ZipOutputStreamDemo1{
10 public static void main(String[] args) throws IOException{
11 File file = new File("d:" + File.separator + "hello.txt");
12 File zipFile = new File("d:" + File.separator + "hello.zip");
13 InputStream input = new FileInputStream(file);
14 ZipOutputStream zipOut = new ZipOutputStream(new FileOutputStream(
15 zipFile));
16 zipOut.putNextEntry(new ZipEntry(file.getName()));
17 // 设置注释
18 zipOut.setComment("hello");
19 int temp = ;
20 while((temp = input.read()) != -1){
21 zipOut.write(temp);
22 }
23 input.close();
24 zipOut.close();
25 }
26 }
【运行结果】
运行结果之前，我创建了一个hello.txt的文件，原本大小56个字节，但是压缩之后产生hello.zip之后，居然变成了175个字节，有点搞不懂。
不过结果肯定是正确的，我只是提出我的一个疑问而已。
上面的这个例子测试的是压缩单个文件，下面的们来看看如何压缩多个文件。
01 import java.io.File;
02 import java.io.FileInputStream;
03 import java.io.FileOutputStream;
04 import java.io.IOException;
05 import java.io.InputStream;
06 import java.util.zip.ZipEntry;
07 import java.util.zip.ZipOutputStream;
08
09 /**
10 * 一次性压缩多个文件
11 * */
12 public class ZipOutputStreamDemo2{
13 public static void main(String[] args) throws IOException{
14 // 要被压缩的文件夹
15 File file = new File("d:" + File.separator + "temp");
16 File zipFile = new File("d:" + File.separator + "zipFile.zip");
17 InputStream input = null;
18 ZipOutputStream zipOut = new ZipOutputStream(new FileOutputStream(
19 zipFile));
20 zipOut.setComment("hello");
21 if(file.isDirectory()){
22 File[] files = file.listFiles();
23 for(int i = ; i < files.length; ++i){
24 input = new FileInputStream(files[i]);
25 zipOut.putNextEntry(new ZipEntry(file.getName()
26 + File.separator + files[i].getName()));
27 int temp = ;
28 while((temp = input.read()) != -1){
29 zipOut.write(temp);
30 }
31 input.close();
32 }
33 }
34 zipOut.close();
35 }
36 }
【运行结果】
先看看要被压缩的文件吧：
接下来看看压缩之后的：
大家自然想到，既然能压缩，自然能解压缩，在谈解压缩之前，我们会用到一个ZipFile类，先给一个这个例子吧。java中的每一个压缩文件都是可以使用ZipFile来进行表示的
01 import java.io.File;
02 import java.io.IOException;
03 import java.util.zip.ZipFile;
04
05 /**
06 * ZipFile演示
07 * */
08 public class ZipFileDemo{
09 public static void main(String[] args) throws IOException{
10 File file = new File("d:" + File.separator + "hello.zip");
11 ZipFile zipFile = new ZipFile(file);
12 System.out.println("压缩文件的名称为：" + zipFile.getName());
13 }
14 }
【运行结果】：
压缩文件的名称为：d:\hello.zip
现在我们呢是时候来看看如何加压缩文件了，和之前一样，先让我们来解压单个压缩文件（也就是压缩文件中只有一个文件的情况），我们采用前面的例子产生的压缩文件hello.zip
01 import java.io.File;
02 import java.io.FileOutputStream;
03 import java.io.IOException;
04 import java.io.InputStream;
05 import java.io.OutputStream;
06 import java.util.zip.ZipEntry;
07 import java.util.zip.ZipFile;
08
09 /**
10 * 解压缩文件（压缩文件中只有一个文件的情况）
11 * */
12 public class ZipFileDemo2{
13 public static void main(String[] args) throws IOException{
14 File file = new File("d:" + File.separator + "hello.zip");
15 File outFile = new File("d:" + File.separator + "unZipFile.txt");
16 ZipFile zipFile = new ZipFile(file);
17 ZipEntry entry = zipFile.getEntry("hello.txt");
18 InputStream input = zipFile.getInputStream(entry);
19 OutputStream output = new FileOutputStream(outFile);
20 int temp = ;
21 while((temp = input.read()) != -1){
22 output.write(temp);
23 }
24 input.close();
25 output.close();
26 }
27 }
【运行结果】：
解压缩之前：
这个压缩文件还是175字节
解压之后产生：
又回到了56字节，表示郁闷。
现在让我们来解压一个压缩文件中包含多个文件的情况吧
ZipInputStream类
当我们需要解压缩多个文件的时候，ZipEntry就无法使用了，如果想操作更加复杂的压缩文件，我们就必须使用ZipInputStream类
01 import java.io.File;
02 import java.io.FileInputStream;
03 import java.io.FileOutputStream;
04 import java.io.IOException;
05 import java.io.InputStream;
06 import java.io.OutputStream;
07 import java.util.zip.ZipEntry;
08 import java.util.zip.ZipFile;
09 import java.util.zip.ZipInputStream;
10
11 /**
12 * 解压缩一个压缩文件中包含多个文件的情况
13 * */
14 public class ZipFileDemo3{
15 public static void main(String[] args) throws IOException{
16 File file = new File("d:" + File.separator + "zipFile.zip");
17 File outFile = null;
18 ZipFile zipFile = new ZipFile(file);
19 ZipInputStream zipInput = new ZipInputStream(new FileInputStream(file));
20 ZipEntry entry = null;
21 InputStream input = null;
22 OutputStream output = null;
23 while((entry = zipInput.getNextEntry()) != null){
24 System.out.println("解压缩" + entry.getName() + "文件");
25 outFile = new File("d:" + File.separator + entry.getName());
26 if(!outFile.getParentFile().exists()){
27 outFile.getParentFile().mkdir();
28 }
29 if(!outFile.exists()){
30 outFile.createNewFile();
31 }
32 input = zipFile.getInputStream(entry);
33 output = new FileOutputStream(outFile);
34 int temp = ;
35 while((temp = input.read()) != -1){
36 output.write(temp);
37 }
38 input.close();
39 output.close();
40 }
41 }
42 }
【运行结果】：
被解压的文件：
解压之后再D盘下会出现一个temp文件夹，里面内容：
PushBackInputStream回退流
01 import java.io.ByteArrayInputStream;
02 import java.io.IOException;
03 import java.io.PushbackInputStream;
04
05 /**
06 * 回退流操作
07 * */
08 public class PushBackInputStreamDemo{
09 public static void main(String[] args) throws IOException{
10 String str = "hello,rollenholt";
11 PushbackInputStream push = null;
12 ByteArrayInputStream bat = null;
13 bat = new ByteArrayInputStream(str.getBytes());
14 push = new PushbackInputStream(bat);
15 int temp = ;
16 while((temp = push.read()) != -1){
17 if(temp == ','){
18 push.unread(temp);
19 temp = push.read();
20 System.out.print("(回退" + (char) temp + ") ");
21 }else{
22 System.out.print((char) temp);
23 }
24 }
25 }
26 }
【运行结果】：
hello(回退,) rollenholt
1 /**
2 * 取得本地的默认编码
3 * */
4 public class CharSetDemo{
5 public static void main(String[] args){
6 System.out.println("系统默认编码为：" + System.getProperty("file.encoding"));
7 }
8 }
【运行结果】：
系统默认编码为：GBK
乱码的产生：
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
/**
* 乱码的产生
* */
public class CharSetDemo2{
public static void main(String[] args) throws IOException{
File file = new File("d:" + File.separator + "hello.txt");
OutputStream out = new FileOutputStream(file);
byte[] bytes = "你好".getBytes("ISO8859-1");
out.write(bytes);
out.close();
}
}
【运行结果】：
??
一般情况下产生乱码，都是由于编码不一致的问题。