当前位置：首页 > news >正文

【IO】进程间通信

news 来源：原创 2024/5/9 12:17:10

A程序代码：

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
int main(int argc, const char *argv[])
{if(mkfifo("./fifo1",0664)<0){if(errno !=17){perror("mkfifo");return -1;}}if(mkfifo("./fifo2",0664)<0){if(errno !=17){perror("mkfifo");return -1;}}printf("mkfifo success\n");int fd1 = open("./fifo1",O_WRONLY);if(fd1<0){perror("open");return -1;}int fd2=open("./fifo2",O_RDONLY);if(fd2<0){perror("open_fifo2");return-1;}printf("open RDONLY NONBLOCK success\n");char buf[128];ssize_t res;while(1){printf("输入数据>>\n");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]='\0';if(write(fd1,buf,sizeof(buf))<0){perror("write");return -1;}printf("写入成功\n");if(strcmp(buf,"quit")==0){break;                                                                              }
//读数据ibzero(buf,sizeof(buf));res=read(fd2,buf,sizeof(buf));if(res<0){perror("read");return -1;}else if(res==0){printf("写端关闭，且管道没有数据");break;}printf("fd2:%ld  %s\n",res,buf);}close(fd2);close(fd1);return 0;
}

B程序代码：

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
int main(int argc, const char *argv[])
{if(mkfifo("./fifo1",0664)<0){if(errno !=17){perror("mkfifo");return -1;}}if(mkfifo("./fifo2",0664)<0){if(errno !=17){perror("mkfifo");return -1;}}printf("mkfifo success\n");pid_t pid;int fd1 = open("./fifo1",O_RDONLY);if(fd1<0){perror("open");return -1;}int fd2 = open("./fifo2",O_WRONLY);if(fd2<0){perror("open");return -1;}printf("open RDONLY NONBLOCK success\n");char buf[128];ssize_t res;while(1){bzero(buf,sizeof(buf));res=read(fd1,buf,sizeof(buf));if(res<0){perror("read");return -1;}else if(0==res){                                                                       printf("写端关闭,且管道里没有数据\n");break;}printf("%ld :%s \n",res,buf);//写数据bzero(buf,sizeof(buf));printf("输入数据>>\n");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]='\0';if(write(fd2,buf,sizeof(buf))<0){perror("write");return -1;}printf("fd2_写入成功\n");if(strcmp(buf,"quit")==0){break;}}close(fd2);close(fd1);return 0;
}

运行结果：