节点流的学习

    技术2024-12-05  17

    1FileOutputStreamFileInputStream

    package IO;

    import java.io.*;

    public class FileStream {

     

        public static void main(String[] args) throws Exception {

           FileOutputStream out=new FileOutputStream("hello.txt");//创建输出流

           out.write("我是一个大英雄".getBytes());//在输出流中写入数据

           out.close();//关闭输出流

          

           //在文件中输出内容

           byte [] buf=new byte[1024];//创建一个存储字节数据的数据

           File f=new File("hello.txt");//创建文件的对象

           FileInputStream in=new FileInputStream(f);//创建输入流

           int len=in.read(buf);//获得字符长度

           System.out.println(new String(buf,0,len));//把字符数组转化成字符串,并输出到控制台

           in.close();//关闭输入流

        }

    }

    总结:output是总内存中向硬盘中输入数据,input是从硬盘向内存中输入数据

    2FileWriter类和FileReader类(用来读取文本文件)

    package IO;

    import java.io.*;

    public class FileStream2 {

     

     

        public static void main(String[] args) throws Exception {

           FileWriter out=new FileWriter("hello2.txt");//创建一个写入流

           out.write("www.it315.com");//写入内容

           out.close();//关闭写入流,把缓存中的内容读取到文件中

          

           char [] buf=new char[1024];//定义一个字符数组

           FileReader in=new FileReader("hello2.txt");//创建一个读取流

           int len=in.read(buf);//把流读取到字符数组,并获得字符的长度

           System.out.println(new String(buf,0,len));//把字符组成字符串并输出

           in.close();//关闭读取流

        }

    }

    遇见问题:写入文件时,文档为空白文件

    解决方案:加入close方法,因为FileWriter在调用write读取字符串后不会自动调用flush方法,这与FileOutputStreamwrite方法不同。

    3PipedOutputStreamPipedInputStream类(用来线程间信息传输)

    主类:

    package IO;

    import java.io.*;

    public class PipedStreamTest {

     

        /**

         * @param args

         */

        public static void main(String[] args) throws Exception {     

            Sender t1=new Sender();//定义输入接口对象

            Reseiver t2=new Reseiver();//定义输出接口对象

            PipedOutputStream out=t1.getOutputStream();//获得输出流

            PipedInputStream in=t2.getInputStream();//获得输入流

            out.connect(in);//连接输出流和输入流

            t1.start();//开启输出流线程

            t2.start();//开启输入流线程

        }

     

    }

    Sender类:

    package IO;

     

    import java.io.*;

    public class Sender extends Thread {

        private PipedOutputStream out=new PipedOutputStream();//定义一个流对象成员

        public PipedOutputStream getOutputStream()

        {

           return out;   //返回输出流

        }

        //重写子类的方法

        public void run()

        {

           String strInfo=new String("hello,reserver");//输入到流中的字符串

           try {

               out.write(strInfo.getBytes());//把字符串转换成字节,写入流

               out.close();//关闭流

           } catch (IOException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

           }

          

        }

    }

    Reseiver类:

    package IO;

    import java.io.*;

    public class Reseiver extends Thread {

        private PipedInputStream in=new PipedInputStream();

        public PipedInputStream getInputStream()

        {

           return in;

        }

        public void run()

        {

           byte []buf=new byte[1024];//定义读取数据时存储用的字节数组

           try {

               int len=in.read(buf);//把流中的数据读入数组,并获得字符长度

               System.out.println("the following message comes from sender:"+new String(buf,0,len));//把字符数组中的数据组成字符串,显示出来

               in.close();

           } catch (IOException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

           }

          

        }

    }

    4ByteArrayInputStreamByteArrayOutputStream类(用来把输入缓存数据和读取缓存数据)

    package IO;

    import java.io.*;

    public class ByteArrayTest  {

     

        /**

         * @param args

         */

        public static void main(String[] args) {

           String tmp="abcdefghijklmn";//定义输入的字符串

           byte [] src=tmp.getBytes();//把字符串读入字符数组

           ByteArrayInputStream input=new ByteArrayInputStream(src);//定义缓存读入流

           ByteArrayOutputStream output=new ByteArrayOutputStream();//定义缓存读出流

           transfrom(input, output);//调用转换流的函数

           byte []result=output.toByteArray();//把转换后的输出流添加到字节数组中

           System.out.println(new String(result));//把字节数组转化成字符串输出

          

        }

        public static void transfrom(InputStream in,OutputStream out)

        {

              int ch=0;//定义一个整形变量来存放流的字节

               try {

                  while ((ch=in.read())!=-1) { //如果读取的数不为-1,则循环继续

                      int upperCh=Character.toUpperCase((char)ch);//把小写的字符转换成大写

                      out.write(upperCh);//把转换后的数据加入到输出流中

                    

                  }

               } catch (IOException e) {

                  // TODO Auto-generated catch block

                  e.printStackTrace();

               }

          

          

          

        }

     

    }

    5)增加代码的复用性

    在主函数的结尾加入代码:

    transfrom(System.in, System.out);

    从键盘输入的小写字母,显示在控制台上就是大写字母了

    结论:这样transform函数就通过定义的输入参数是父类的InputStreamOutputStream,成为了一个通用的流转换方法。

     

    最新回复(0)