一开始以为输入输出流能相同不用中间值，感觉特爽。
毕老师在视频中演示的是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. }
    
17. 
    
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. }
    
17. 
    
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();
    
34. 
    
35. }catch(IOException e){
    
36. throw new RuntimeException("管道流读取失败");
    
37. }
    
38. }
    
39. }
    
40. 
    
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();
    
55. 
    
56. }catch(IOException e){
    
57. throw new RuntimeException("管道输出失败");
    
58. }
    
59. }
    
60. 
    
61. }

复制代码

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

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

一开始以为输入输出流能相同不用中间值，感觉特爽。
毕老师在视频中演示的是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. }
    
17. 
    
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. }
    
17. 
    
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();
    
34. 
    
35. }catch(IOException e){
    
36. throw new RuntimeException("管道流读取失败");
    
37. }
    
38. }
    
39. }
    
40. 
    
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();
    
55. 
    
56. }catch(IOException e){
    
57. throw new RuntimeException("管道输出失败");
    
58. }
    
59. }
    
60. 
    
61. }

复制代码

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

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