A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 学习交流 › 技术交流 › Java技术交流 › 正文

[论坛提问] 通过管道流复制文件该怎么做呢？

© 王小乖 中级黑马   /  2015-5-20 11:35  /  618 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

我想通过管道流来复制文件，这是我的代码，不过出现问题了，求大神给看看，该怎么解决呢？
  1. package StreamDemo;

  3. import java.io.BufferedReader;
  4. import java.io.BufferedWriter;
  5. import java.io.FileInputStream;
  6. import java.io.FileNotFoundException;
  7. import java.io.FileWriter;
  8. import java.io.IOException;
  9. import java.io.InputStreamReader;
  10. import java.io.PipedInputStream;
  11. import java.io.PipedOutputStream;

  13. public class PipedStreamDemo {
  14.        
  15.         PipedInputStream pis = null;
  16.         public static void main(String[] args) {
  17.                 PipedInputStream pis = new PipedInputStream();
  18.                 PipedOutputStream pos = new PipedOutputStream();
  19.                 try {
  20.                         pis.connect(pos);
  21.                 } catch (IOException e) {
  22.                         e.printStackTrace();
  23.                 }
  24.                 finally{
  25.                         try {
  26.                                 if(pis!=null){
  27.                                         pis.close();
  28.                                 }
  29.                         } catch (Exception e2) {
  30.                                 e2.printStackTrace();
  31.                         }
  32.                         try {
  33.                                 if(pos!=null){
  34.                                         pos.close();
  35.                                 }
  36.                         } catch (Exception e2) {
  37.                                 e2.printStackTrace();
  38.                         }
  39.                 }
  40.                
  41.                 Thread t1 = new Thread(new inputStream(pos));
  42.                 Thread t2 = new Thread(new outputStream(pis));
  43.                 t1.start();
  44.                 t2.start();
  45.                
  46.         }
  47. }

  49. class inputStream implements Runnable{         //这是输入流。
  50.        
  51.         PipedOutputStream pos = null;
  52.        
  53.         BufferedReader bufr = null;
  54.        
  55.         inputStream(PipedOutputStream pos){
  56.                 this.pos = pos;
  57.                 try {
  58.                         bufr = new BufferedReader(new InputStreamReader(new FileInputStream("BufferedDemo.java")));  //跟硬盘上的文件绑定
  59.                 } catch (FileNotFoundException e) {
  60.                         e.printStackTrace();
  61.                 }
  62.         }

  64.         @Override
  65.         public void run() {
  66.                 try {

  68.                         String line = null;
  69.                         while((line=bufr.readLine())!=null){   //读文件上的内容
  70.                                 pos.write(line.getBytes());      //用管道流将输入流读到的文件内容以字节数组的形式写入到管道流中。
  71.                         }
  72.                 } catch (IOException e) {
  73.                         e.printStackTrace();
  74.                 }
  75.                
  76.                 finally{
  77.                         try {
  78.                                 if(pos!=null){
  79.                                         pos.close();
  80.                                 }
  81.                         } catch (Exception e2) {
  82.                                 e2.printStackTrace();
  83.                         }
  84.                        
  85.                         try {
  86.                                 if(bufr!=null){
  87.                                         bufr.close();
  88.                                 }
  89.                         } catch (Exception e2) {
  90.                                 e2.printStackTrace();
  91.                         }
  92.                 }
  93.         }
  94. }

  96. class outputStream implements Runnable{    //输出流
  97.         PipedInputStream pis = null;
  98.         BufferedWriter bufw = null;
  99.        
  100.         outputStream(PipedInputStream pis){
  101.                 this.pis = pis;
  102.                 try {
  103.                         bufw = new BufferedWriter(new FileWriter("test7.txt"));      //跟文件进行绑定，如果文件不存在，系统会创建一个新文件
  104.                                                                                                                                                 //如果文件存在，系统会将原来的文件覆盖掉。
  105.                 } catch (IOException e) {
  106.                         e.printStackTrace();
  107.                 }
  108.         }

  110.         @Override
  111.         public void run() {
  112.                
  113.                 byte by[] = new byte[1024];
  114.                
  115.                 int len = 0;
  116.                
  117.                 try {
  118.                         while((len=pis.read(by))!=-1){         //用管道流将管道流里面的内容读到字节数组中
  119.                                 bufw.write(new String(by),0,len);       //将字节数组中的的内容写入到文件中。
  120.                         }
  121.                         System.out.println("复制完成！");
  122.                 } catch (IOException e) {
  123.                         e.printStackTrace();
  124.                 }
  125.                 finally{
  126.                         try {
  127.                                 if(pis!=null){
  128.                                         pis.close();
  129.                                 }
  130.                         } catch (Exception e2) {
  131.                                 e2.printStackTrace();
  132.                         }
  133.                         try {
  134.                                 if(bufw!=null){
  135.                                         bufw.close();
  136.                                 }
  137.                         } catch (Exception e2) {
  138.                                 e2.printStackTrace();
  139.                         }
  140.                 }
  141.                
  142.         }
  143. }
复制代码


这是出现的问题：
java.io.IOException: Pipe closed
        at java.io.PipedInputStream.read(PipedInputStream.java:308)
        at java.io.PipedInputStream.read(PipedInputStream.java:378)
        at java.io.InputStream.read(InputStream.java:101)
        at StreamDemo.outputStream.run(PipedStreamDemo.java:117)
        at java.lang.Thread.run(Thread.java:744)
java.io.IOException: Pipe closed
        at java.io.PipedInputStream.checkStateForReceive(PipedInputStream.java:261)
        at java.io.PipedInputStream.receive(PipedInputStream.java:227)
        at java.io.PipedOutputStream.write(PipedOutputStream.java:149)
        at java.io.OutputStream.write(OutputStream.java:75)
        at StreamDemo.inputStream.run(PipedStreamDemo.java:70)
        at java.lang.Thread.run(Thread.java:744)

0 个回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马