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

灰太狼 2024-02-18 15:08 14阅读 0赞

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

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

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

1) 数据流：

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

![821603-20151013172823804-570655082.jpg][]

2) 输入流（Input Stream）：

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

![821603-20151013172842194-895850889.jpg][]

3) 输出流：

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

![821603-20151013172859757-1837855379.jpg][]

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

1.输入流代码

![复制代码][copycode.gif]

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;
        }
    
    }

![复制代码][copycode.gif]

2.输出流代码

![复制代码][copycode.gif]

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;
        }
    }

![复制代码][copycode.gif]

3.测试类

![复制代码][copycode.gif]

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("");
        }
    
    }

![复制代码][copycode.gif]

ps:欢迎各位吐槽指点~

[java]: http://www.cnblogs.com/mistwalker/p/7489492.html
[821603-20151013172823804-570655082.jpg]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/9b8374381a0146dfb7e08bd298a6ed9d.png
[821603-20151013172842194-895850889.jpg]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/492cff34c9124cf59a602198e9f9c0a2.png
[821603-20151013172859757-1837855379.jpg]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/8e34e7c0bb774e6f92cef757089b1d90.png
[copycode.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/aa8602ecc055464ca9b9af64253130b5.png