关于Linux管道中read() 和write()的问题

373202184

代码很简单：
父进程向管道中写入"Hello,World!\n",子进程将管道中的数据读出存储到buf2，然后送到标准输出中。
问题是如果要写入的字符串超过了BUFFER_SIZE，应该怎样编写代码呢？求指点迷津阿

附上代码：

1. #include <stdio.h>
   
2. #include <unistd.h>
   
3. #include <sys/types.h>
   
4. #include <limits.h>
   
5. #include <stdlib.h>
   
6. #include <string.h>
   
7. 
   
8. #define BUFFER_SIZE 100
   
9. 
   
10. 
    
11. int main(int argc, char **argv)
    
12. {
    
13.         int fd[2];
    
14.         char buf1[BUFFER_SIZE] = "Hello,World!\n"  ;
    
15.     char buf2[BUFFER_SIZE];
    
16.         pid_t pid;
    
17.         int len;
    
18.         if((pipe(fd))<0)
    
19.         {
    
20.                 printf("pipe failed\n");
    
21.         }
    
22.         if((pid = fork())<0)
    
23.         {
    
24.                 printf("fork failed\n");
    
25.         }
    
26.         else if(pid>0)
    
27.         {
    
28.                 close(fd[0]);
    
29.                 write(fd[1],buf1,strlen(buf1));
    
30.                 exit(0);
    
31.         }
    
32.         else
    
33.         {
    
34.         wait(2);
    
35.                 close(fd[1]);
    
36.                 len = read(fd[0],buf2,BUFFER_SIZE);
    
37.                 if(len < 0)
    
38.                 {
    
39.                         printf("process failed when read\n");
    
40.                 }
    
41.                 else
    
42.                 {
    
43.                         write(STDOUT_FILENO,buf2,len);
    
44.                 }
    
45.                 exit(0);
    
46.         }
    
47.         return 0;
    
48. }
    

复制代码

我想请教一下，如果要写入的数据比BUFFER_SIZE 还要大该怎么实现呢？

Wisatbff

1. 请用perror输出错误信息。
2. 没看懂你的意思。你把BUFFER_SIZE改大一点不就行了？只要不比PIPE_BUF大，那么写入pipe的信息就不会和其他向同一个pipe写入的信息混起来。

井蛙夏虫

回复 1# 373202184
将write放在while循环中，分多次写直到写完
将read也放在while循环中，直到返回0
另外你的wait(2)，看一下文档吧(man -s 2 wait)
   

fly3ds

给你个循环read的例子 http://www.oschina.net/code/snippet_1016509_25659， 循环write类似。

373202184

回复 4# fly3ds


    谢谢！