双进程有名管道通信应用实例

梦里梦外; 2023-03-06 03:42 9阅读 0赞

更多资料请点击：[我的目录][Link 1]  
本篇仅用于记录自己所学知识及应用，代码仍可优化，仅供参考，如果发现有错误的地方，尽管留言于我，谢谢。

要求：  
p1和p2两个进程通信，用有名管道实现  
需要两个管道文件  
第一个管道 p1写入，p2读取，第二个管道 p2写入，p1读取  
p1写入数据  
p2把读到的数据做简单处理后返回给p1，反之亦然  
所谓的简单处理： 如p1写入"123456"，p2收到之后，反馈给p1 “received:123456”  
p1收到该反馈信息后，会和之前的信息确认，没有错误才发送下一个信息

P1部分：

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <fcntl.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    
    int main()
    { 
    	int ret;
    	if(access("/home/gec/jiajia/1.txt",F_OK))					//判断文件是否存在，固定参数F_OK
    	{ 
    		ret = mkfifo("/home/gec/jiajia/1.txt",0666);			//不存在则创建
    		if(ret == -1)
    		{ 
    			perror("创建有名管道失败！\n");
    			return -1;
    		}
    	}
    	
    	int fifo1 = open("/home/gec/jiajia/1.txt",O_RDWR);			//存在就直接打开
    	if(fifo1 == -1)
    	{ 
    		perror("打开有名管道1失败！\n");
    		return -1;
    	}
    	
    	if(access("/home/gec/jiajia/2.txt",F_OK))					//判断文件是否存在，固定参数F_OK
    	{ 
    		ret = mkfifo("/home/gec/jiajia/2.txt",0666);			//不存在则创建
    		if(ret == -1)
    		{ 
    			perror("创建有名管道失败！\n");
    			return -1;
    		}
    	}
    	
    	int fifo2 = open("/home/gec/jiajia/2.txt",O_RDWR);			//存在就直接打开
    	if(fifo2 == -1)
    	{ 
    		perror("打开有名管道2失败！\n");
    		return -1;
    	}
    	
    	char buf1[50];
    	char buf2[50];
    	char receive_buf[60];
    	char fix_buf[50];
    	int flag = 0;
    	int flag1 = 0;
    	int flag2 = 0;
    	
    	while(1)
    	{ 	
    		if(flag1 == 0)
    		{ 
    			bzero(buf1,50);
    			printf("\nP1输入：");
    			scanf("%s",buf1);
    			write(fifo1, buf1 ,50);								//从有名管道1中写入内容
    			flag1 = 1;
    		}
    		
    		bzero(buf2,50);
    		read(fifo2, buf2 ,50);									//从有名管道2中读取内容
    		if(strcmp(buf2,"exit")==0)								//判断是否接收到exit
    		{ 
    			write(fifo1, buf2 ,50);								//从有名管道1中写入exit
    			break;												//退出循环
    		}
    		printf("\nP1输出：%s\n",buf2);
    		
    		if(++flag2 >1)
    		{ 
    			flag1 = 0;
    			flag2 = 0;
    		}
    				
    		if(strstr(buf2,":")!=NULL)								//判断是否接收到拼接字符串
    		{ 
    			bzero(fix_buf,60);
    			for(int j = 0; j < strlen(buf2)-8;j++)
    			{ 
    				fix_buf[j] = buf2[8+j];							//获取":"后的字符串
    			}
    			flag = 1;
    		}
    
    		
    		if(flag == 0)
    		{ 
    			bzero(receive_buf,50);
    			sprintf(receive_buf,"%s%s","receive:",buf2);
    			write(fifo1, receive_buf,50);						//从有名管道1中写入内容
    		}
    		if(flag == 1)
    		{ 
    			if(strcmp(fix_buf,buf1) != 0)						//判断":"后的字符串是否与刚输入的字符串相同
    			{ 
    				printf("信息有误！\n\n");
    			}
    			else 
    			{ 
    				printf("信息无误！\n\n");
    			}
    			flag = 0 ;
    		}	
    	}
    	
    	
    	close(fifo1);												//关闭有名管道1文件
    	close(fifo2);												//关闭有名管道2文件
    	return 0;
    }

P2部分

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <fcntl.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    
    int main()
    { 
    	int ret;
    	if(access("/home/gec/jiajia/1.txt",F_OK))					//判断文件是否存在，固定参数F_OK
    	{ 
    		ret = mkfifo("/home/gec/jiajia/1.txt",0666);			//不存在则创建
    		if(ret == -1)
    		{ 
    			perror("创建有名管道失败！\n");
    			return -1;
    		}
    	}
    	
    	int fifo1 = open("/home/gec/jiajia/1.txt",O_RDWR);			//存在就直接打开
    	if(fifo1 == -1)
    	{ 
    		perror("打开有名管道1失败！\n");
    		return -1;
    	}
    	
    	if(access("/home/gec/jiajia/2.txt",F_OK))					//判断文件是否存在，固定参数F_OK
    	{ 
    		ret = mkfifo("/home/gec/jiajia/2.txt",0666);			//不存在则创建
    		if(ret == -1)
    		{ 
    			perror("创建有名管道失败！\n");
    			return -1;
    		}
    	}
    	
    	int fifo2 = open("/home/gec/jiajia/2.txt",O_RDWR);			//存在就直接打开
    		if(fifo2 == -1)
    	{ 
    		perror("打开有名管道2失败！\n");
    		return -1;
    	}
    	
    	char buf1[50];
    	char buf2[50];
    	char receive_buf[60];
    	char fix_buf[50];
    	int flag = 0;
    	int flag1 = 0;
    	int flag2 = 0;
    	
    	while(1)
    	{ 
    		if(flag1 == 1)
    		{ 
    			bzero(buf1,50);
    			printf("\nP2输入：");
    			scanf("%s",buf1);
    			write(fifo2, buf1 ,50);								//从有名管道1中写入内容
    			flag1 = 0;
    		}
    		
    		bzero(buf2,50);
    		read(fifo1, buf2 ,50);									//从有名管道2中读取内容
    		if(strcmp(buf2,"exit")==0)								//判断是否接收到exit
    		{ 
    			write(fifo2, buf2 ,50);								//从有名管道1中写入内容
    			break;
    		}
    		printf("\nP2输出：%s\n",buf2);	
    		
    		if(strstr(buf2,":")!=NULL)								//判断是否接收到拼接字符串
    		{ 
    			bzero(fix_buf,60);
    			for(int j = 0; j < strlen(buf2)-8;j++)
    			{ 
    				fix_buf[j] = buf2[8+j];							//获取":"后的字符串
    			}
    			flag = 1;
    		}
    
    		if(flag == 0)
    		{ 
    			bzero(receive_buf,50);
    			sprintf(receive_buf,"%s%s","receive:",buf2);
    			write(fifo2, receive_buf,50);						//从有名管道1中写入内容
    			flag1 = 1;
    		}
    		if(flag == 1)
    		{ 
    			if(strcmp(fix_buf,buf1) != 0)						//判断":"后的字符串是否与刚输入的字符串相同
    			{ 
    				printf("信息有误！\n\n");
    			}
    			else 
    			{ 
    				printf("信息无误！\n\n");
    			}
    			flag = 0 ;
    		}		
    	}
    	
    	close(fifo1);												//关闭有名管道1文件
    	close(fifo2);												//关闭有名管道2文件
    	return 0;	
    }

运行结果：随意一方输入exit，P1\\P2就会同时退出  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzc5MzE4MQ_size_16_color_FFFFFF_t_70]

[Link 1]: http://note.youdao.com/noteshare?id=1370b0e8f4a16b80e7dede7836df3c08
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzc5MzE4MQ_size_16_color_FFFFFF_t_70]: /images/20230208/fb3fa57f91e94a278d9f2599a050739b.png