#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <assert.h>
#include <fcntl.h> 
#define FIFO_PATH "./fifo"
int main()
{
    umask(0);
    // 創(chuàng)建管道
    int ret = mkfifo(FIFO_PATH, 0666);  
    // 打開管道
    int fd = open(FIFO_PATH, O_RDONLY);                                                  
    if(fd > 0) {
      char buf[1024] = {0};
      while(1){
        //管道讀取數(shù)據(jù)
        int ret = read(fd, buf, sizeof(buf) - 1);
        buf[ret] = 0;
        if(ret > 0){
            printf("%s", buf);
            fflush(stdout);
        }
        // 客戶端不寫入數(shù)據(jù)，則停止讀取
        else if(ret == 0){
            printf("client quit\n");
            break;
        }
        else{
            perror("read filed\n");
            break;
        }
      } 
    }
    close(fd);
   return 0;
}

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h> 
#include <sys/stat.h> 
#include <fcntl.h> 
#include <assert.h> 
#include <stdlib.h>
#define FIFO_PATH           "./fifo"
#define WRITE_TIMES         5
/*
標(biāo)準(zhǔn)輸入輸出錯(cuò)誤輸出 FILE*：
stdin
stdout
stderr
標(biāo)準(zhǔn)輸入輸出錯(cuò)誤輸出fd:
STDIN_FILENO 0
STDOUT_FILENO 1
STDERR_FILENO 2
*/
int main()
{
    //打開管道
    int fd = open(FIFO_PATH, O_WRONLY);
    char buf[64] = {0};
    int times = 0;
    while(1)
    {
        // 寫入5次
        if (++times > WRITE_TIMES) {
            break;
        }
        printf("please input info ：");
        fflush(stdout);
        //從標(biāo)準(zhǔn)輸入獲取數(shù)據(jù)寫入進(jìn)管道。
        ssize_t ret = read(0, buf, sizeof(buf) - 1);
        if(ret > 0){ //將讀取到的數(shù)據(jù)往文件中寫入
          buf[ret] = 0;
          write(fd, buf, sizeof(buf) - 1);
        }
        else {
          perror("read");
        }
    }
    close(fd);
    return 0;
}

.PHONY: all
all: server client
server: server.c
	gcc -o $@ $^
client: client.c
	gcc -o $@ $^
.PHONY: clean
clean:
	rm server client fifo -rf