简易多进程单机多人群聊

太过爱你忘了你带给我的痛 2022-11-25 10:25 136阅读 0赞

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

本篇应用消息队列实现简易多进程单机多人群聊，实现上线通知、下线通知、多人群聊的基本功能，但是代码写得较为粗糙笨拙。

效果如下：  
![在这里插入图片描述][2020080810535931.gif]

![在这里插入图片描述][20200808105405922.gif]

迪西部分：

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/msg.h>
    #include <signal.h>
    #include <errno.h>
    
    char buf[50];
    char otherbuf[50];
    int msgid;
    pid_t id;
    			
    struct msg
    { 
    	long msgtype;  										//消息类型
    	char msgdata[50]; 									//存放真实信息
    };
    struct msg msg1;
    
    void send(int n)										//传参为消息类型
    { 
    	bzero(&msg1,sizeof(msg1));
    	msg1.msgtype = n;
    	strcpy(msg1.msgdata,otherbuf);
    	msgsnd(msgid,&msg1,sizeof(msg1),0);
    }
    
    void quit()
    { 	
    	sprintf(otherbuf,"%s","迪西已下线！\n");
    	send(333);
    	send(555);
    	send(444);
    	exit(id);
    	exit(0);
    }
    
    int main()
    { 
    	msgid=msgget(5555,IPC_CREAT|IPC_EXCL|0777);			//申请创建消息队列
    	if(msgid==-1)
    	{ 
    		if(errno==EEXIST)
    		{ 
    			msgid=msgget(5555,0777);
    		}
    		else
    		{ 
    			perror("创建失败!\n");
    			return -1;
    		}
    	}
    	
    	
    	id = fork();	
    	if (id > 0)											//接收群成员发送过来的信息
    	{ 
    		while(1)
    		{ 	
    			bzero(&msg1,sizeof(msg1));
    			msgrcv(msgid,&msg1,sizeof(msg1),222,0);
    			printf("%s",msg1.msgdata);
    		}
    	}
    	
    	if (id == 0)										//发送信息给群所有成员
    	{ 
    		signal(SIGINT,quit);
    		int flag = 0;
    		while(1)
    		{ 
    
    			bzero(buf,50);
    			bzero(otherbuf,50);
    			
    			if(flag == 0)								//上线通知
    			{ 
    				sprintf(otherbuf,"%s","迪西已上线！\n");
    				flag = 1;
    			}
    			
    			else										//输入消息内容
    			{ 
    				fgets (buf , 50 , stdin);				//可以输入带空格的字符串
    				sprintf(otherbuf,"迪西: %s",buf);
    			}
    			
    			send(333);
    			send(444);
    			send(555);
    		}
    	}
    }

拉拉部分：

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/msg.h>
    #include <signal.h>
    #include <errno.h>
    
    char buf[50];
    char otherbuf[50];
    int msgid;
    pid_t id;
    			
    struct msg
    { 
    	long msgtype;  										//消息类型
    	char msgdata[50]; 									//存放真实信息
    };
    struct msg msg1;
    
    void send(int n)										//传参为消息类型
    { 
    	bzero(&msg1,sizeof(msg1));
    	msg1.msgtype = n;
    	strcpy(msg1.msgdata,otherbuf);
    	msgsnd(msgid,&msg1,sizeof(msg1),0);
    }
    
    void quit()
    { 	
    	sprintf(otherbuf,"%s","拉拉已下线！\n");
    	send(444);
    	send(555);
    	send(222);
    	exit(id);
    	exit(0);
    }
    
    int main()
    { 
    	msgid=msgget(5555,IPC_CREAT|IPC_EXCL|0777);			//申请创建消息队列
    	if(msgid==-1)
    	{ 
    		if(errno==EEXIST)
    		{ 
    			msgid=msgget(5555,0777);
    		}
    		else
    		{ 
    			perror("创建失败!\n");
    			return -1;
    		}
    	}
    	
    	
    	id = fork();	
    	if (id > 0)											//接收群成员发送过来的信息
    	{ 
    		while(1)
    		{ 	
    			bzero(&msg1,sizeof(msg1));
    			msgrcv(msgid,&msg1,sizeof(msg1),333,0);
    			printf("%s",msg1.msgdata);
    		}
    	}
    	
    	if (id == 0)										//发送信息给群所有成员
    	{ 
    		signal(SIGINT,quit);
    		int flag = 0;
    		while(1)
    		{ 
    
    			bzero(buf,50);
    			bzero(otherbuf,50);
    			
    			if(flag == 0)								//上线通知
    			{ 
    				sprintf(otherbuf,"%s","拉拉已上线！\n");
    				flag = 1;
    			}
    			
    			else										//输入消息内容
    			{ 
    				fgets (buf , 50 , stdin);				//可以输入带空格的字符串
    				sprintf(otherbuf,"拉拉: %s",buf);
    			}
    			
    			send(555);
    			send(444);
    			send(222);
    		}
    	}
    }

小波部分：

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/msg.h>
    #include <signal.h>
    #include <errno.h>
    
    char buf[50];
    char otherbuf[50];
    int msgid;
    pid_t id;
    			
    struct msg
    { 
    	long msgtype;  										//消息类型
    	char msgdata[50]; 									//存放真实信息
    };
    struct msg msg1;
    
    void send(int n)										//传参为消息类型
    { 
    	bzero(&msg1,sizeof(msg1));
    	msg1.msgtype = n;
    	strcpy(msg1.msgdata,otherbuf);
    	msgsnd(msgid,&msg1,sizeof(msg1),0);
    }
    
    void quit()
    { 	
    	sprintf(otherbuf,"%s","小波已下线！\n");
    	send(333);
    	send(555);
    	send(222);
    	exit(id);
    	exit(0);
    }
    int main()
    { 
    	msgid=msgget(5555,IPC_CREAT|IPC_EXCL|0777);			//申请创建消息队列
    	if(msgid==-1)
    	{ 
    		if(errno==EEXIST)
    		{ 
    			msgid=msgget(5555,0777);
    		}
    		else
    		{ 
    			perror("创建失败!\n");
    			return -1;
    		}
    	}
    	
    	
    	id = fork();	
    	if (id > 0)											//接收群成员发送过来的信息
    	{ 
    		while(1)
    		{ 	
    			bzero(&msg1,sizeof(msg1));
    			msgrcv(msgid,&msg1,sizeof(msg1),444,0);
    			printf("%s",msg1.msgdata);
    		}
    	}
    	
    	if (id == 0)										//发送信息给群所有成员
    	{ 
    		signal(SIGINT,quit);
    		int flag = 0;
    		while(1)
    		{ 
    
    			bzero(buf,50);
    			bzero(otherbuf,50);
    			
    			if(flag == 0)								//上线通知
    			{ 
    				sprintf(otherbuf,"%s","小波已上线！\n");
    				flag = 1;
    			}
    			
    			else										//输入消息内容
    			{ 
    				fgets (buf , 50 , stdin);				//可以输入带空格的字符串
    				sprintf(otherbuf,"小波: %s",buf);
    			}
    			
    			send(333);
    			send(555);
    			send(222);
    		}
    	}
    }

丁丁部分：

#include <stdio.h>
    #include <unistd.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/msg.h>
    #include <signal.h>
    #include <errno.h>
    
    char buf[50];
    char otherbuf[50];
    int msgid;
    pid_t id;
    
    struct msg
    { 
    	long msgtype;  										//消息类型
    	char msgdata[50]; 									//存放真实信息
    };
    struct msg msg1;
    
    void send(int n)										//传参为消息类型
    { 
    	bzero(&msg1,sizeof(msg1));
    	msg1.msgtype = n;
    	strcpy(msg1.msgdata,otherbuf);
    	msgsnd(msgid,&msg1,sizeof(msg1),0);
    }
    
    void quit()
    { 	
    	sprintf(otherbuf,"%s","丁丁已下线！\n");
    	send(333);
    	send(444);
    	send(222);
    	exit(id);
    	exit(0);
    }
    
    int main()
    { 
    
    	msgid=msgget(5555,IPC_CREAT|IPC_EXCL|0777);			//申请创建消息队列
    	if(msgid==-1)
    	{ 
    		if(errno==EEXIST)
    		{ 
    			msgid=msgget(5555,0777);
    		}
    		else
    		{ 
    			perror("创建失败!\n");
    			return -1;
    		}
    	}
    	
    	
    	id = fork();	
    	if (id > 0)											//接收群成员发送过来的信息
    	{ 
    		while(1)
    		{ 	
    			bzero(&msg1,sizeof(msg1));
    			msgrcv(msgid,&msg1,sizeof(msg1),555,0);
    			printf("%s",msg1.msgdata);
    		}
    	}
    	
    	if (id == 0)										//发送信息给群所有成员
    	{ 
    		signal(SIGINT,quit);
    		int flag = 0;
    		while(1)
    		{ 
    
    			bzero(buf,50);
    			bzero(otherbuf,50);
    			
    			if(flag == 0)								//上线通知
    			{ 
    				sprintf(otherbuf,"%s","丁丁已上线！\n");
    				flag = 1;
    			}
    			
    			else										//输入消息内容
    			{ 
    				fgets (buf , 50 , stdin);				//可以输入带空格的字符串
    				sprintf(otherbuf,"丁丁: %s",buf);
    			}
    
    			send(333);
    			send(444);
    			send(222);
    		}
    	}
    }

[Link 1]: http://note.youdao.com/noteshare?id=1370b0e8f4a16b80e7dede7836df3c08
[2020080810535931.gif]: /images/20221124/675778e06baf460c9d8d9c4a604ebe1f.png
[20200808105405922.gif]: /images/20221124/61c243f7944242278c4af4986fca2bd4.png