自己动手写java 字节流输入输出流

　　数据流是一串连续不断的数据的集合，就象水管里的水流，在水管的一端一点一点地供水，而在水管的另一端看到的是一股连续不断的水流。

　 “流是磁盘或其它外围设备中存储的数据的源点或终点。”　

1) 数据流：

一组有序，有起点和终点的字节的数据序列。包括输入流和输出流。

2) 输入流（Input Stream）：

程序从输入流读取数据源。数据源包括外界(键盘、文件、网络…)，即是将数据源读入到程序的通信通道

3) 输出流：

程序向输出流写入数据。将程序中的数据输出到外界（显示器、打印机、文件、网络…）的通信通道。

采用数据流的目的就是使得输出输入独立于设备。

1.输入流代码

import java.io.IOException;

import java.io.InputStream;

//字节数组输入流

public class MyByteInputStream extends InputStream {

    private byte[] buf;// 存放数据流的数组

    private int bufLength;// 记录buf数组长度

    private int pos;// 已经存放数据的下标位置

    private int readPos = 0;// 记录当前数据流读取到的位置

    public MyByteInputStream(int i) {

        buf = new byte[32];

        bufLength = 32;

        pos = 0;

    }

    // 构建输入流（直接存入待输入的流数据）

    public MyByteInputStream(byte[] b) {

        if (b != null && b.length > 0) {

            int copyLength = b.length;

            buf = new byte[copyLength];

            System.arraycopy(b, 0, buf, 0, copyLength);// 复制数组内容

            bufLength = copyLength;

            pos = copyLength;

        } else {

            buf = new byte[32];

            bufLength = 32;

            pos = 0;

        }

    }

    /*

     * 若有数据则返回对应buf[readPos],否则返回-1

     */

    public int read() throws IOException {

        if (pos > 0 && readPos <= (pos - 1)) {

            readPos = readPos + 1;

            return buf[readPos - 1];

        }

        return -1;

    }

}

2.输出流代码

import java.io.OutputStream;

public class MyByteOutStream extends OutputStream {

    private byte[] buf;// 输出流

    private int length;// 存放输出流的长度

    private int pos;// 写到的位置

    public MyByteOutStream() {

        buf = new byte[32];

        length = 32;

        pos = 0;

    }

    public MyByteOutStream(int size) {

        if (size > 0) {

            buf = new byte[size];

            length = size;

            pos = 0;

        } else {

            buf = new byte[32];

            length = 32;

            pos = 0;

        }

    }

    /**

     * 将字符b写入到字节流中，若流空间不够则扩展

     *

     * @param b

     */

    public void write(int b) {

        if (pos < length) {

            buf[pos] = (byte) b;

            pos = pos + 1;

        } else {

            // TODO:扩展字节流buf[]大小

        }

    }

    /**

     * 将输出流copy

     *

     * @return

     */

    public byte[] toByteArray() {

        if (pos > 0) {

            byte[] b = new byte[pos];

            System.arraycopy(buf, 0, b, 0, pos);

            return b;

        }

        return null;

    }

}

3.测试类

import java.io.IOException;

public class MyTest {

    public static void main(String[] args) {

        String inputStr = "Test input stream!";

        String outStr = "Test out strem!";

        // 自定义输入流

        MyByteInputStream myByteInputStream = new MyByteInputStream(inputStr.getBytes());

        try {

            for (int i; (i = myByteInputStream.read()) != -1;) {

                System.out.print(Character.toString((char) i));

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

        System.out.println("");

        // 自定义输出流

        MyByteOutStream myByteOutStream = new MyByteOutStream(100);

        byte[] b = outStr.getBytes();

        for (int i = 0; i < b.length; i++) {

            myByteOutStream.write(b[i]);

        }

        byte[] outb = myByteOutStream.toByteArray();

        for (int i = 0; i < outb.length; i++) {

            System.out.print(Character.toString((char) outb[i]));

        }

        System.out.println("");

    }

}

ps:欢迎各位吐槽指点~

巴特西

自己动手写java 字节流输入输出流

最新文章

热门文章