BufferedInputStream與BufferedOutputStream用法簡介

BufferedInputStream是帶緩沖區的輸入流，默認緩沖區大小是8M，能夠減少訪問磁盤的次數，提高文件讀取性能；BufferedOutputStream是帶緩沖區的輸出流，能夠提高文件的寫入效率。BufferedInputStream與BufferedOutputStream分別是FilterInputStream類和FilterOutputStream類的子類，實現了裝飾設計模式。
BufferedInputStream類的例子如下：

import java.io.File;
import java.io.InputStream;
import java.io.FileInputStream;
import java.io.BufferedInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;

public class BufferedInputStreamDemo01{

    // 聲明常量
        public static final int SIZE=1024;

    public static void main(String[] args){
       //變量聲明
           File f=null;
       InputStream input=null;
       BufferedInputStream bis=null;
           StringBuilder strBuild=null;
       SimpleDateFormat sdf=null;
       Date d=null;
           long start=0L;
       long end=0L; 

          try{
          sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
          
          strBuild=new StringBuilder();
                  start=System.currentTimeMillis();
          d=new Date();
          if(d!=null){
                  d.setTime(start);
         }
          System.out.println("程序開始執行時間:"+sdf.format(d));

      f=new File("d:"+File.separator+"demo.txt");
          input=new FileInputStream(f);
          // 指定文件帶緩沖區的讀取流且指定緩沖區大小為2KB
      bis=new BufferedInputStream(input,2*SIZE);
          int bisLength=bis.available();
          int readLength=0;
          byte[] byteArray=new byte[SIZE];
          int tmp=0;
          while((tmp=bis.read(byteArray))!=-1){ 
                strBuild.append(new String(byteArray,0,tmp));
        System.out.println("每次讀取字節數量:"+tmp);
        System.out.println("文件中剩余字節數:"+input.available());
     }
          
          System.out.println(String.format("文件的大小:%d,緩沖區讀取流返回的大小:%d",f.length(),bisLength));
      System.out.println("文件的內容："+strBuild.toString());
      System.out.println("字符串長度:"+strBuild.toString().length());
      char[] cTmp=strBuild.toString().toCharArray();
      System.out.println("字符串->字符數組長度:"+cTmp.length);

      end=System.currentTimeMillis();
      d=new Date();
      if(d!=null){ 
         d.setTime(end);
      }
      System.out.println("程序執行的結束時間:"+sdf.format(d));
      System.out.println("<-------------******************---------------->");
      System.out.println("程序執行時間(ms):"+(end-start)+"毫秒");

       }catch(FileNotFoundException ex){
          ex.printStackTrace();
       }catch(IOException ex){
          ex.printStackTrace();
       }finally{
         try{
               if(input!=null){
         input.close();
        }
           if(bis!=null){
         bis.close(); 
           }
         }catch(IOException ex){
           ex.printStackTrace();
         }
      }
   }
}

BufferedOutputStream類的例子如下：

import java.io.File;
import java.io.OutputStream;
import java.io.FileOutputStream;
import java.io.BufferedOutputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class BufferedOutputStreamDemo01{
        public static final int SIZE=1024;
        public static final String DRIVERNAME="oracle.jdbc.driver.OracleDriver";
        public static final String DBURL="jdbc:oracle:thin:@IP:1521:DB名稱";
    public static final String USERNAME="用戶名";
    public static final String PASSWORD="密碼";
    
    static{
       try{
            // 加載驅動程序
            Class.forName(DRIVERNAME);
          }catch(ClassNotFoundException ex){
            ex.printStackTrace();
        }
    }

    public static void main(String[] args){
       // 變量聲明
       File f=null;
       OutputStream output=null; 
       BufferedOutputStream bos=null;
           Connection con=null;
       PreparedStatement pst=null;
           ResultSet rs=null;
       StringBuilder strBuild=null;
 
           try{
          String sql=" select vendor_no,vendor_name,address,phone,email,zipcode from VENDOR";
           
          con=new BufferedOutputStreamDemo01().getConnection();
                  // 獲得數據庫操作類
                  pst=new BufferedOutputStreamDemo01().getPst(con,sql);
                  // 獲得結果集
          rs=pst.executeQuery();

          f=new File("F:"+File.separator+"tmp.txt");
          output=new FileOutputStream(f,false);
          bos=new BufferedOutputStream(output,SIZE*4);
          
          while(rs.next()){
                        strBuild=new StringBuilder();
            
            // 店號
            strBuild.append(rs.getString("vendor_no"));
            strBuild.append(",");

                        // 店名
            strBuild.append(rs.getString("vendor_name"));
            strBuild.append(",");
            
            // 地址
            strBuild.append(rs.getString("address"));
            strBuild.append(",");
            
            // 電話
            strBuild.append(rs.getString("phone"));
            strBuild.append(",");

                        // 郵件
            strBuild.append(rs.getString("email"));
            strBuild.append(",");

                        // 郵政編碼
            strBuild.append(rs.getString("zipcode"));
            strBuild.append("\n");
            
                        bos.write(strBuild.toString().getBytes("utf-8"));
          }

           }catch(IOException ex1){
               ex1.printStackTrace();
       }catch(SQLException ex){
           ex.printStackTrace();
       }finally{
               try{
             // 關閉流
             if(output!=null){
               output.close(); 
             }
             if(bos!=null){
                            bos.close();
             } 
             //關閉數據庫連接
             if(rs!=null){
                            rs.close();
             }
                         if(pst!=null){
                            pst.close();
             }
                         if(con!=null){
               con.close();
             }
                 }catch(IOException ex){
                ex.printStackTrace();
                 }catch(SQLException ex){
                    ex.printStackTrace();
             }
         }
    }
    
    /**
        **獲得數據庫連接
    **
    **/
    public static Connection getConnection(){
       Connection con=null;
       try{
           // 獲得數據庫連接
           con=DriverManager.getConnection(DBURL,USERNAME,PASSWORD);
       }catch(SQLException ex){
           ex.printStackTrace();
       } 

       return con;
    }
    
    /**
        **獲得數據庫操作類
    **/
    public static PreparedStatement getPst(Connection con,String sql){
            PreparedStatement pst=null;
        try{
          pst=con.prepareStatement(sql);
           }catch(SQLException ex){
          ex.printStackTrace();
           } 

        return pst;
    }
}