|
命名管道的默认操作 2）假如 FIFO 里没有数据，调用 read() 函数从 FIFO 里读数据时 read() 也会阻塞。这个特点和无名管道是一样的。 写端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666);//创建命名管道 if(ret != 0) { perror("mkfifo"); } printf("before open\n"); fd = open("my_fifo", O_WRONLY); //等着只读 if(fd < 0) { perror("open fifo"); } printf("after open\n"); printf("before write\n"); // 5s后才往命名管道写数据，没数据前，读端read()阻塞 sleep(5); char send[100] = "Hello Mike"; write(fd, send, strlen(send)); printf("write to my_fifo buf=%s\n", send); return 0; } 读端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666); //创建命名管道 if(ret != 0) { perror("mkfifo"); } printf("before open\n"); fd = open("my_fifo", O_RDONLY);//等着只写 if(fd < 0) { perror("open fifo"); } printf("after open\n"); printf("before read\n"); char recv[100] = {0}; //读数据，命名管道没数据时会阻塞，有数据时就取出来 read(fd, recv, sizeof(recv)); printf("read from my_fifo buf=[%s]\n", recv); return 0; } 请根据下图自行编译运行验证：  3）通信过程中若写进程先退出了，就算命名管道里没有数据，调用 read() 函数从 FIFO 里读数据时不阻塞；若写进程又重新运行，则调用 read() 函数从 FIFO 里读数据时又恢复阻塞。 写端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666); // 创建命名管道 if(ret != 0) { perror("mkfifo"); } fd = open("my_fifo", O_WRONLY); // 等着只读 if(fd < 0) { perror("open fifo"); } char send[100] = "Hello Mike"; write(fd, send, strlen(send)); //写数据 printf("write to my_fifo buf=%s\n",send); while(1); // 阻塞，保证读写进程保持着通信过程 return 0; } 读端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666);// 创建命名管道 if(ret != 0) { perror("mkfifo"); } fd = open("my_fifo", O_RDONLY);// 等着只写 if(fd < 0) { perror("open fifo"); } while(1) { char recv[100] = {0}; read(fd, recv, sizeof(recv)); // 读数据 printf("read from my_fifo buf=[%s]\n",recv); sleep(1); } return 0; } 请根据下图自行编译运行验证：  5）通信过程中，读进程退出后，写进程向命名管道内写数据时，写进程也会（收到 SIGPIPE 信号）退出。 6）调用 write() 函数向 FIFO 里写数据，当缓冲区已满时 write() 也会阻塞。 5）和 6）这两个特点和无名管道是一样的，这里不再验证，详情请看《无名管道》。 命名管道非阻塞标志操作 命名管道可以以非阻塞标志（O_NONBLOCK）方式打开： fd = open("my_fifo", O_WRONLY|O_NONBLOCK); fd = open("my_fifo", O_RDONLY|O_NONBLOCK); 非阻塞标志（O_NONBLOCK）打开的命名管道有以下特点： 1、先以只读方式打开，如果没有进程已经为写而打开一个 FIFO, 只读 open() 成功，并且 open() 不阻塞。 2、先以只写方式打开，如果没有进程已经为读而打开一个 FIFO，只写 open() 将出错返回 -1。 3、read()、write() 读写命名管道中读数据时不阻塞。 请根据以下代码自行编译运行验证。 写端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666); // 创建命名管道 if(ret != 0) { perror("mkfifo"); } // 只写并指定非阻塞方式打开 fd = open("my_fifo", O_WRONLY|O_NONBLOCK); if(fd<0) { perror("open fifo"); } char send[100] = "Hello Mike"; write(fd, send, strlen(send)); printf("write to my_fifo buf=%s\n",send); while(1); return 0; } 读端代码如下： #include <stdio.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, char *argv[]) { int fd; int ret; ret = mkfifo("my_fifo", 0666); // 创建命名管道 if(ret != 0) { perror("mkfifo"); } // 只读并指定非阻塞方式打开 fd = open("my_fifo", O_RDONLY|O_NONBLOCK); if(fd < 0) { perror("open fifo"); } while(1) { char recv[100] = {0}; read(fd, recv, sizeof(recv)); printf("read from my_fifo buf=[%s]\n",recv); sleep(1); } return 0; } |
|
|
