• IO和进程day07（IPC、管道、信号）

    今日任务

    1.代码（一次只能发一次消息，不然会存在一些小问题，在接受消息之后会立刻输出上次的第二次发送的消息）

    read.c文件（先读取消息）

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. int main(int argc, const char *argv[])
    10. {
    11. 	//创建打开第一个管道文件
    12. 	if(-1==mkfifo("./fifo1",0664)){
    13. 		if(17!=errno){
    14. 			perror("mkfifo1");
    15. 			return -1;
    16. 		}
    17. 	}
    18. 	puts("create pipe1 success");
    19. 	//打开管道文件
    20. 	int fd1=open("./fifo1",O_RDONLY);
    21. 	if(-1==fd1){
    22. 		perror("open1");
    23. 		return -1;
    24. 	}
    25. 	puts("open1 success");
    26. 	//创建打开第二个管道文件
    27. 	if(-1==mkfifo("./fifo2",0664)){
    28. 		if(17!=errno){
    29. 			perror("mkfifo2");
    30. 			return -1;
    31. 		}
    32. 	}
    33. 	puts("create pipe2 success");
    34. 	//打开管道文件
    35. 	int fd2=open("./fifo2",O_WRONLY);
    36. 	if(-1==fd2){
    37. 		perror("open2");
    38. 		return -1;
    39. 	}
    40. 	puts("open2 success");
    41. 	//读  写
    42. 	char buf1[128];
    43. 	char buf2[128];
    44. 	while(1){
    45. 		//读
    46. 		bzero(buf1,sizeof(buf1));
    47. 		int res=read(fd1,buf1,sizeof(buf1));
    48. 		if(res<0){
    49. 			perror("read");
    50. 			return -1;
    51. 		}else if(res==0){
    52. 			break;
    53. 		}else{
    54. 			printf("jack:%s\n",buf1);
    55. 			//fprintf(stdout,"jack:%s\n",buf1);
    56. 		}
    57. 		//写
    58. 		bzero(buf2,sizeof(buf2));
    59. 		//scanf("%s",buf2);
    60. 		fgets(buf2,sizeof(buf2),stdin);
    61. 		buf2[strlen(buf2)-1]='\0';
    62. 		if(strcmp(buf2,"quit")==0)
    63. 			break;
    64. 		if(-1==write(fd2,buf2,sizeof(buf2))){
    65. 			perror("write");
    66. 			return -1;
    67. 		}
    68.  
    69. 	}
    70.  
    71. 	//关闭
    72. 	close(fd1);
    73. 	close(fd2);
    74. 	return 0;
    75. }

    write.c文件（先发送消息的）

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. int main(int argc, const char *argv[])
    10. {
    11. 	//创建打开第一个管道文件
    12. 	if(-1==mkfifo("./fifo1",0664)){
    13. 		if(17!=errno){
    14. 			perror("mkfifo1");
    15. 			return -1;
    16. 		}
    17. 	}
    18. 	puts("create pipe1 success");
    19. 	//打开管道文件
    20. 	int fd1=open("./fifo1",O_WRONLY);
    21. 	if(-1==fd1){
    22. 		perror("open1");
    23. 		return -1;
    24. 	}
    25. 	puts("open1 success");
    26. 	//创建打开第二个管道文件
    27. 	if(-1==mkfifo("./fifo2",0664)){
    28. 		if(17!=errno){
    29. 			perror("mkfifo2");
    30. 			return -1;
    31. 		}
    32. 	}
    33. 	puts("create pipe2 success");
    34. 	//打开管道文件
    35. 	int fd2=open("./fifo2",O_RDONLY);
    36. 	if(-1==fd2){
    37. 		perror("open2");
    38. 		return -1;
    39. 	}
    40. 	puts("open2 success");
    41. 	
    42. 	char buf1[128];
    43. 	char buf2[128];
    44. 	while(1){
    45. 		//写
    46. 		bzero(buf1,sizeof(buf1));
    47. 		//scanf("%s",buf1);
    48. 		fgets(buf1,sizeof(buf1),stdin);
    49. 		buf1[strlen(buf1)-1]='\0';
    50. 		if(strcmp(buf1,"quit")==0)
    51. 			break;
    52. 		if(-1==write(fd1,buf1,sizeof(buf1))){
    53. 			perror("write");
    54. 			return -1;
    55. 		}
    56. 		//读
    57. 		bzero(buf2,sizeof(buf2));
    58. 		int res=read(fd2,buf2,sizeof(buf2));
    59. 		if(res<0){
    60. 			perror("read");
    61. 			return -1;
    62. 		}else if(res==0){
    63. 			break;
    64. 		}else{
    65. 			printf("rose:%s\n",buf2);
    66. 			//fprintf(stdout,"rose:%s\n",buf2);
    67. 		}
    68. 	}
    69.  
    70. 	//关闭
    71. 	close(fd1);
    72. 	close(fd2);
    73. 	return 0;
    74. }

    运行结果

    2.代码（就是把代码1分别放到线程中就可以了，）

    jack.c文件

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #include 
    10.  
    11.  
    12. //线程１：读取
    13. void * fun1(void*arg){
    14. 	//创建打开第一个管道文件
    15. 	if(-1==mkfifo("./fifo1",0664)){
    16. 		if(17!=errno){
    17. 			perror("mkfifo1");
    18. 			return NULL;
    19. 		}
    20. 	}
    21. 	puts("create pipe1 success");
    22. 	//打开管道文件
    23. 	int fd1=open("./fifo1",O_WRONLY);
    24. 	if(-1==fd1){
    25. 		perror("open1");
    26. 		return NULL;
    27. 	}
    28. 	puts("open1 success");
    29. 	char buf1[128];
    30. 	while(1){
    31.  
    32. 		//写
    33. 		bzero(buf1,sizeof(buf1));
    34. 		//scanf("%s",buf1);
    35. 		fgets(buf1,sizeof(buf1),stdin);
    36. 		buf1[strlen(buf1)-1]='\0';
    37. 		if(strcmp(buf1,"quit")==0)
    38. 			break;
    39. 		if(-1==write(fd1,buf1,sizeof(buf1))){
    40. 			perror("write");
    41. 			return NULL;
    42. 		}
    43.  
    44. 	}
    45.  
    46. 	close(fd1);
    47. 	pthread_exit(NULL);
    48. }
    49. //线程２：写出
    50. void * fun2(void*arg){
    51. 	//创建打开第二个管道文件
    52. 	if(-1==mkfifo("./fifo2",0664)){
    53. 		if(17!=errno){
    54. 			perror("mkfifo2");
    55. 			return NULL;
    56. 		}
    57. 	}
    58. 	puts("create pipe2 success");
    59. 	//打开管道文件
    60. 	int fd2=open("./fifo2",O_RDONLY);
    61. 	if(-1==fd2){
    62. 		perror("open2");
    63. 		return NULL;
    64. 	}
    65. 	puts("open2 success");
    66.  
    67. 	char buf2[128];
    68. 	while(1){
    69.  
    70. 		//读
    71. 		bzero(buf2,sizeof(buf2));
    72. 		int res=read(fd2,buf2,sizeof(buf2));
    73. 		if(res<0){
    74. 			perror("read");
    75. 			return NULL;
    76. 		}else if(res==0){
    77. 			break;
    78. 		}else{
    79. 			printf("rose:%s\n",buf2);
    80. 			//fprintf(stdout,"rose:%s\n",buf2);
    81. 		}
    82.  
    83. 	}
    84.  
    85. 	close(fd2);
    86. 	pthread_exit(NULL);
    87. }
    88. int main(int argc, const char *argv[])
    89. {
    90. 	//创建线程
    91. 	pthread_t th1,th2;
    92. 	if(0!=pthread_create(&th1,NULL,fun1,NULL)){
    93. 		puts("th1 create failed");
    94. 		return -1;
    95. 	}
    96. 	if(0!=pthread_create(&th2,NULL,fun2,NULL)){
    97. 		puts("th2 create failed");
    98. 		return -1;
    99. 	}
    100.  
    101. 	pthread_join(th1,NULL);
    102. 	pthread_join(th2,NULL);
    103. 	return 0;
    104. }

    rose文件

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #include 
    10. //线程１：写出
    11. void * fun1(void* arg){
    12. 	//创建打开第一个管道文件
    13. 	if(-1==mkfifo("./fifo1",0664)){
    14. 		if(17!=errno){
    15. 			perror("mkfifo1");
    16. 			return NULL;
    17. 		}
    18. 	}
    19. 	puts("create pipe1 success");
    20. 	//打开管道文件
    21. 	int fd1=open("./fifo1",O_RDONLY);
    22. 	if(-1==fd1){
    23. 		perror("open1");
    24. 		return NULL;
    25. 	}
    26. 	puts("open1 success");
    27. 	char buf1[128];
    28. 	while(1){
    29.  
    30. 	//读
    31. 		bzero(buf1,sizeof(buf1));
    32. 		int res=read(fd1,buf1,sizeof(buf1));
    33. 		if(res<0){
    34. 			perror("read");
    35. 			return NULL;
    36. 		}else if(res==0){
    37. 			break;
    38. 		}else{
    39. 			printf("jack:%s\n",buf1);
    40. 			//fprintf(stdout,"jack:%s\n",buf1);
    41. 		}
    42.  
    43.  
    44. 	}
    45. 	
    46. 	close(fd1);
    47. 	pthread_exit(NULL);
    48. }
    49. //线程２：读取
    50. void *fun2(void* arg){
    51. 	//创建打开第二个管道文件
    52. 	if(-1==mkfifo("./fifo2",0664)){
    53. 		if(17!=errno){
    54. 			perror("mkfifo2");
    55. 			return NULL;
    56. 		}
    57. 	}
    58. 	puts("create pipe2 success");
    59. 	//打开管道文件
    60. 	int fd2=open("./fifo2",O_WRONLY);
    61. 	if(-1==fd2){
    62. 		perror("open2");
    63. 		return NULL;
    64. 	}
    65. 	puts("open2 success");
    66. 	char buf2[128];
    67. 	while(1){
    68. 			//写
    69. 		bzero(buf2,sizeof(buf2));
    70. 		//scanf("%s",buf2);
    71. 		fgets(buf2,sizeof(buf2),stdin);
    72. 		buf2[strlen(buf2)-1]='\0';
    73. 		if(strcmp(buf2,"quit")==0)
    74. 			break;
    75. 		if(-1==write(fd2,buf2,sizeof(buf2))){
    76. 			perror("write");
    77. 			return NULL;
    78. 		}
    79.  
    80. 	}
    81.  
    82. 	close(fd2);
    83. 	pthread_exit(NULL);
    84. 	
    85. }
    86. int main(int argc, const char *argv[])
    87. {
    88. 	//创建线程
    89. 	pthread_t th1,th2;
    90. 	if(0!=pthread_create(&th1,NULL,fun1,NULL)){
    91. 		puts("th1 create failed");
    92. 		return -1;
    93. 	}
    94. 	if(0!=pthread_create(&th2,NULL,fun2,NULL)){
    95. 		puts("th2 create failed");
    96. 		return -1;
    97. 	}
    98.  
    99. 	pthread_join(th1,NULL);
    100. 	pthread_join(th2,NULL);
    101. 	return 0;
    102. }

    运行结果

    今日思维导图

    to be honest，sometime my brain is shutdown .

  • 相关阅读:
    大数据Hadoop之——Hadoop 3.3.4 HA（高可用）原理与实现（QJM）
    美国零售电商平台Target，值得入驻吗？如何入驻？
    泰克示波器TDS210更换IPS彩色屏幕
    mybatis.spring.MyBatisSystemException【bug】
    k8s crd设置额外header
    32、学习 Java 中的注解（参照官方教程）
    MySQL进阶
    VOT Toolkit环境配置与使用
    技术对比：Flutter vs. 传统桌面应用开发框架
    Python 算法高级篇：布谷鸟哈希算法与分布式哈希表
  • 原文地址：https://blog.csdn.net/weixin_53762703/article/details/132865708