package io;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
/***
* 管道流:
* 作用:两个线程间的通信
* 在PipedOutputStream类上具有下面方法:
* public void connect(PipedInputStream snk);
* 线程启动后,后自动进行管道的输入、输出操作;
* @author huawei
*
*/
public class PipedIO {
public static void main(String[] args) {
Send s = new Send();
Receive r = new Receive();
try{
s.getPos().connect(r.getPis());//连接管道
}catch(IOException e){
e.printStackTrace();
}
new Thread(s).start();
new Thread(r).start();
}
}
/*线程:写入数据*/
class Send implements Runnable{
private PipedOutputStream pos = null;
public Send(){
this.pos = new PipedOutputStream();
}
@Override
public void run() {
String str = "HELLO WORLD";
try{
this.pos.write(str.getBytes());
}catch(IOException e){
e.printStackTrace();
}
try{
this.pos.close();
}catch(IOException e){
e.printStackTrace();
}
}
public PipedOutputStream getPos(){
return this.pos;
}
}
/*线程:读出数据*/
class Receive implements Runnable{
private PipedInputStream pis = null;
public Receive() {
this.pis = new PipedInputStream();
}
@Override
public void run() {
byte[] b = new byte[1024];
int len = 0;
try{
len = this.pis.read(b);//接收数据
}catch(IOException e){
e.printStackTrace();
}
try{
this.pis.close();
}catch(IOException e){
e.printStackTrace();
}
System.out.println("接收的内容为: " + new String(b,0,len));
}
public PipedInputStream getPis(){
return pis;
}
}
相关推荐
java.io.CharConversionException: isHexDigit.最近项目运行出现了这个问题,刚开始就知道是编码问题,怎么改编码都不正确,在网上搜到的文章。
java.io.Reader 和 java.io.InputStream 的区别
专业的课程讲解 所有的程序都离不开信息的输入和输出。例如,从键盘读取数据、在网络上交换数据、打印报表、读写文件信息等,都要涉及数据输入输出的处理。...在Java中,处理数据流的类主要被放在java.io包中 。
java.io包详细解说,讲得很详细 同类文档:Java-从Decorator,Adapter模式看Java IO库,已上传
ajax,js传值到后台,后台出现java.io.CharConversionException: isHexDigit 异常
串口通讯需要的jar包,gnu.io.SerialPort; gnu.io.CommPortIdentifier; gnu.io.SerialPort; gnu.io.SerialPortEvent; gnu.io.SerialPortEventListener; gnu.io.UnsupportedCommOperationException; Copy RXTXcomm...
串口通信gnu.io包不存在,这里提供jar包,下载导入即可,亲测可用
java.io.Serializable序列化问题
项目工程中用到jdk1.6相关方法,可以使用,但是升级到jdk1.8以后,编译出现java.lang.NoClassDefFoundError: sun/io/CharToByteConverter错误,后经查询,是jdk1.8版本中已经从sun.io.*中进行去除。网上找来了相关...
NULL 博文链接:https://yizhilong28.iteye.com/blog/1154098
java.io clojure.java.io 的 JK7 java.nio.file.Path 兼容性依赖信息该库托管在 Releases 上。 依赖: [me.moocar/java.io " 0.1.0 " ]用法是 JDK7 中引入的文件路径的抽象。 这个库提供了和 Paths 之间的兼容性。 ...
Eclipse 进行 ANT 时错误 Javadoc failed java.io.IOException Cannot run program javadoc
import java.io.*; public class udptest { ///创建一个数据包套接字对象ds,并且指定连接的端口号 ///创建一个数据包对象dp ///指定一个字节数组,用来存储接受的数据 public static void rev() { try { ...
socket.io,socket.io-client 用于java或android连接nodejs websocket
http://blog.csdn.net/maoxiang/archive/2008/09/20/2954553.aspx 详细见
因为项目中需要实现后端推荐消息到前端,经过研究和讨论,最终决定用Socket.io实现消息的推送,而在SpringBoot用Socket.io实现消息推送在网上的例子太少了,本人研究了一天的Socket.io,终于对Socket.io的应用比较...
开发java时,使用的一个引用包,平时dos中测试开发小程序时,可能缺少;
gnu.io.CommDriver.class gnu.io.CommPort.class gnu.io.CommPortEnumerator.class gnu.io.CommPortIdentifier.class gnu.io.CommPortOwnershipListener.class gnu.io.Configure.class gnu.io.I2C.class gnu.io.I2...
用java写socket.io客户端所需jar包,