黑马程序员技术交流社区

标题: 很纠结！ [打印本页]
作者: 明锦添    时间: 2013-4-25 19:52
标题: 很纠结！
管道流有什么用？它能将一个文件中的内容通过循环读写的方式复制到另一个文件中吗？它们循环读写的时候是怎么对接的？毕老师的视频里完全没有介绍求解释
作者: 郑雪    时间: 2013-4-25 20:28
管道流的主要作用是可以进行两个线程之间的通信，分为管道输出流和管道输入流，如果想要进行管道输出，则必须把输出流连在输入流之上。用管道流进行读写操作需要将读与写分开到不同的线程，这样不会发生线程阻塞的问题。例如：
import java.io.*;
public class Listing {
    static PipedInputStream pipedIS = new PipedInputStream();
    static PipedOutputStream pipedOS = new PipedOutputStream();
    public static void main(String[] args) {
        try {
            pipedIS.connect(pipedOS);
        }
        catch(IOException e) {
            System.err.println("连接失败");
            System.exit(1);
        }
        byte[] inArray = new byte[10];
        int bytesRead = 0;
        startWriterThread();   // 启动写操作线程
        try {
            bytesRead = pipedIS.read(inArray, 0, 10);
            while(bytesRead != -1) {
                System.out.println("已经读取" + bytesRead + "字节...");
                bytesRead = pipedIS.read(inArray, 0, 10);
            }
        }
        catch(IOException e) {
            System.err.println("读取输入错误.");
            System.exit(1);
        }
    }
    // 创建一个独立的线程执行写入PipedOutputStream的操作
    private static void startWriterThread() {
        new Thread(new Runnable() {
            public void run() {
                byte[] outArray = new byte[2000];
                while(true) { // 无终止条件的循环
                    try {
                        // 在该线程阻塞之前，有最多1024字节的数据被写入
                        pipedOS.write(outArray, 0, 2000);
                    }
                    catch(IOException e) {
                        System.err.println("写操作错误");
                        System.exit(1);
                    }
                    System.out.println("     已经发送2000字节...");
                }
            }
        }).start();
    }
}
作者: HM朱蛟    时间: 2013-4-25 23:09
本帖最后由 HM朱蛟 于 2013-4-25 23:12 编辑

这个问题我觉得要是要接触了实际项目才能有深切的体会。
不过这需要一个过程，我看这个视频的时候也不是很明白，纠结半天，但是调整了下心态，就像毕老师说的：“有些问题我们不需要理解的那么深”，确实，有些问题我们花费太多精力反而是事倍功半，姑且先学会“如何使用”。听之任之，存疑信之。今后在使用过程中再慢慢巩固。(针对一些短时间无法掌握牢固的知识点)

我学习这里的时候做过一些总结，不求完全解惑，但求对楼主有所用处吧。


管道流
涉及到了多线程的IO技术

一个线程读，一个线程写
2个管道即使你一个线程执行时，遇见阻塞式方法都不用怕。你这个线程挂了，CPU会执行你另一个线程。互相不影响
------------------------------------------------------------------------

Java I/O系统是建立在数据流概念之上的，
而在UNIX/Linux中有一个类似的概念，
就是管道，
它具有将一个程序的输出当作另一个程序的输入的能力。
在Java中，
可以使用管道流进行线程之间的通信，
输入流和输出流必须相连接，
这样的通信有别于一般的共享数据通信，
其不需要一个共享的数据空间。

------------------------------------------------------------------------

管道流的读写方法都是阻塞式的，所以：
如果写入线程完成了写入操作，当读取流读取数据之前此线程会阻塞，所以此时只有读取流能够获得资源执行
读取流同上
所以他们会很协调的运行

------------------------------------------------------------------------

一个概念上的问题。IO流只有一种表现形态，即要么输出，要么输入。
这样就有了InputStream和OutputStream。再说一点，
流是可以相互包含的，即输入流可以接受输出对象，输出流可以接受输入对象

------------------------------------------------------------------------

Demo:

  2. import java.io.*;
  3. class Run
  4. {
  5.         //main
  6.         public static void main(String [] args)throws Exception
  7.         {
  8.           PipedInputStream in = new PipedInputStream();//创建管道流
  9.           PipedOutputStream out = new PipedOutputStream();//创建管道流

  11.           in.connect(out); //接上

  13.           Read r = new Read(in);
  14.           Write w = new Write(out);
  15.          
  16.                 new Thread(r).start();
  17.                 new Thread(w).start();
  18.                
  19.         }
  20.         
  21.         public static void sop(Object obj)
  22.         {
  23.                 System.out.println(obj);
  24.         }        
  25. }

  27. //1：建立2个Runnable接口
  28. class Read implements Runnable//读
  29. {
  30.         private PipedInputStream in ;
  31.         
  32.         //2 构造函数接收进来一个管道流，这里是读取流
  33.         Read(PipedInputStream in)
  34.         {
  35.                         this.in = in ;
  36.         }

  38.         //多线程，复写run方法
  39.         public void run()
  40.         {
  41.                 try //不能抛异常。
  42.                 {

  44.                         byte[] buf = new byte[1024];//读数据容器
  45.                         
  46.                   System.out.println("读取前，没有数据，阻塞");
  47.                                                                   
  48.                         int len =(in.read(buf));//往数组里面读。
  49.                                                 //PipedInputStream也是InputStream的子类,所以这里调用的是父类的Read方法
  50.                         
  51.                         String s = new String(buf,0,len);
  52.                         
  53.                         System.out.println(s);//打印
  54.                         
  55.                         in.close();//关闭
  56.                 }
  57.                
  58.                 catch (IOException e)
  59.                 {
  60.                          throw new RuntimeException("管道读取流失败");
  61.                 }
  62.         }
  63. }


  66. class Write implements Runnable//写
  67. {
  68.         private PipedOutputStream out ;
  69.         //2 构造函数接收进来一个管道流，这里是读取流
  70.         Write(PipedOutputStream out)
  71.         {
  72.                         this.out = out ;
  73.         }

  75.         //多线程，复写run方法
  76.         public void run()
  77.         {
  78.                 try
  79.                 {
  80.                         System.out.println("等待6秒写入");
  81.                         Thread.sleep(6000);//我让他停6秒
  82.                         out.write("piped lai la".getBytes());//写入字节流
  83.                         out.close();        //关流
  84.                 }
  85.                 catch (Exception e)
  86.                 {
  87.                           throw new RuntimeException("管道输出流失败");
  88.                 }
  89.         }
  90. }
复制代码
作者: 黄玉昆    时间: 2013-4-26 23:41
如果仍有问题，请继续追问，如果问题已解决，请将分类改为已解决，谢谢



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2