通过有名管道的方式实现对话

目录

• 
  

  一、必备知识

• 
  

  二、思路分析

• 
  

  三、代码分析

• • 1、pj.c
  • 2、sj.c
• 
  

  四、参考书籍

---

QQ，微信是我们早已熟悉不过的聊天软件，通过各种聊天软件，我们可以很愉快的和朋友开启聊天模式，其实，我们也可以自己制作一个聊天工具哦，下面就让我们通过有名管道的方式创建属于我们自己的聊天工具吧！

---

一、必备知识

1. Linux基本 *** 作命令

2. C语言

3. 进程的创建及相关 *** 作

4. 有名管道的创建及相关 *** 作

5. 信号通信

二、思路分析

1. 创建两个用户，一个叫佩吉，一个叫斯基

2. 两个用户创建有名管道

3. 佩吉和斯基通过有名管道交换彼此的进程pid号

4. 佩吉和斯基通过信号和有名管道实现聊天

5. 当一个进程（即一个用户）按下ctrl+c，结束聊天

三、代码分析

创建两个文件，一个命名为pj.c，用于存放和佩吉相关的代码。

另外一个命名为sj.c，用于存放和斯基有关的代码。

1、pj.c

int fd;
int sj_pid;

void read_pid(int sig)
{
	printf("斯基来信号了\n");
}

void readmsg(int sig)
{
	char buf[50]={0};
	read(fd,buf,sizeof(buf));
	printf("斯基说：%s\n",buf);
}

void stop(int sig)
{
	//给斯基发个信号
	kill(sj_pid,20);
	
	//自己挂掉
	exit(0);
	
}

void closeall(int sig)
{
	exit(0);
}


int main(int argc,char *argv[])
{
	if(argc!=2){
		printf("usage:%s \n",argv[0]);
		exit(-1);
	}
	
	//创建有名管道
	if(access(argv[1],F_OK)){
		if(mkfifo(argv[1],0666)){
			perror("mkfifo error");
			exit(-1);
		}
	}
	
	//打开有名管道
	fd = open(argv[1],O_RDWR);
	if(fd<0){
		perror("open error");
		exit(-1);
	}
	
	//注册信号：
	signal(3,read_pid);
	
	/* 交换pid号 */
	int pj_pid = getpid();
	
	//写入 自己的
	write(fd,&pj_pid,sizeof(pj_pid));
	
	pause();
	
	//读取 对方的
	read(fd,&sj_pid,sizeof(sj_pid));
	
	printf("pj_pid:%d\n",pj_pid);
	printf("sj_pid:%d\n",sj_pid);
	
	signal(12,readmsg);
	signal(2,stop);
	signal(20,closeall);
	
	/* 聊天 */
	char buf[50]={0};
	while(1){
		bzero(buf,sizeof(buf));
		scanf("%s",buf);
		
		write(fd,buf,strlen(buf));
		kill(sj_pid,10);
	}
	
	
	
	
	
	return 0;
}

2、sj.c

int fd;
int pj_pid;

void read_pid(int sig)
{
	read(fd,&pj_pid,sizeof(pj_pid));
}

void readmsg(int sig)
{
	char buf[50]={0};
	read(fd,buf,sizeof(buf));
	printf("佩吉说：%s\n",buf);
}

void closeall(int sig)
{
	exit(0);
}

void stop(int sig)
{
	//给佩吉发送个信号
	kill(pj_pid,20);
	
	//自己挂掉
	exit(0);
}


int main(int argc,char *argv[])
{
	if(argc!=2){
		printf("usage:%s \n",argv[0]);
		exit(-1);
	}
	
	//创建有名管道
	if(access(argv[1],F_OK)){
		if(mkfifo(argv[1],0666)){
			perror("mkfifo error");
			exit(-1);
		}
	}
	
	//打开有名管道
	fd = open(argv[1],O_RDWR);
	if(fd<0){
		perror("open error");
		exit(-1);
	}
	
	/* 交换pid号 */
	int sj_pid = getpid();
	
	//读取 对方的
	read(fd,&pj_pid,sizeof(pj_pid));
	
	//写入 自己的
	write(fd,&sj_pid,sizeof(sj_pid));	
	
	//告知对方
	kill(pj_pid,3);
	
	printf("pj_pid:%d\n",pj_pid);
	printf("sj_pid:%d\n",sj_pid);
	
	signal(SIGUSR1,readmsg);
	signal(SIGTSTP,closeall);
	signal(SIGINT,stop);
	
	/* 聊天 */
	char buf[50]={0};
	while(1){
		bzero(buf,sizeof(buf));
		scanf("%s",buf);
		
		write(fd,buf,strlen(buf));
		kill(pj_pid,12);
	}
	
	return 0;
}

四、参考书籍

刘洪涛，熊家.[嵌入式应用程序设计综合教程].北京:人民邮电出版社，2017.
刘洪涛，苗德行.[嵌入式 Linux C语言程序设计].北京:人民邮电出版社，2017