没有合适的资源?快使用搜索试试~ 我知道了~
(2)命名管道(named pipe):命名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它还允许无亲缘关系进程间的通信 (3)信号(Signa
资源详情
资源评论
资源推荐
Java 进程间通信学习
转自:https://www.iteye.com/blog/polim-1278435
进程间通信的主要方法有:
(1)管道(Pipe):管道可用于具有亲缘关系进程间的通信,允许一个进程和另一个与它有共同祖先的进程之间进行通信。
(2)命名管道(named pipe):命名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它还允许无亲缘关系进程间的通信。
命名管道在文件系统中有对应的文件名。命名管道通过命令 mkfifo 或系统调用 mkfifo 来创建。
(3)信号(Signal):信号是比较复杂的通信方式,用于通知接受进程有某种事件发生,除了用于进程间通信外,进程还可以发送信号给进程本
身;linux 除了支持 Unix 早期信号语义函数 sigal 外,还支持语义符合 Posix.1 标准的信号函数 sigaction(实际上,该函数是基于 BSD 的,BSD
为了实现可靠信号机制,又能够统一对外接口,用 sigaction 函数重新实现了 signal 函数)。Linux 中可以使用 kill -12 进程号,像当前进程发送
信号,但前提是发送信号的进程要注册该信号。
example:
OperateSignal operateSignalHandler = new OperateSignal();
Signal sig = new Signal("USR2");
Signal.handle(sig, operateSignalHandler);
(4)消息(Message)队列:消息队列是消息的链接表,包括 Posix 消息队列 system V 消息队列。有足够权限的进程可以向队列中添加消息,
被赋予读权限的进程则可以读走队列中的消息。消息队列克服了信号承载信息量少,管道只能承载无格式字节流以及缓冲区大小受限等缺限。
(5)共享内存:使得多个进程可以访问同一块内存空间,是最快的可用 IPC 形式。是针对其他通信机制运行效率较低而设计的。往往与其它通信
机制,如信号量结合使用,来达到进程间的同步及互斥。
(6)内存映射(mapped memory):内存映射允许任何多个进程间通信,每一个使用该机制的进程通过把一个共享的文件映射到自己的进程地
址空间来实现它。
Java 中有类 MappedByteBuffer 实现内存映射
(7)信号量(semaphore):主要作为进程间以及同一进程不同线程之间的同步手段。
(8)套接口(Socket):更为一般的进程间通信机制,可用于不同机器之间的进程间通信。起初是由 Unix 系统的 BSD 分支开发出来的,但现在
一般可以移植到其它类 Unix 系统上:Linux 和 System V 的变种都支持套接字。
管道方式
一、Java 启动子进程方式
1 1、
2 Runtime rt = Runtime.getRuntime();
3 Process process = rt.exec("java com.test.process.T3");
4 2、
5 ProcessBuilder pb = new ProcessBuilder("java", "com.test.process.T3");
6 Process p = pb.start();
二、Java 父、子进程通信方式(管道方式)
父进程获取子进程输出流方式
1 BufferedInputStream in = new BufferedInputStream(p.getInputStream());
2 BufferedReader br = new BufferedReader(new InputStreamReader(in));
3 String s;
4 while ((s = br.readLine()) != null) {
5 System.out.println(s);
6 }
子进程获取父进程输入流方式
1 package com.test.process;
2 import java.io.BufferedReader;
3 import java.io.IOException;
4 import java.io.InputStreamReader;
5
6 public class T3 {
7
8 public static void main(String[] args) throws IOException {
9 System.out.println("子进程被调用成功!");
10
11 BufferedReader bfr = new BufferedReader(new
InputStreamReader(System.in));
12
13 while (true) {
14 String strLine = bfr.readLine();
15 if (strLine != null) {
16 System.out.println("hi:" + strLine);
17 }
18 }
19 }
20
21 }
三、详细测试类
父进程测试类:
1 package com.test.process.pipe;
2 import java.io.IOException;
3
4 public class ProcessTest {
5
6 public static void main(String[] args) throws IOException,
InterruptedException {
7 Process p = Runtime.getRuntime().exec("java
com.test.process.pipe.MyTest");
8
9 StringBuilder sbuilder = new StringBuilder();
10 for(int k=0;k<1;k++){
11 sbuilder.append("hello");
12 }
13
14 int outSize = 1;
15 TestOut out[] = new TestOut[outSize];
16 for(int i=0;i<outSize;i++){
17 out[i] = new TestOut(p,sbuilder.toString().getBytes());
18 new Thread(out[i]).start();
19 }
20
21 int inSize = 1;
22 TestIn in[] = new TestIn[inSize];
23 for(int j=0;j<inSize;j++){
24 in[j] = new TestIn(p);
25 new Thread(in[j]).start();
26 }
27 }
28 }
子进程类
1 package com.test.process.pipe;
2 import java.io.BufferedReader;
3 import java.io.InputStreamReader;
4
5 public class MyTest {
6 public static void main(String[] args) throws Exception {
7 //读取父进程输入流
8 BufferedReader bfr = new BufferedReader(new
InputStreamReader(System.in));
9 while (true) {
10 String strLine = bfr.readLine();
11 if (strLine != null) {
12 System.out.println(strLine);//这个地方的输出在子进
程控制台是无法输出的,只可以在父进程获取子进程的输出
13 }else {
14 return;
15 }
16 }
17 }
18 }
剩余10页未读,继续阅读
Msura
- 粉丝: 56
- 资源: 323
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0