pipe

Guolei1130 · Guolei1130 · commit 3e0ec70251ab · 2016-08-07T10:58:06.000+08:00
diff --git a/IO/code/PipeStream.java b/IO/code/PipeStream.java
@@ -0,0 +1,92 @@
+package com.example.iostream;
+
+import java.io.IOException;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * Created by guolei on 16-8-5.
+ * ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
+ * |        没有神兽，风骚依旧！          |
+ * |        QQ:1120832563             |
+ * ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
+ */
+
+
+public class PipeStream {
+//http://xouou.iteye.com/blog/1333475
+    public static void main(String[] args){
+        PipedInputStream pis = new PipedInputStream();
+        PipedOutputStream pos = new PipedOutputStream();
+
+        try {
+            pis.connect(pos);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+
+        new Thread(new ReadThread(pis)).start();
+        new Thread(new WriteThread(pos)).start();
+    }
+
+    static class ReadThread implements Runnable{
+
+        private PipedInputStream pis ;
+
+        public ReadThread(PipedInputStream pis){
+            this.pis = pis ;
+        }
+
+        @Override
+        public void run() {
+            byte[] b = new byte[1024];
+            try {
+                if (null != pis){
+                    System.err.println(getDate() + "  等待另一头输入数据");
+                    while (pis.read(b) != -1){
+                        System.err.println(getDate()+ "  读取成功,数据为:"+new String(b).trim());
+                    }
+                    pis.close();
+                }else {
+                    System.err.println("pis is null");
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    static class WriteThread implements Runnable{
+
+        private PipedOutputStream pos;
+
+        public WriteThread(PipedOutputStream pos){
+            this.pos = pos ;
+        }
+
+        @Override
+        public void run() {
+            byte[] b = new byte[1024];
+            try {
+                if (null != pos){
+                    Thread.sleep(5000);
+                    pos.write("这是输入的数据".getBytes("utf-8"));
+                    System.err.println(getDate()+"  输入数据成功");
+                    pos.close();
+                }
+            }catch (IOException e){
+                e.printStackTrace();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    private static String getDate(){
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yy-MM-dd HH:mm:ss");
+
+        return simpleDateFormat.format(new Date().getTime());
+    }
+}
