黑马程序员技术交流社区

标题: 关于管道流复制文件 [打印本页]
作者: 崔政    时间: 2012-10-31 21:15
标题: 关于管道流复制文件
一开始以为输入输出流能相同不用中间值，感觉特爽。
毕老师在视频中演示的是Write线程write一句话，在Read线程中用read（byte[]b）读取到数组中。这是先输出，后读取
在Write线程中输入，在Read线程中直接获取并读
  1. class Read implements Runnable{
  2. private PipedInputStream pis;
  3. public Read(PipedInputStream pis){
  4. this.pis=pis;
  5. }
  6. public void run(){
  7. try{
  8. byte[]by=new byte[1024];
  9. int len=pis.read(by);
  10. String s=new String(by,0,len);
  11. System.out.println(s);
  12. }catch(IOException e){
  13. throw new RuntimeException("读取管道流失败");
  14. }
  15. }
  16. }

  18. class Write implements Runnable{
  19. private PipedOutputStream pos;
  20. public Write(PipedOutputStream pos){
  21. this.pos=pos;
  22. }
  23. public void run(){
  24. try{
  25. pos.write("Piped pia pia lai la".getBytes());
  26. pos.close();
  27. }catch(IOException e){
  28. throw new RuntimeException("写入管道流失败");
  29. }
  30. }
  31. }
复制代码
我自己试了一下，可行。我又试验复制文件，先读取，后输出。
(先写流，后读，可以直接read，但是先读，后写，我不知道怎么write了，我是没办法了，只有静态数组和长度)
不知道大家是用声明办法搞定的，求分享！{:soso__12516999552140149459_4:}
  1. import java.io.*;
  2. class PipedStreamTest{
  3. public static void main(String[] args){
  4. try{
  5. PipedInputStream pis=new PipedInputStream();
  6. PipedOutputStream pos=new PipedOutputStream();
  7. pos.connect(pis);
  8. Thread t1=new Thread(new Rea(pis));
  9. Thread t2=new Thread(new Wri(pos));
  10. t1.start();
  11. t2.start();
  12. }catch(IOException e){
  13. throw new RuntimeException("管道流错误！");
  14. }
  15. }
  16. }

  18. class Rea implements Runnable{
  19. private PipedInputStream pis;
  20. private FileInputStream fis;
  21. static byte[] by=new byte[1024*5];
  22. static int len;
  23. public Rea(PipedInputStream pis){
  24. this.pis=pis;
  25. }
  26. public void run(){
  27. try{
  28. fis=new FileInputStream("Person.java");
  29. len=fis.read(by);
  30. System.out.println("len:"+len);
  31. pis.read(by,0,len);
  32. fis.close();
  33. pis.close();

  35. }catch(IOException e){
  36. throw new RuntimeException("管道流读取失败");
  37. }
  38. }
  39. }

  41. class Wri implements Runnable{
  42. private PipedOutputStream pos;
  43. private FileOutputStream fos;
  44. public Wri(PipedOutputStream pos){
  45. this.pos=pos;
  46. }
  47. public void run(){
  48. try{
  49. fos=new FileOutputStream("copy_Person.java");
  50. System.out.println("Rea.length:"+Rea.by.length+"Rea.len:"+Rea.len);
  51. fos.write(Rea.by,0,Rea.len);
  52. fos.flush();
  53. fos.close();
  54. pos.close();

  56. }catch(IOException e){
  57. throw new RuntimeException("管道输出失败");
  58. }
  59. }

  61. }
复制代码
上面是我写的拷贝一个文件的小程序。就小于5KB的文件来说，可行(因为我数组定义的就是1024*5)，因为我没有写循环
我想知道怎么拷贝更大的文件，保持数组大小不变的情况。
循环我自己试了，我的想法是，如果先Read线程开启，读5KB,然后wait(),接着Write开始写，写5KB，wait()，notify()  Read线程，如此反复。
理论上我觉得可行，可是挂掉了，报了java.lang.IllegalMonitorStateException。
这个代码我就不粘了，感觉写的太丢人。
求高手帮助，用PipedOutputStream和PipedInputStream写一个复制文件的小程序。

PS:话说，用管道流复制文件是不是很麻烦，很搞笑？





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