Java流缓冲区问题

会计考友

先讲一下关于java缓冲区的知识，应用程序和IO设备之间存在一个缓冲区，一般流是没有缓冲区的，但是如果存在缓冲区，就会发现很大的问题。
　　错误代码如下：为了确保问题发生，我使用了BufferedOutputStream，使得手动构造出了一个缓冲区。
/ G& A) f: k7 kimport java.io.*;
6 J+ U% V2 A* B. }: apublic class Test {
    public static void main(String[] args) throws Exception{
        DataOutputStream out = new DataOutputStream(
8 C& Z; w% p' T: [                            new BufferedOutputStream(
                            new FileOutputStream("1.txt")));
        out.writeChars("hello");
        FileInputStream in = new FileInputStream("1.txt");
        int len = in.available();
        byte[] b = new byte[len];
        int actlen = in.read(b);
. d- |! z4 @- R4 j        String str = new String(b);
( i& ~0 ^( N/ v0 T, i$ c; l" i        System.out.println(str);
4 Q" m1 r8 |6 |& i. P7 P$ Z    }
}
8 B$ ~6 _- b9 ~　　发现什么问题了吗？
　　因为如果没有缓冲区，应用程序每次IO都要和设备进行通信，效率很低，因此缓冲区为了提高效率，当写入设备时，先写入缓冲区，等到缓冲区有足够多的数据时，就整体写入设备。这就是问题所在，上个例子中，当我们写入hello时，由于hello占用空间很小，所以暂时存放在缓冲区中，后来输入流想要从文件中读取，但是由于文件中没有字节，所以不能读取hello。
　　这里，解决方法很简单，只要调用out.flush() 或者out.close()即可，这是把缓冲区的数据手动写入文件。
( ]2 d/ W4 b  v) u  T& [' [　　正确代码如下：
) Q5 ?( t3 M$ n7 D0 c/ g2 A7 `import java.io.*;
public class Test {
    public static void main(String[] args) throws Exception{
        DataOutputStream out = new DataOutputStream(
                            new BufferedOutputStream(
$ o, l$ _; `; b4 E4 z                            new FileOutputStream("1.txt")));
5 f) Q+ ]. D' Y+ Z- g2 h' m        out.writeChars("hello");
        out.close();//inserted
        FileInputStream in = new FileInputStream("1.txt");
        int len = in.available();
- J& b) f  M0 k( ], H0 B$ q        byte[] b = new byte[len];
+ F" ^& I, @9 o; ?$ C) o% H        int actlen = in.read(b);
8 ?3 C& T5 f& `: P        String str = new String(b);
3 B: |0 q- @2 U        System.out.println(str);
) ?! g# [2 k8 `, l
; ~# G' M* S+ J' l" [# L- n2 x    }
6 _3 T; J0 E  h}

会计考友

</p>接下来又是我遇到的一个例子，这个例子也很明显的反应出缓冲区的问题。
9 E3 F+ f/ X1 s+ v- {5 X5 |; b) rimport java.io.BufferedReader;
import java.io.FileReader;
$ K% \. D% s- d: w- vimport java.io.FileWriter;
import java.io.IOException;
" @  J* j  Y) p5 Y# _import java.io.PrintWriter;
0 R# A# t/ V5 Z: k6 y. |3 w8 rimport java.util.Calendar;
1 \; k+ ~0 T9 d# [# Uimport java.util.Date;
import java.util.GregorianCalendar;
import java.util.Scanner;
! w6 N/ O. y* G" x9 p6 yimport java.util.StringTokenizer;
' v8 j  q2 G7 W" \/ e9 w" J4 Hpublic class StringTokenizerTest {
; w7 J1 f6 y- V* M: J9 R$ |0 L5 _    public static void main(String[] args) {
" X" B4 n/ y; M' F/ O. |, f/ j        Employee[] e = new Employee[3];
        e[0] = new Employee("Carl Cracker", 75000, 1987, 12, 15);
  ~: m' B! d5 ^4 z6 |        e[1] = new Employee("Harry Hacker", 50000, 1989, 10, 1);
        e[2] = new Employee("Tony Tester", 40000, 1990, 3, 15);
9 `2 y, p  P1 M3 S) O1 i5 p7 i4 U        try {
- I  J2 r% V  h; k/ W            PrintWriter out = new PrintWriter(new FileWriter("1.txt"));
            writeData(e, out);
            // out.close();**********************************************************************
5 s2 V! r+ S) ~( F        } catch (Exception e1) {
            e1.printStackTrace();
/ y4 P! P! w" ]# e        }
        System.out.println("*******是否要读取数据？********");
: h; g* ~3 L, i$ i        Scanner in1 = new Scanner(System.in);
        String yes = in1.nextLine();
+ u" @+ c2 _2 M        if (yes.equalsIgnoreCase("YES")) {
            try {
* C! L' T2 O+ d7 O- f                BufferedReader in = new BufferedReader(new FileReader("1.txt"));
" T7 `2 X# u" Q, b                Employee[] result = readData(in);
                for (int i = 0; i < result.length; i++)
& _* e/ z4 k0 `" P  _: G1 B9 A  H  `                    System.out.println(result);
                in.close();
            } catch (Exception e2) {
! R4 i3 V$ I, }                e2.printStackTrace();
) j6 a$ R2 K/ \7 i& c% R' `; D            }
7 N0 u( n4 L/ p        }
3 a# O" g3 G# o( `- z& t9 ~: W, ?. b    }
# a4 i/ ?0 p! a) c/ s9 ?    public static Employee[] readData(BufferedReader in) throws IOException {
2 u# P$ Y) F9 I9 e! V' L" }        int length = Integer.parseInt(in.readLine());
% z: s6 [" p, ^        Employee[] e = new Employee[length];
2 q9 x/ T0 Q2 N3 i% j        for (int i = 0; i < length; i++) {
            String line = in.readLine();
$ ~! u0 `0 d  [$ G            StringTokenizer token = new StringTokenizer(line, "|");
+ R2 E9 e9 N* N" `/ ?7 }. A            String name = token.nextToken();
            double salary = Double.parseDouble(token.nextToken());
            int year = Integer.parseInt(token.nextToken());
            int month = Integer.parseInt(token.nextToken());
9 B4 S$ F0 z5 d. ?+ s% l1 l3 {            int day = Integer.parseInt(token.nextToken());
            e = new Employee(name, salary, year, month, day);
& O: D2 J4 |- K        }
        return e;
    }
# @' u; \: w0 _) i; s* N    public static void writeData(Employee[] e, PrintWriter out) {
( \! ?9 G, e/ ~" ?        out.println(e.length);
        for (int i = 0; i < e.length; i++) {
! N# u0 R  m+ b  d) ~/ c" m5 y            String name = e.getName();
            double salary = e.getSalary();
            Date date = e.getHireDay();
1 T% E& z- U- X9 ~            Calendar c = new GregorianCalendar();
& C# Y; T) X1 \! b            c.setTime(date);
            int year = c.get(Calendar.YEAR);
            int month = c.get(Calendar.MONTH) + 1;
/ \7 f. W& D, Q1 Q9 J, c            int day = c.get(Calendar.DAY_OF_MONTH);
            out.println(name + "|" + salary + "|" + year + "|" + month + "|"
+ z' s6 l  P4 I+ o! g  K) Y+ [                    + day);
0 @6 Y( y, n1 H9 _7 S        }
        System.out.println("********写入数据完毕********");
    }
}
class Employee {
$ n- |1 m. E- n6 j    public Employee(String n, double s, int year, int month, int day) {
        name = n;
        salary = s;
* t, T* y; Y" O5 V) e) j: j        GregorianCalendar calendar = new GregorianCalendar(year, month - 1, day);
$ a) z' i; B$ k6 Q2 w        hireDay = calendar.getTime();
  \' j4 d" E$ y    }
: x  ]+ U+ z- _6 J    public String getName() {
        return name;
+ n. p9 M, C9 [) j+ X0 g    }
    public double getSalary() {
        return salary;
    }
/ b; V8 a4 r3 A/ R4 J    public Date getHireDay() {
0 M. p, e3 o' X' Q( O$ C        return hireDay;
    }
, U9 h$ T# c& ^% z    public void raiseSalary(double byPercent) {
        double raise = salary * byPercent / 100;
/ v  b* T7 Q) t- o. c# w        salary += raise;
& }" r5 W* n* g8 O. l    }
2 j( @/ K4 z6 ?0 z! x! K; X    public String toString() {
0 A3 w& V4 X  V  P        return getClass().getName() + "[name=" + name + ",salary=" + salary
" @/ f" e, A, g! }+ k" X* k! S' L" p( C) Q                + ",hireDay=" + hireDay + "]";
; I  b- J$ P' D. ?5 ^( N0 x    }
    private String name;
8 t. Q' H' u% R1 P7 ]( E  S    private double salary;
' [% h1 h" F! n7 ~    private Date hireDay;
}
　　结果是没有向文件写入任何数据，为什么呢？
　　唯一的错误就在main方法中没有调用out.close()，把数据从缓冲区刷新到文件。因此用完资源即时关闭是很重要的。