【Java开源代码栏目提醒】:网学会员为广大网友收集整理了,Communication.java,希望对大家有所帮助!
import java.awt.*;
import java.awt.event.*;
import java.io.*;
public class Communication {
public static void main(String[] args) {
// 创建输出管道流
PipedOutputStream ChannelOut = new PipedOutputStream();
// 创建输入管道流
PipedInputStream ChannelIn = new PipedInputStream();
try {
ChannelOut.connect(ChannelIn);
MsgOut out = new MsgOut(ChannelOut);
MsgIn in = new MsgIn(ChannelIn);
out.start();
in.start();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class MsgOut extends Thread {
DataOutputStream DataWrite;
String Content;
MsgOut(PipedOutputStream Out) {
DataWrite = new DataOutputStream(Out);
}
public void run() {
InputStreamReader in = new InputStreamReader(System.in);
BufferedReader buffer = new BufferedReader(in);
System.out.println("请输入内容:");
// 从标准输入流读取数据
try {
Content = buffer.readLine();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("来自于类MsgOut的信息:"+Content);
// 向管道中写数据
try {
DataWrite.writeUTF(Content);
DataWrite.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class MsgIn extends Thread {
DataInputStream DataRead;
MsgIn(PipedInputStream In){
DataRead = new DataInputStream(In);
}
public void run(){
String Content;
// 读管道中的数据
try {
Content = DataRead.readUTF();
System.out.println("来自于管道的信息:"+Content);
DataRead.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
上一篇:
commSource.java
下一篇:
“文化力”的认识和发展1805字