(1) 管道(PIPE)
(2) 命名管道(FIFO)
(3) 信号量(Semphore)
(4) 消息队列(MessageQueue)
(5) 共享内存(SharedMemory)
(6) Socket
Java如何支持进程间通信。我们把Java进程理解为JVM进程。很明显,传统的这些大部分技术是无法被我们的应用程序利用裂陵了(这些进程间通信都是靠系统调用来实现的)。但是Java也有很多方法可以进行进程间通信的。
除了上面提到的Socket之外,当然首选的IPC可以使用Rmi,或者Corba也可以。另外Java nio的MappedByteBuffer也可以通过内存映射文件来实现进程间通信(共享内存)。
给你一个简单的实现吧拍饥,注意一戚贺慎定要高敬先运行MyServer.java
//MyCilent.java
import java.io.*
import java.net.*
import javax.swing.*
import java.awt.*
import java.awt.event.*
public class MyClient extends JFrame implements ActionListener{
JTextField tf
JTextArea tx
JButton bt
PrintWriter out
public MyClient(){
tf=new JTextField(20)
tx=new JTextArea()
tx.setLineWrap(true)
tx.setWrapStyleWord(true)
JPanel pan=new JPanel()
JScrollPane jsp=new JScrollPane(tx)
add(jsp,"Center")
bt=new JButton("SEND")
bt.addActionListener(this)
pan.add(tf)
pan.add(bt)
add(pan,"South")
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0)
}
})
setTitle("THE CLIENT")
setSize(400,300)
setVisible(true)
try{
Socket socket=new Socket("127.0.0.1",1680)
out=new PrintWriter(socket.getOutputStream(),true)
InputStreamReader in = new InputStreamReader(socket.getInputStream())
BufferedReader sin=new BufferedReader(in)
String s
while(true){
s=sin.readLine()
tx.append("#Server Said#: "+s+"\n")
}
}catch(Exception e){
e.printStackTrace()
}
}
public void actionPerformed(ActionEvent e){
if(e.getSource()==bt){
tx.append("@Client Said@: "+tf.getText()+"\n")
out.println(tf.getText())
tf.setText("")
}
}
public static void main(String[] args){
MyClient mct = new MyClient()
}
}
//MyServer.java
import java.io.*
import java.net.*
import javax.swing.*
import java.awt.*
import java.awt.event.*
public class MyServer extends JFrame implements ActionListener{
JTextField tf
JTextArea tx
JButton bt
JScrollPane jsp
JPanel pan
PrintWriter out
public MyServer(){
tx=new JTextArea()
tx.setLineWrap(true)
tx.setWrapStyleWord(true)
jsp=new JScrollPane(tx)
tf=new JTextField(20)
bt=new JButton("SEND")
bt.addActionListener(this)
pan=new JPanel()
pan.add(tf)
pan.add(bt)
add(pan,"South")
add(jsp,"Center")
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0)
}
})
setTitle("THE SERVER")
setSize(400,300)
setVisible(true)
try{
ServerSocket server = new ServerSocket(1680)
Socket socket = server.accept()
InputStreamReader in = new InputStreamReader(socket.getInputStream())
BufferedReader sin=new BufferedReader(in)
out=new PrintWriter(socket.getOutputStream(),true)
while(true){
String s=sin.readLine()
tx.append("@Client Said@: "+s+"\n")
}
}catch(Exception e){
e.printStackTrace()
}
}
public void actionPerformed(ActionEvent e){
if(e.getSource()==bt){
String st = tf.getText()
tx.append("#Server Said#: "+st+"\n")
out.println(st)
tf.setText("")
}
}
public static void main(String[] args){
MyServer msr = new MyServer()
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)