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()); } }