/**
     * 存儲數(shù)據(jù)的緩沖區(qū)
     */
    protected byte buf[];
 
    /**
     * 緩沖區(qū)中的有效字節(jié)數(shù)
     */
    protected int count;

 /**
     * 創(chuàng)建新的字節(jié)數(shù)組輸出流、默認緩沖區(qū)大小是32個字節(jié)
     */
    public ByteArrayOutputStream() {
        this(32);
    }
 
    /**
     * 創(chuàng)建新的字節(jié)數(shù)組輸出流，以指定的大小
     */
    public ByteArrayOutputStream(int size) {
        if (size < 0) {
            throw new IllegalArgumentException("Negative initial size: "
                                               + size);
        }
        buf = new byte[size];
    }

   /**
     * 寫入指定的字節(jié)到此字節(jié)輸出流中
     */
    public synchronized void write(int b) {
        ensureCapacity(count + 1);
        buf[count] = (byte) b;
        count += 1;
    }

 /**
     *  從指定數(shù)組的下標off開始寫入len個字節(jié)到該輸出流中
     */
    public synchronized void write(byte b[], int off, int len) {
        if ((off < 0) || (off > b.length) || (len < 0) ||
            ((off + len) - b.length > 0)) {
            throw new IndexOutOfBoundsException();
        }
        ensureCapacity(count + len);
        System.arraycopy(b, off, buf, count, len);
        count += len;
    }

    /**
     *  將此字節(jié)輸出流的內(nèi)容寫入到指定的輸出流中
     */
    public synchronized void writeTo(OutputStream out) throws IOException {
        out.write(buf, 0, count);
    }

     /**
     * 重置此字節(jié)輸出流，廢棄此前存儲的數(shù)據(jù)
     */
    public synchronized void reset() {
        count = 0;
    }

   /**
     * 將此輸出流轉(zhuǎn)成字節(jié)數(shù)組輸出
     */
    public synchronized byte toByteArray()[] {
        return Arrays.copyOf(buf, count);
    }
 
    /**
     * 將此輸出流轉(zhuǎn)成字符串輸出
     */
    public synchronized String toString() {
        return new String(buf, 0, count);
    }
    
 
    /**
     *  通過指定編碼格式將緩沖區(qū)內(nèi)容轉(zhuǎn)換為字符串
     */
    public synchronized String toString(String charsetName)
        throws UnsupportedEncodingException
    {
        return new String(buf, 0, count, charsetName);
    }

    /**
     * 關(guān)閉流無效，關(guān)閉后調(diào)用其他方法不會有異常
     */
    public void close() throws IOException {
    }

public class ByteArrayOutputStream  extends OutputStream

FileInputStream fis=new FileInputStream("test");
BufferedInputStream bis=new BufferedInputStream(fis);
ByteArrayOutputStream baos=new ByteArrayOutputStream();
int c=bis.read();//讀取bis流中的下一個字節(jié)
while(c!=-1){
     baos.write(c);
     c=bis.read();
}
bis.close();
byte retArr[]=baos.toByteArray();

public class ByteArrayInputStreamextends InputStreamByteArrayInputStream 

ByteArrayInputStream(byte[] buf) 

Socket s=...;
DataInputStream dis=new DataInputStream(s.getInputStream());
dis.read(buf);//把所有數(shù)據(jù)存到buf中
ByteArrayInputStream bais=new ByteArrayInputStream(buf); //把剛才的部分視為輸入流
DataInputStream dis_2=new DataInputStream(bais);
//現(xiàn)在可以使用dis_2的各種read方法，讀取指定的字節(jié)