Linux-进程间通信（一、匿名管道与命名管道）

LINUX进程间通信（二、消息队列）

匿名管道：

头文件：#include<unistd.h>
函数原型：int pipe(int fd[2]);
返回值：成功返回0，失败返回错误代码
注：fd：文件描述符数组，fd[0]代表读端，fd[1]代表写端

用法：

#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>

int main()
{
//creat pipe
int fd[2] = {0};
if(pipe(fd) == -1){
perror("pipe");
exit(1);
}

//pipe create
4000
success
int res = fork();
if(res > 0){
//father
close(fd[1]);
char buf[1024] = {0};
ssize_t tmp = read(fd[0],buf,sizeof(buf)-1);
if(tmp == -1){
perror("read");
exit(1);
}else if(tmp == 0){
printf("read done\n");
exit(0);
}else{
printf("father read : %s",buf);
}
}else if(res == 0){
//child
close(fd[0]);
char tmp[256] = {0};
printf("child say : ");
fflush(stdout);
read(0,tmp,sizeof(tmp)-1);
if(write(fd[1],tmp,strlen(tmp)) == -1){
perror("write");
exit(1);
}
//子进程正常退出
close(fd[1]);
exit(0);
}else{
perror("fork");
exit(1);
}
return 0;
}

管道特点：

管道读写规则

2、当管道满时：采用不阻塞方式将调用返回-1；反之write阻塞，直到有程序读走数据。

int pipe2(int pipefd[2], int flags);

命名管道（FIFO）：相当于创建一个文件，通过一个进程读 一个写来完成通信

//使用mkfifo命令创建一个名为filaname的命名管道。
mkfifo filename

//使用函数创建
函数原型：int mkfifo(const char* filename, mode_t mode);
参数：filename为所要创建的文件名，mode为文件权限.
返回值：成功返回0，失败返回-1

匿名管道与命名管道的区别：

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <stdlib.h>

int main()
{
if( mkfifo("myfifo",0666) == -1){
perror("mkfifo");
exit(1);
}

//FIFO creat success
char buf[1024] = {0};
int rfd = open("myfifo",O_RDONLY);
while(1){
printf("please wait...\n");
if(rfd > 0){
//open myfifo success
printf("client say : ");
fflush(stdout);
ssize_t count = read(rfd,buf,sizeof(buf)-1);
if(count > 0){
buf[count] = 0;
printf("%s",buf);
}else if(count == 0){
printf("client close\n");
exit(0);
}else{
perror("read");
exit(1);
}
}else{
//open return -1,open failed
perror("open");
exit(1);
}
}
close(rfd);
return 0;
}

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>

int main()
{
int wfd = open("myfifo",O_WRONLY);
if(wfd == -1){
perror("open");
exit(1);
}

//open success
char buf[1024] = {0};
while(1){
printf("client send : ");
fflush(stdout);
ssize_t count = read(0,buf,sizeof(buf)-1);
if(count > 0){
buf[count] = 0;
write(wfd,buf,strlen(buf));
}else{
perror("read");
exit(1);
}
}
close(wfd);
return 0;
}

.PHONY:all
all : server client

server:server.c
gcc $^ -o $@

client:client.c
gcc $^ -o $@

.PYHONY : clean
clean:
rm server client myfifo

运行结果显示：