免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › C/C++ › pipe copy file
最近访问板块 发新帖
查看: 1886 | 回复: 8
打印 上一主题 下一主题

[其他] pipe copy file [复制链接]

shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2015-10-17 14:57 |只看该作者 |倒序浏览
本帖最后由 shihyu 于 2015-10-17 14:59 编辑
  1. #include <sys/types.h>
  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <unistd.h>

  6. #define BUFFER_SIZE 80
  7. #define READ_END 0
  8. #define WRITE_END 1

  10. int main(int argc, char *argv[]) {

  12.     /* argc must be 3 to ensure the correct usage */
  13.     if (argc != 3) {
  14.         printf("The usage of this program is:\n");
  15.         printf("FileCopy input.txt copy.txt\n");
  16.         return 1;
  17.     }

  19.     else {
  20.         int pid;
  21.         /* initialize the pipe and fork variables */
  22.         int fd[2];/* argv[0] is the program name, argv[1] and argv[2] are the file names */
  23.         char *infile = argv[1];
  24.         char *outfile = argv[2];

  26.         /* create a pipe */
  27.         if (pipe(fd) == -1) {
  28.             fprintf(stderr, "Pipe failed");
  29.             return 1;
  30.         }

  32.         /* fork */
  33.         pid = fork();

  35.         /* if pid < 0 there is an error */
  36.         if (pid < 0) {
  37.             fprintf(stderr, "Fork error");
  38.             return 1;
  39.         }

  41.         /* parent code */
  42.         if (pid > 0) {
  43.             FILE *in;
  44.             char buffer[BUFFER_SIZE];
  45.             /* close the unused end of the pipe */
  46.             close(fd[READ_END]);
  47.             /* make a buffer to store input file information */


  50.             /* open input file */
  51.             in = fopen(infile, "r");

  53.             /* make sure it's not null */
  54.             if (in == NULL) {
  55.                 fprintf(stderr, "Error opening file %s\n", infile);
  56.                 return 1;
  57.             }

  59.             /* read from the file into the pipe thru the buffer */
  60.             while (fgets(buffer, BUFFER_SIZE, in)) {
  61.                 write(fd[WRITE_END], buffer, strlen(buffer)+1);
  62.                 printf("buf1:%s\n",buffer);
  63.                 buffer[0]='\0';
  64.             }

  66.             /* close the input file */
  67.             fclose(in);
  68.             close(fd[WRITE_END]);
  69.         }

  71.         /* child process has pid == 0 */
  72.         else {
  73.             FILE *out;
  74.             /* create a buffer to read from the pipe and store into the out file */
  75.             char buffer[BUFFER_SIZE];

  77.             /* close the unused end of the pipe */
  78.             close(fd[WRITE_END]);

  80.             /* initialize the output file */

  82.             /* w+ means open a file for writing and create it if it doesn't exist */
  83.             out = fopen(outfile, "w+");

  85.             while(1) {
  86.                 if (read(fd[READ_END], buffer, BUFFER_SIZE) != 0)
  87.                 {
  88.                     fprintf(out,"%s",buffer);
  89.                     fflush(out);
  90.                 }
  91.                 else
  92.                     break;
  93.             }

  95.             /* close the file and the pipe */
  96.             fclose(out);
  97.             close(fd[READ_END]);
  98.         }
  99.     }

  101.     return 0;
  102. }
复制代码
./copyfile  aa.txt  bb.txt


aa.txt
  1. hello world
  2. 123
  3. 445
  4. 66778
  5. hhhh
复制代码
为什么代码 copy 出来的 bb.txt 只有 hello world?

谢谢
file
tc1989tc

论坛徽章:
16
CU十二周年纪念徽章 日期:2013-10-24 15:41:3415-16赛季CBA联赛之广东 日期:2015-12-23 21:21:55青铜圣斗士 日期:2015-12-05 10:35:30黄金圣斗士 日期:2015-11-26 20:42:16神斗士 日期:2015-11-19 12:47:50每日论坛发贴之星 日期:2015-11-18 06:20:00程序设计版块每日发帖之星 日期:2015-11-18 06:20:002015亚冠之城南 日期:2015-11-10 19:10:492015亚冠之萨济拖拉机 日期:2015-10-28 18:47:282015亚冠之柏太阳神 日期:2015-08-30 17:21:492015亚冠之山东鲁能 日期:2015-07-07 18:48:39摩羯座 日期:2014-08-29 23:01:42
2楼 [报告]
发表于 2015-10-17 18:38 |只看该作者
  1. #include <sys/types.h>

  3. #include <stdio.h>

  5. #include <string.h>

  7. #include <unistd.h>


  10. #define BUFFER_SIZE 80

  12. #define READ_END 0

  14. #define WRITE_END 1


  17. int main(int argc, char *argv[]) {


  20.     /* argc must be 3 to ensure the correct usage */

  22.     if (argc != 3) {

  24.         printf("The usage of this program is:\n");

  26.         printf("FileCopy input.txt copy.txt\n");

  28.         return 1;

  30.     }


  33.     else {

  35.         int pid;

  37.         /* initialize the pipe and fork variables */

  39.         int fd[2];/* argv[0] is the program name, argv[1] and argv[2] are the file names */

  41.         char *infile = argv[1];

  43.         char *outfile = argv[2];


  46.         /* create a pipe */

  48.         if (pipe(fd) == -1) {

  50.             fprintf(stderr, "Pipe failed");

  52.             return 1;

  54.         }


  57.         /* fork */

  59.         pid = fork();


  62.         /* if pid < 0 there is an error */

  64.         if (pid < 0) {

  66.             fprintf(stderr, "Fork error");

  68.             return 1;

  70.         }


  73.         /* parent code */

  75.         if (pid > 0) {

  77.             FILE *in;

  79.             char buffer[BUFFER_SIZE];

  81.             /* close the unused end of the pipe */

  83.             close(fd[READ_END]);

  85.             /* make a buffer to store input file information */



  89.             /* open input file */

  91.             in = fopen(infile, "r");


  94.             /* make sure it's not null */

  96.             if (in == NULL) {

  98.                 fprintf(stderr, "Error opening file %s\n", infile);

  100.                 return 1;

  102.             }


  105.             /* read from the file into the pipe thru the buffer */

  107.             while (fgets(buffer, BUFFER_SIZE, in)) {

  109.                 write(fd[WRITE_END], buffer, strlen(buffer)+1);

  111.                 printf("buf1:%s\n",buffer);

  113.                 buffer[0]='\0';

  115.             }


  118.             /* close the input file */

  120.             fclose(in);

  122.             close(fd[WRITE_END]);
  123. wait(NULL);
  124.         }


  127.         /* child process has pid == 0 */

  129.         else {

  131.             FILE *out;

  133.             /* create a buffer to read from the pipe and store into the out file */

  135.             char buffer[BUFFER_SIZE];


  138.             /* close the unused end of the pipe */

  140.             close(fd[WRITE_END]);


  143.             /* initialize the output file */


  146.             /* w+ means open a file for writing and create it if it doesn't exist */

  148.             out = fopen(outfile, "w+");


  151.             while(1) {

  153.                 if (read(fd[READ_END], buffer, BUFFER_SIZE) != 0)

  155.                 {

  157.                     fprintf(out,"%s",buffer);

  159.                     fflush(out);

  161.                 }

  163.                 else

  165.                     break;

  167.             }


  170.             /* close the file and the pipe */

  172.             fclose(out);

  174.             close(fd[READ_END]);

  176.         }

  178.     }


  181.     return 0;

  183. }
复制代码
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
tc1989tc

论坛徽章:
16
CU十二周年纪念徽章 日期:2013-10-24 15:41:3415-16赛季CBA联赛之广东 日期:2015-12-23 21:21:55青铜圣斗士 日期:2015-12-05 10:35:30黄金圣斗士 日期:2015-11-26 20:42:16神斗士 日期:2015-11-19 12:47:50每日论坛发贴之星 日期:2015-11-18 06:20:00程序设计版块每日发帖之星 日期:2015-11-18 06:20:002015亚冠之城南 日期:2015-11-10 19:10:492015亚冠之萨济拖拉机 日期:2015-10-28 18:47:282015亚冠之柏太阳神 日期:2015-08-30 17:21:492015亚冠之山东鲁能 日期:2015-07-07 18:48:39摩羯座 日期:2014-08-29 23:01:42
3楼 [报告]
发表于 2015-10-17 18:39 |只看该作者
父进程要wait一下。。。
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
4楼 [报告]
发表于 2015-10-17 19:23 |只看该作者
本帖最后由 shihyu 于 2015-10-17 19:24 编辑

父进程 不wait  会怎样吗？
  1.         while (fgets(buffer, BUFFER_SIZE, in)) {

  3.                 write(fd[WRITE_END], buffer, strlen(buffer)+1);

  5.                 printf("buf1:%s\n",buffer);

  7.                 buffer[0]='\0';

  9.             }
复制代码
write(fd[WRITE_END], buffer, strlen(buffer)+1);

做完离开  while 还需要 wait?

谢谢
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
5楼 [报告]
发表于 2015-10-18 01:12 |只看该作者
本帖最后由 shihyu 于 2015-10-18 01:12 编辑

父进程加上wait 结果还是不正常 xd
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
ljmmail

论坛徽章:
0
6楼 [报告]
发表于 2015-10-18 10:09 |只看该作者
  1. #include <sys/types.h>
  2. #include <sys/wait.h>
  3. #include <fcntl.h>

  5. #include <stdio.h>
  6. #include <string.h>
  7. #include <unistd.h>

  9. #define BUFFER_SIZE 80
  10. #define READ_END 0
  11. #define WRITE_END 1

  13. int main(int argc, char *argv[]) {
  14.         /* argc must be 3 to ensure the correct usage */
  15.         if (argc != 3) {
  16.                 printf("The usage of this program is:\n");
  17.                 printf("FileCopy input.txt copy.txt\n");
  18.                 return 1;
  19.         }
  20.         else {
  21.                 int pid;
  22.                 /* initialize the pipe and fork variables */
  23.                 int fd[2];/* argv[0] is the program name, argv[1] and argv[2] are the file names */
  24.                 char *infile = argv[1];
  25.                 char *outfile = argv[2];
  26.                 /* create a pipe */
  27.                 if (pipe(fd) == -1) {
  28.                         fprintf(stderr, "Pipe failed");
  29.                         return 1;
  30.                 }
  31.                 /* fork */
  32.                 pid = fork();
  33.                 /* if pid < 0 there is an error */
  34.                 if (pid < 0) {
  35.                         fprintf(stderr, "Fork error");
  36.                         return 1;
  37.                 }
  38.                 /* parent code */
  39.                 if (pid > 0) {
  40.                         int  in;
  41.                         int  len;
  42.                         char buffer[BUFFER_SIZE];
  43.                         /* close the unused end of the pipe */
  44.                         close(fd[READ_END]);
  45.                         /* make a buffer to store input file information */
  46.                         /* open input file */
  47.                         in = open(infile, O_RDONLY);
  48.                         /* make sure it's not null */
  49.                         if (in == -1) {
  50.                                 fprintf(stderr, "Error opening file %s\n", infile);
  51.                                 return 1;
  52.                         }
  53.                         /* read from the file into the pipe thru the buffer */
  54.                         while ( 1 ) {
  55.                                 memset( buffer, 0, sizeof(buffer));
  56.                                 len = read(in, buffer, BUFFER_SIZE);
  57.                                 if( len <= 0 ) break;
  58.                                 write(fd[WRITE_END], buffer, len );
  59.                         }
  60.                         /* close the input file */
  61.                         close(in);
  62.                         close(fd[WRITE_END]);
  63.                         wait(NULL);
  64.                 }
  65.                 /* child process has pid == 0 */
  66.                 else {
  67.                         int out;
  68.                         int len;
  69.                         /* create a buffer to read from the pipe and store into the out file */
  70.                         char buffer[BUFFER_SIZE];
  71.                         /* close the unused end of the pipe */
  72.                         close(fd[WRITE_END]);
  73.                         /* initialize the output file */
  74.                         /* w+ means open a file for writing and create it if it doesn't exist */
  75.                         out = open(outfile, O_RDWR | O_TRUNC | O_CREAT);
  76.                         while(1) {
  77.                                 memset(buffer, 0, sizeof(buffer));
  78.                                 len = read(fd[READ_END], buffer, BUFFER_SIZE) ;
  79.                                 if (len <= 0 ) break;
  80.                                 write(out,buffer, len );
  81.                                 printf("buf1:%s\n",buffer);
  82.                         }
  83.                         /* close the file and the pipe */
  84.                         close(out);
  85.                         close(fd[READ_END]);
  86.                 }
  87.         }
  88.         return 0;
  89. }
复制代码
文件拷贝，需要试用 open(), read(), write() 低级函数，上述程序测试通过。
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
7楼 [报告]
发表于 2015-10-18 10:41 |只看该作者
本帖最后由 shihyu 于 2015-10-18 10:41 编辑

为什么用  fopen  fprintf + fflush 不行？
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
8楼 [报告]
发表于 2015-10-19 21:57 |只看该作者
  1. #include <sys/types.h>
  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <unistd.h>
  5. #include <sys/wait.h>
  6. #include <fcntl.h>

  8. #define BUFFER_SIZE 80
  9. #define READ_END 0
  10. #define WRITE_END 1

  12. int main(int argc, char* argv[])
  13. {

  15.     /* argc must be 3 to ensure the correct usage */
  16.     if (argc != 3) {
  17.         printf("The usage of this program is:\n");
  18.         printf("FileCopy input.txt copy.txt\n");
  19.         return 1;
  20.     }

  22.     else {
  23.         int pid;
  24.         /* initialize the pipe and fork variables */
  25.         int fd[2];/* argv[0] is the program name, argv[1] and argv[2] are the file names */
  26.         char* infile = argv[1];
  27.         char* outfile = argv[2];

  29.         /* create a pipe */
  30.         if (pipe(fd) == -1) {
  31.             fprintf(stderr, "Pipe failed");
  32.             return 1;
  33.         }

  35.         /* fork */
  36.         pid = fork();

  38.         /* if pid < 0 there is an error */
  39.         if (pid < 0) {
  40.             fprintf(stderr, "Fork error");
  41.             return 1;
  42.         }

  44.         /* parent code */
  45.         if (pid > 0) {
  46.             FILE* in;
  47.             int len;
  48.             char buffer[BUFFER_SIZE];
  49.             int i;
  50.             /* close the unused end of the pipe */
  51.             close(fd[READ_END]);
  52.             /* make a buffer to store input file information */


  55.             /* open input file */
  56.             in = fopen(infile, "r");

  58.             /* make sure it's not null */
  59.             if (in == NULL) {
  60.                 fprintf(stderr, "Error opening file %s\n", infile);
  61.                 return 1;
  62.             }

  64.             /* read from the file into the pipe thru the buffer */
  65.             while (1) {
  66.                 memset(buffer, 0, sizeof(buffer));
  67.                 len = fread(buffer, sizeof(char), BUFFER_SIZE, in);

  69.                 // printf("len 1=%d\n", len);
  70.                 if (len <= 0) {
  71.                     break;
  72.                 }


  75.                 for (i = 0; i < strlen(buffer); ++i) {
  76.                     printf("%c", buffer[i]);
  77.                 }


  80.                 write(fd[WRITE_END], buffer, len);
  81.             }

  83.             /* close the input file */
  84.             fclose(in);
  85.             close(fd[WRITE_END]);
  86.             wait(NULL);
  87.         }

  89.         /* child process has pid == 0 */
  90.         else {
  91.             FILE* out;
  92.             int len;

  94.             /* create a buffer to read from the pipe and store into the out file */
  95.             char buffer[BUFFER_SIZE];

  97.             /* close the unused end of the pipe */
  98.             close(fd[WRITE_END]);

  100.             /* initialize the output file */

  102.             /* w+ means open a file for writing and create it if it doesn't exist */
  103.             out = fopen(outfile, "w");

  105.             while (1) {
  106.                 memset(buffer, 0, sizeof(buffer));
  107.                 len = read(fd[READ_END], buffer, BUFFER_SIZE) ;

  109.                 if (len <= 0) {
  110.                     break;
  111.                 }

  113.                 fwrite(buffer, sizeof(char), len, out);
  114.             }

  116.             /* close the file and the pipe */
  117.             fclose(out);
  118.             close(fd[READ_END]);
  119.         }
  120.     }

  122.     return 0;
  123. }
复制代码
我改成 fread + write 可以 , 但是下面這樣就不能, 是 fgets 跟 write  不能混用嗎？
  1. /* read from the file into the pipe thru the buffer */
  2. while (fgets(buffer, BUFFER_SIZE, in)) {
  3.     write(fd[WRITE_END], buffer, strlen(buffer)+1);
  4.     buffer[0]='\0';
  5. }

复制代码
  1. while(1) {
  2.     if (read(fd[READ_END], buffer, BUFFER_SIZE) != 0)
  3.     {
  4.         fprintf(out,"%s",buffer);
  5.         fflush(out);
  6.     }
  7.     else
  8.         break;
  9. }
复制代码
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
shihyu

论坛徽章:
1
2015年迎新春徽章 日期:2015-03-04 09:49:03
9楼 [报告]
发表于 2015-10-19 22:52 |只看该作者
本帖最后由 shihyu 于 2015-10-19 22:53 编辑

找到原因 fgets 字符串最后自动加入 '\0' , 改回 '\n' 之后 write

read 之后在 buffer 最后加上 '\0' 往 fprintf 送即可
  1. #include <sys/types.h>
  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <unistd.h>

  6. #define BUFFER_SIZE 200
  7. #define READ_END 0
  8. #define WRITE_END 1

  10. int main(int argc, char *argv[]) {

  12.     /* argc must be 3 to ensure the correct usage */
  13.     if (argc != 3) {
  14.         printf("The usage of this program is:\n");
  15.         printf("FileCopy input.txt copy.txt\n");
  16.         return 1;
  17.     }

  19.     else {
  20.         int pid;
  21.         /* initialize the pipe and fork variables */
  22.         int fd[2];/* argv[0] is the program name, argv[1] and argv[2] are the file names */
  23.         char *infile = argv[1];
  24.         char *outfile = argv[2];

  26.         /* create a pipe */
  27.         if (pipe(fd) == -1) {
  28.             fprintf(stderr, "Pipe failed");
  29.             return 1;
  30.         }

  32.         /* fork */
  33.         pid = fork();

  35.         /* if pid < 0 there is an error */
  36.         if (pid < 0) {
  37.             fprintf(stderr, "Fork error");
  38.             return 1;
  39.         }

  41.         /* parent code */
  42.         if (pid > 0) {
  43.             FILE *in;
  44.             char buffer[BUFFER_SIZE];
  45.             int len;
  46.             /* close the unused end of the pipe */
  47.             close(fd[READ_END]);
  48.             /* make a buffer to store input file information */


  51.             /* open input file */
  52.             in = fopen(infile, "r");

  54.             /* make sure it's not null */
  55.             if (in == NULL) {
  56.                 fprintf(stderr, "Error opening file %s\n", infile);
  57.                 return 1;
  58.             }

  60.             /* read from the file into the pipe thru the buffer */
  61.             while (fgets(buffer, BUFFER_SIZE, in)) {
  62.                 len = strlen(buffer);
  63.                 buffer[len]='\n';
  64.                 write(fd[WRITE_END], buffer, len);
  65.             }

  67.             /* close the input file */
  68.             close(fd[WRITE_END]);
  69.             fclose(in);
  70.             wait(NULL);
  71.         }

  73.         /* child process has pid == 0 */
  74.         else {
  75.             FILE *out;
  76.             int len;

  78.             /* create a buffer to read from the pipe and store into the out file */
  79.             char buffer[BUFFER_SIZE];

  81.             /* close the unused end of the pipe */
  82.             close(fd[WRITE_END]);

  84.             /* initialize the output file */

  86.             /* w+ means open a file for writing and create it if it doesn't exist */
  87.             out = fopen(outfile, "w+");

  89.             while(1) {
  90.                 memset(buffer, 0, sizeof(buffer));
  91.                 len = read(fd[READ_END], buffer, BUFFER_SIZE) ;

  93.                 if (len <= 0) {
  94.                     break;
  95.                 }

  97.                 buffer[len + 1] = '\0';

  99.                 printf("buffer=%s, len 2=%ld\n", buffer, strlen(buffer));
  100.                 fprintf(out,"%s", buffer);
  101.                 fflush(out);
  102.             }

  104.             /* close the file and the pipe */
  105.             fclose(out);
  106.             close(fd[READ_END]);
  107.         }
  108.     }

  110.     return 0;
  111. }
复制代码
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP