码迷,mamicode.com
首页 > 编程语言 > 详细

c/c++ linux 进程间通信系列3,使用socketpair,pipe

时间:2018-10-20 10:14:13      阅读:150      评论:0      收藏:0      [点我收藏+]

标签:gets   sock   mem   rom   file   输出   ast   lin   取数   

linux 进程间通信系列3,使用socketpair,pipe

1,使用socketpair,实现进程间通信,是双向的。

2,使用pipe,实现进程间通信

使用pipe关键点:fd[0]只能用于接收,fd[1]只能用于发送,是单向的。

3,使用pipe,用标准输入往里写。

疑问:在代码2里不写wait函数的话,父进程不能结束,但是在代码3里也没有写wait函数,父进程却可以结束???

1,使用socketpair:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <wait.h>

int main(){
  int sv[2];
  pid_t pid;
  char buf[128];

  memset(buf, 0, sizeof(buf));

  if(socketpair(AF_UNIX, SOCK_STREAM, 0, sv) != 0){
    perror("socketpair");
    return 1;
  }

  pid = fork();
  if(pid < 0){
    perror("fork");
    return 1;
  }
  if(pid == 0){
    close(sv[0]);
    read(sv[1], buf, sizeof(buf));
    printf("child process : data from parant process [%s]\n", buf);
    exit(0);
  }
  else {
    int status;
    close(sv[1]);
    write(sv[0], "HELLO", 5);
    printf("parent process : child process id %d\n", pid);
    wait(&status);
  }

  return 0;
}

github源代码

2,使用pipe:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <wait.h>

int main(){
  int p[2];
  pid_t pid;
  char buf[128];

  memset(buf, 0, sizeof(buf));

  if(pipe(p) != 0){
    perror("pipe");
    return 1;
  }

  pid = fork();
  if(pid < 0){
    perror("fork");
    return 1;
  }

  if(pid == 0){
    close(p[1]);
    read(p[0], buf, sizeof(buf));
    printf("child process : data form parent process [%s]\n", buf);
    exit(0);
  }
  else{
    close(p[0]);
    write(p[1], "aaaa", 4);
    printf("parent process : child process is %d\n", pid);
    int status;
    wait(&status);
  }
  return 0;
}

github源代码

3,使用pipe,用标准输入往里写。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <wait.h>

int main(){
  int p[2];
  pid_t pid;
  char buf[1024];

  memset(buf, 0, sizeof(buf));

  if(pipe(p) != 0){
    perror("pipe");
    return 1;
  }

  pid = fork();
  if(pid < 0){
    perror("fork");
    return 1;
  }
  if(pid == 0){
    printf("child process : my_id=%d\n",getpid());

    close(p[0]);
    //把标准输出给管道1了
    dup2(p[1], fileno(stdout));

    char *argv[ ]={"ls", "/home/ys/cpp/network"};
    //利用ls命令,往标准输出里,输入文件夹里文件的的名字,标准输出又连接到了上面开的管道1里。
    if(execve("/bin/ls", argv, NULL) < 0){
      perror("exec");
      return 1;
    }
    exit(0);
  }else{
    int n;
    FILE* filep;

    close(p[1]);
    printf("parent process : child process id=%d\n", pid);

    //先打开管道1
    filep = fdopen(p[0], "r");
    if(filep == NULL){
      perror("fdopen");
      return 1;
    }

    //再从管道1里读取数据
    while(fgets(buf, sizeof(buf), filep) != NULL){
      printf("get:%s\n", buf);
    }
    int status;
    wait(&status);
  }
  return 0;
}

github源代码

c/c++ 学习互助QQ群:877684253

技术分享图片

本人微信:xiaoshitou5854

c/c++ linux 进程间通信系列3,使用socketpair,pipe

标签:gets   sock   mem   rom   file   输出   ast   lin   取数   

原文地址:https://www.cnblogs.com/xiaoshiwang/p/9820598.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!