聊天室-客户端

小咪咪 2024-02-19 14:02 28阅读 0赞

流程图：![Center][]

模块化划分：

共分为一下几个模块：

mian.cpp :

socket启动及链接，开启线程

logic.cpp

功能函数：对应了登陆与注册，私聊，群聊，文件传输，好友和群组管理函数

tools.cpp

工具函数：求文件大小，发送包，和一些判断函数

view.cpp

显示的界面函数：菜单显示函数，聊天界面函数，信息查看函数

client.h

结构体声明，函数声明，全局变量声明

下面是客户端的界面截图  
登陆界面：

![Center 1][]  
主界面：

![Center 2][]

好友查看界面：

![Center 3][]

聊天界面：

![Center 4][]

文件发送界面：

![Center 5][]

文件接收界面：

![Center 6][]

文件消息盒子界面：

![Center 7][]

聊天记录界面：

![Center 8][]

下面上代码（已加详细注释）：

\#include <mysql/mysql.h>  
\#include <gtk/gtk.h>  
\#include <stdio.h>  
\#include <pthread.h>  
\#include <sys/socket.h>  
\#include <sys/epoll.h>  
\#include <sys/types.h>  
\#include <sys/stat.h>  
\#include <fcntl.h>  
\#include <netinet/in.h>  
\#include <arpa/inet.h>  
\#include <stdlib.h>  
\#include <unistd.h>  
\#include <string.h>  
\#include <signal.h>  
\#include <time.h>  
\#include <termios.h>  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*same with server\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
\#define LOGIN 1  
\#define REGISTER 2  
\#define FRIEND\_SEE 3  
\#define FRIEND\_ADD 4  
\#define FRIEND\_DEL 5  
\#define GROUP\_SEE 6  
\#define GROUP\_CREATE 7  
\#define GROUP\_JOIN 8  
\#define GROUP\_QIUT 9  
\#define GROUP\_DEL 10  
\#define CHAT\_ONE 11  
\#define CHAT\_MANY 12  
\#define FILE\_SEND\_BEGIN 13  
\#define FILE\_SEND\_BEGIN\_RP 14  
\#define FILE\_SEND\_STOP\_RP 15  
\#define FILE\_RECV\_RE 16  
\#define FILE\_SEND 17  
\#define FILE\_RECV\_BEGIN 18  
\#define FILE\_RECV\_BEGIN\_RP 19  
\#define FILE\_RECV\_STOP\_RP 20  
\#define FILE\_RECV 21  
\#define FILE\_FINI\_RP 22  
\#define MES\_RECORD 23  
\#define EXIT -1  
  
  
\#define SIZE\_PASS\_NAME 10  
\#define MAX\_PACK\_CONTIAN 100  
\#define MAX\_CHAR 300  
\#define NUM\_MAX\_DIGIT 10  
  
\#define DOWNLINE 0  
\#define ONLINE 1  
\#define BUZY 2  
  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
typedef struct friend\_info  
\{  
int statu;  
int mes\_num;  
char name\[MAX\_CHAR\];  
\}FRIEND\_INFO;  
  
  
  
  
typedef struct user\_infor\{  
char username \[MAX\_CHAR\];  
FRIEND\_INFO friends \[MAX\_CHAR\];  
int friends\_num;  
char group \[MAX\_CHAR\]\[MAX\_CHAR\];  
int group\_num;  
\}USER\_INFOR;  
  
  
  
  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*be sure same with server\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
typedef struct datas\{  
char send\_name\[MAX\_CHAR\];  
char recv\_name\[MAX\_CHAR\];  
int send\_fd;  
int recv\_fd;  
//time\_t time;  
char mes\[MAX\_CHAR\*2\];  
\}DATA;  
  
typedef struct package\{  
int type;  
DATA data;  
\}PACK;  
  
typedef struct pthread\_parameter  
\{  
int a;  
int b;  
\}PTHREAD\_PAR;  
  
  
  
typedef struct prinit\_mes  
\{  
char name\[MAX\_CHAR\];  
char time\[MAX\_CHAR\];  
char mes \[MAX\_CHAR\];  
  
\}PRINT\_MES;  
  
typedef struct sockaddr SA;  
  
  
  
  
void init();  
void \*deal\_statu(void \*arg);  
void \*clien\_recv\_thread(void \*arg);  
void init\_clien\_pthread();  
int main\_menu();  
  
  
  
  
  
  
int send\_login(char username\_t\[\],char password\_t\[\]);  
int login();  
int send\_registe(char username\_t\[\],char password\_t\[\]);  
void registe();  
void get\_status\_mes();  
void change\_statu(PACK pack\_deal\_statu\_t);  
void add\_friend();  
void del\_friend();  
void group\_create();  
void group\_join();  
void group\_qiut();  
void group\_del();  
void send\_mes\_to\_one();  
void send\_mes\_to\_group();  
void send\_mes(char mes\_recv\_name\[\],int type);  
void \*show\_mes(void \*username);  
void print\_mes(int id);  
void send\_file();  
void \*pthread\_send\_file(void \*mes\_t);  
void send\_file\_send(int begin\_location,char \*file\_path);  
int file\_mes\_box();  
void deal\_file\_mes(int id);  
void mes\_sendfile\_fail(int id);  
void mes\_recv\_requir(int id);  
void mes\_recvfile\_fail(int id);  
void \*pthread\_recv\_file(void \*par\_t);  
int mes\_record();  
void print\_mes\_record(PACK\* pack\_t);  
  
  
  
int login\_menu();  
void show\_mes\_smart(char \*name ,char \*mes);  
void friends\_see();  
void group\_see();  
void print\_main\_menu();  
  
  
void my\_err(const char \* err\_string,int line);  
void sig\_close(int i);  
int get\_file\_size(char \*file\_name);  
void file\_infor\_delete(int id);  
int judge\_same\_group(char \*group\_name);  
int judge\_same\_friend(char add\_friend\_t\[\]);  
int get\_choice(char \*choice\_t);  
void send\_pack(int type,char \*send\_name,char \*recv\_name,char \*mes);  
void send\_pack\_memcpy(int type,char \*send\_name,char \*recv\_name,char \*mes);  
  
  
  
  
  
  
  
  
USER\_INFOR m\_my\_infor;  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*send\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
PACK m\_pack\_send \[MAX\_CHAR\];  
int m\_send\_num;  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*recv\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
PACK m\_pack\_recv\_friend\_see \[MAX\_PACK\_CONTIAN\];  
PACK m\_pack\_recv\_chat \[MAX\_PACK\_CONTIAN\];  
PACK m\_pack\_recv\_send\_file \[MAX\_PACK\_CONTIAN\];  
PACK m\_pack\_recv\_file\_mes \[MAX\_PACK\_CONTIAN\];  
PACK m\_pack\_recv\_file \[MAX\_PACK\_CONTIAN\];  
  
int m\_recv\_num\_friend\_see;  
int m\_recv\_num\_chat;  
int m\_recv\_num\_send\_file;  
int m\_recv\_num\_file\_mes;  
int m\_recv\_num\_file;  
int m\_print\_mes\_flag;  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
int m\_flag\_group\_create;  
int m\_flag\_group\_join ;  
int m\_flag\_group\_del ;  
int m\_flag\_print\_mes;  
int m\_flag\_print\_recorde;  
// int window\_col;  
// int window\_row;  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
PRINT\_MES m\_print\_mes\[10\];  
int m\_print\_mes\_num;  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*function\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
int sockfd;  
char \*IP = "115.159.205.168";  
short PORT = 11112;  
typedef struct sockaddr SA;  
pthread\_mutex\_t mutex\_local\_user;  
pthread\_mutex\_t mutex\_recv\_file;  
  
  
  
void init()  
\{  
printf("客户端开始启动\\n");  
sockfd = socket(AF\_INET,SOCK\_STREAM,0);//启动socket  
struct sockaddr\_in addr;  
addr.sin\_family = AF\_INET;  
addr.sin\_port = htons(PORT);  
addr.sin\_addr.s\_addr = inet\_addr(IP);  
if(connect(sockfd,(SA\*)&addr,sizeof(addr))==-1)\{  
perror("无法连接到服务器");  
printf("客户端启动失败\\n");  
exit(-1);  
\}  
printf("客户端启动成功\\n");  
\}  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*  
\* 根据发来数据包及时更新  
\* 好友状态  
\* \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
void \*deal\_statu(void \*arg)  
\{  
int i;  
while(1)  
\{  
pthread\_mutex\_lock(&mutex\_local\_user);  
for(i=1;i<=m\_recv\_num\_friend\_see;i++)  
\{  
//printf("flag1\\n");  
change\_statu(m\_pack\_recv\_friend\_see\[i\]);  
\}  
m\_recv\_num\_friend\_see = 0;  
pthread\_mutex\_unlock(&mutex\_local\_user);  
usleep(1);  
\}  
\}  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*  
\* 一直接收客户端发来的包  
\* 并把包存储到数组当中  
\* \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
void \*clien\_recv\_thread(void \*arg)  
\{  
int i;  
PACK pack\_t;  
pthread\_t pid\_send\_file;  
while(1)  
\{  
if(recv(sockfd,&pack\_t,sizeof(PACK),0) < 0)\{  
my\_err("recv",\_\_LINE\_\_);  
\}  
//for(int i=1;i <= )  
pthread\_mutex\_lock(&mutex\_local\_user);  
  
for(int i=1 ;i<= m\_my\_infor.friends\_num;i++)  
\{  
if(strcmp(m\_my\_infor.friends\[i\].name,pack\_t.data.send\_name) == 0)  
\{  
m\_my\_infor.friends\[i\].mes\_num++;  
break;  
\}  
\}  
  
switch(pack\_t.type)  
\{  
case FRIEND\_SEE:  
m\_pack\_recv\_friend\_see\[++m\_recv\_num\_friend\_see\] = pack\_t;  
break;  
case GROUP\_CREATE:  
m\_flag\_group\_create = pack\_t.data.mes\[0\];  
break;  
case GROUP\_JOIN:  
m\_flag\_group\_join = pack\_t.data.mes\[0\];  
break;  
case GROUP\_DEL:  
m\_flag\_group\_del = pack\_t.data.mes\[0\];  
case CHAT\_ONE:  
m\_pack\_recv\_chat\[++m\_recv\_num\_chat\] = pack\_t;  
break;  
case CHAT\_MANY:  
m\_pack\_recv\_chat\[++m\_recv\_num\_chat\] = pack\_t;  
break;  
//case SEND\_FILE:  
// m\_pack\_recv\_send\_file\[++m\_recv\_num\_send\_file\] = pack\_t;  
//break;  
case FILE\_SEND\_BEGIN\_RP:  
pthread\_create(&pid\_send\_file,NULL,pthread\_send\_file,(void \*)pack\_t.data.mes);  
break;  
case FILE\_SEND\_STOP\_RP:  
m\_pack\_recv\_file\_mes\[++m\_recv\_num\_file\_mes\] = pack\_t;  
break;  
case FILE\_RECV\_BEGIN:  
m\_pack\_recv\_file\_mes\[++m\_recv\_num\_file\_mes\] = pack\_t;  
break;  
case FILE\_RECV:  
pthread\_mutex\_lock(&mutex\_recv\_file);  
m\_pack\_recv\_file\[++m\_recv\_num\_file\] = pack\_t;  
  
pthread\_mutex\_unlock(&mutex\_recv\_file);  
  
break;  
case FILE\_RECV\_STOP\_RP:  
m\_pack\_recv\_file\_mes\[++m\_recv\_num\_file\_mes\] = pack\_t;  
break;  
case MES\_RECORD:  
PACK \*pack\_record = (PACK \*)malloc(sizeof(PACK));  
memcpy(pack\_record,&pack\_t,sizeof(PACK));  
print\_mes\_record(pack\_record);  
break;  
\}  
pthread\_mutex\_unlock(&mutex\_local\_user);  
usleep(1);  
\}  
\}  
  
  
//开启线程  
void init\_clien\_pthread()  
\{  
pthread\_t pid\_deal\_statu,pid\_recv,pid\_recv\_file;  
pthread\_create(&pid\_deal\_statu,NULL,deal\_statu,NULL);  
pthread\_create(&pid\_recv,NULL,clien\_recv\_thread,NULL);  
\}  
  
  
//主菜单  
int main\_menu()  
\{  
char choice\_t\[100\];  
int chioce;  
do  
\{  
get\_status\_mes();  
//printf("pack num\_chat:%d\\n", m\_recv\_num\_chat);  
print\_main\_menu();  
scanf("%s",choice\_t);  
chioce = get\_choice(choice\_t);  
switch(chioce)  
\{  
case 1:  
friends\_see();  
break;  
case 2:  
add\_friend();  
break;  
case 3:  
del\_friend();  
break;  
case 4:  
group\_see();  
break;  
case 5:  
group\_create();  
break;  
case 6:  
group\_join();  
break;  
case 7:  
group\_qiut();  
break;  
case 8:  
group\_del();  
break;  
case 9:  
send\_mes\_to\_one();  
break;  
case 10:  
send\_mes\_to\_group();  
break;  
case 11:  
send\_file();  
break;  
case 12:  
file\_mes\_box();  
break;  
case 13:  
mes\_record();  
default:  
break;  
\}  
\}while(chioce!=0);  
return 0;  
\}  
  
  
  
int main(int argc, char const \*argv\[\])  
\{  
int flag =0;  
// struct winsize size;  
  
signal(SIGINT,sig\_close);//关闭CTRL+C  
init();//启动并连接服务器  
  
// ioctl(STDIN\_FILENO,TIOCGWINSZ,&size); //get size of window  
// window\_col = size.ws\_col;  
// window\_row = size.ws\_row;  
  
if(login\_menu() == 0)//判断是否登陆成功  
return 0;  
init\_clien\_pthread();//开启线程  
main\_menu(); //主菜单  
return 0;  
\}  
logic.cpp

\#include "client.h"  
  
  
  
  
  
/\*  
\* 向服务端发送登陆信息  
\*/  
  
int send\_login(char username\_t\[\],char password\_t\[\])  
\{  
PACK recv\_login\_t;  
int login\_judge\_flag = 0;  
send\_pack(LOGIN,username\_t,"server",password\_t);  
  
if(recv(sockfd,&recv\_login\_t,sizeof(PACK),0) < 0)\{  
my\_err("recv",\_\_LINE\_\_);  
\}  
login\_judge\_flag = recv\_login\_t.data.mes\[0\] - 48;  
return login\_judge\_flag;  
\}  
  
/\*  
\* 根据输入信息向客户端发送登陆请求  
\* 并根据返回内容，提示用户  
\*/  
int login()  
\{  
int flag = 0;  
  
int login\_flag = 0;  
char username\_t \[MAX\_CHAR\];  
char password\_t \[MAX\_CHAR\];  
printf("please input the username:\\n");  
scanf("%s",username\_t);  
printf("please input the password\\n");  
scanf("%s",password\_t);  
  
login\_flag = send\_login(username\_t,password\_t);  
if(login\_flag == 2)\{  
printf("\\033\[;31mthe username is not exit.\\033\[0m\\n");  
return 0;  
\}  
if(login\_flag == 3 )\{  
printf("\\033\[;31mthe user has loged in .\\033\[0m\\n");  
return 0;  
\}  
if(login\_flag == 0) \{  
printf("\\033\[;31mthe password is not crrect.\\033\[0m\\n");  
return 0;  
\}  
strcpy(m\_my\_infor.username,username\_t);  
printf("\\033\[;32mload successfully!\\033\[0m\\n");  
return 1;  
\}  
  
  
  
  
  
  
  
  
/\*  
\* 向服务端发送注册信息  
\*/  
int send\_registe(char username\_t\[\],char password\_t\[\])  
\{  
PACK recv\_registe\_t;  
int send\_registe\_flag;  
  
send\_pack(REGISTER,username\_t,"server",password\_t);  
  
if(recv(sockfd,&recv\_registe\_t,sizeof(PACK),0) < 0)\{  
my\_err("recv",\_\_LINE\_\_);  
\}  
send\_registe\_flag = recv\_registe\_t.data.mes\[0\] - 48;  
return send\_registe\_flag;  
\}  
  
/\*  
\* 根据输入信息向客户端发送注册请求  
\* 并根据返回内容，提示用户  
\*/  
void registe()  
\{  
int flag = 0;  
flag = REGISTER;  
char username\_t\[MAX\_CHAR\];  
char password\_t\[MAX\_CHAR\];  
  
  
  
printf("please input the username you want register:\\n");  
scanf("%s",username\_t);  
printf("please input the password you want register:\\n");  
scanf("%s",password\_t);  
if(send\_registe(username\_t,password\_t))  
printf("\\033\[;32mregiste successfully!\\033\[0m\\n");  
else  
printf("\\033\[;31mthe name is used ,please input another one\\033\[0m\\n");  
\}  
  
  
  
/\*  
\* 向服务端请求更新好友状态  
\*/  
void get\_status\_mes()  
\{  
PACK pack\_friend\_see;  
pack\_friend\_see.type = FRIEND\_SEE;  
strcpy(pack\_friend\_see.data.send\_name,m\_my\_infor.username);  
strcpy(pack\_friend\_see.data.recv\_name,"server");  
memset(pack\_friend\_see.data.mes,0,sizeof(pack\_friend\_see.data.mes));  
if(send(sockfd,&pack\_friend\_see,sizeof(PACK),0) < 0)\{  
my\_err("send",\_\_LINE\_\_);  
\}  
\}  
  
//根据服务端发送来的包，利用字符串解析，更新当前好友状态  
void change\_statu(PACK pack\_deal\_statu\_t)  
\{  
int count = 0;  
m\_my\_infor.friends\_num=pack\_deal\_statu\_t.data.mes\[count++\];  
//更新好友信息  
for(int i=1; i <= m\_my\_infor.friends\_num ;i++)  
\{  
for(int j=0;j<SIZE\_PASS\_NAME;j++)  
\{  
if(j == 0)  
m\_my\_infor.friends\[i\].statu = pack\_deal\_statu\_t.data.mes\[count+j\] - 48;  
else  
m\_my\_infor.friends\[i\].name\[j-1\] = pack\_deal\_statu\_t.data.mes\[count+j\];  
\}  
count += SIZE\_PASS\_NAME;  
\}  
//更新群组信息  
m\_my\_infor.group\_num=pack\_deal\_statu\_t.data.mes\[count++\];  
for(int i=1 ;i <= m\_my\_infor.group\_num ;i++)  
\{  
for(int j=0;j<SIZE\_PASS\_NAME;j++)  
\{  
m\_my\_infor.group\[i\]\[j\] = pack\_deal\_statu\_t.data.mes\[count+j\];  
\}  
count += SIZE\_PASS\_NAME;  
\}  
\}  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
  
  
  
  
//添加好友  
void add\_friend()  
\{  
char add\_friend\_t\[MAX\_CHAR\];  
  
printf("please input the name of friend you want to add:\\n");  
scanf("%s",add\_friend\_t);  
if(strcmp(add\_friend\_t,m\_my\_infor.username) == 0)  
\{  
printf("you can't add youself to be your friend!\\n");  
return;  
\}  
//判断是否已经添加过该好友  
if(judge\_same\_friend(add\_friend\_t))  
\{  
printf("you already have same friends!\\n");  
return ;  
\}  
printf("m\_my\_infor.username:%s\\n", m\_my\_infor.username);  
send\_pack(FRIEND\_ADD,m\_my\_infor.username,"server",add\_friend\_t);  
get\_status\_mes();  
\}  
  
  
  
//删除好友  
void del\_friend()  
\{  
char del\_friend\_t\[MAX\_CHAR\];  
printf("please input the name of friend you want to delete:\\n");  
scanf("%s",del\_friend\_t);  
//判断是否添加过该好友  
if(!judge\_same\_friend(del\_friend\_t))  
\{  
printf("you don't have this friends on list!\\n");  
return ;  
\}  
printf("m\_my\_infor.username:%s\\n", m\_my\_infor.username);  
//发送包  
send\_pack(FRIEND\_DEL,m\_my\_infor.username,"server",del\_friend\_t);  
//得到状态信息  
get\_status\_mes();  
\}  
  
  
  
  
  
  
  
  
//创建群组  
void group\_create()  
\{  
char group\_name\[MAX\_CHAR\];  
printf("please input the group name you want to create:\\n");  
scanf("%s",group\_name);  
send\_pack(GROUP\_CREATE,m\_my\_infor.username,"server",group\_name);  
while(!m\_flag\_group\_create);  
printf("m\_flag\_group\_create=%d\\n", m\_flag\_group\_create);  
if(m\_flag\_group\_create == 2)  
printf("create group successfully!\\n");  
else if(m\_flag\_group\_create == 1)  
printf("this group has been created!\\n");  
m\_flag\_group\_create = 0;  
\}  
  
  
//加入群组  
void group\_join()  
\{  
  
char group\_name\[MAX\_CHAR\];  
printf("please input the group name you want to join:\\n");  
scanf("%s",group\_name);  
//判断是否已经加入该群  
for(int i=1;i <= m\_my\_infor.group\_num ;i++)  
\{  
if(strcmp(m\_my\_infor.group\[i\],group\_name) == 0)  
\{  
printf("you have join this group!\\n");  
return ;  
\}  
\}  
  
send\_pack(GROUP\_JOIN,m\_my\_infor.username,"server",group\_name);  
while(!m\_flag\_group\_join);  
if(m\_flag\_group\_join == 2)  
printf("join group successfully!\\n");  
else if(m\_flag\_group\_join == 1)  
printf("there is no group named %s\\n",group\_name);  
m\_flag\_group\_join = 0;  
\}  
  
//退出群组  
void group\_qiut()  
\{  
char group\_name\[MAX\_CHAR\];  
printf("please input the group name you want to qiut:\\n");  
scanf("%s",group\_name);  
//判断是否添加过该群组  
for(int i=1;i <= m\_my\_infor.group\_num ;i++)  
\{  
if(strcmp(m\_my\_infor.group\[i\],group\_name) == 0)  
\{  
send\_pack(GROUP\_QIUT,m\_my\_infor.username,"server",group\_name);  
printf("quit group %s successfully!\\n",group\_name);  
return ;  
\}  
\}  
  
printf("you did't join this group!\\n");  
\}  
  
//解散群  
void group\_del()  
\{  
char group\_name\[MAX\_CHAR\];  
printf("please input the group name you want to delete:\\n");  
scanf("%s",group\_name);  
for(int i=1;i <= m\_my\_infor.group\_num ;i++)  
\{  
if(strcmp(m\_my\_infor.group\[i\],group\_name) == 0)  
\{  
send\_pack(GROUP\_DEL,m\_my\_infor.username,"server",group\_name);  
while(!m\_flag\_group\_del);  
printf("m\_flag\_group\_del=%d\\n", m\_flag\_group\_del);  
if(m\_flag\_group\_del == 2)  
printf("delete group successfully!\\n");  
else if(m\_flag\_group\_del == 1)  
printf("you isn't the owner of group %s\\n",group\_name);  
return ;  
\}  
\}  
  
printf("you did't join this group!\\n");  
\}  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
//私聊  
void send\_mes\_to\_one()  
\{  
pthread\_t pid;  
int id;  
char mes\_recv\_name\[MAX\_CHAR\];  
friends\_see();//print friend list !  
  
printf("please input the name you want to chat\\n");  
scanf("%s",mes\_recv\_name);  
if (!(id=judge\_same\_friend(mes\_recv\_name)))  
\{  
printf("sorry,you don't have the friend named !%s\\n",mes\_recv\_name);  
return ;  
\}  
printf("\\33\[2J \\33\[1;1H\\033\[;33m\\33\[1m-^-^-^-^-^-^-^-^-^-^-message-^-^-^-^-^-^-^-^-^-^-\\033\[0m");  
printf("\\33\[26B\\n");  
m\_flag\_print\_mes = 1;  
m\_my\_infor.friends\[id\].mes\_num = 0;  
//开启线程显示信息  
pthread\_create(&pid,NULL,show\_mes,(void \*)mes\_recv\_name);  
send\_mes(mes\_recv\_name,CHAT\_ONE);  
\}  
  
//群聊  
void send\_mes\_to\_group()  
\{  
pthread\_t pid;  
char mes\_recv\_group\_name\[MAX\_CHAR\];  
group\_see();  
printf("please input the group you want to chat\\n");  
scanf("%s",mes\_recv\_group\_name);  
if (!judge\_same\_group(mes\_recv\_group\_name))  
\{  
printf("sorry,you don't have the group named !%s\\n",mes\_recv\_group\_name);  
return ;  
\}  
  
m\_flag\_print\_mes = 1;  
printf("\\33\[2J \\33\[1;1H\\033\[;33m\\33\[1m-^-^-^-^-^-^-^-^-^-^-message-^-^-^-^-^-^-^-^-^-^-\\033\[0m");  
printf("\\33\[26B\\n");  
//开启线程显示信息  
pthread\_create(&pid,NULL,show\_mes,(void \*)mes\_recv\_group\_name);  
send\_mes(mes\_recv\_group\_name,CHAT\_MANY);  
\}  
  
  
//接收用户输入并发送信息到客户端  
void send\_mes(char mes\_recv\_name\[\],int type)  
\{  
PACK pack\_send\_mes;  
char mes\[MAX\_CHAR\];  
time\_t timep;  
getchar();  
printf("\\033\[;34m\\33\[1m-^-^-^-^-^-^-^-^-^-^-please input-^-^-^-^-^-^-^-^-^-^-\\033\[0m\\n");  
while(1)  
\{  
time(&timep);  
memset(mes,0,sizeof(mes));  
printf("\\33\[s");  
fflush(stdout);  
//if(type == CHAT\_ONE)  
// printf("%s->",m\_my\_infor.username);  
fgets(mes,MAX\_CHAR,stdin);  
while(mes\[0\] == 10)  
\{  
printf("\\33\[1A");  
fflush(stdout);  
fgets(mes,MAX\_CHAR,stdin);  
\}  
  
//当用户输入quit时退出  
if(strcmp(mes,"quit\\n") == 0)  
break;  
printf("\\33\[u");  
fflush(stdout);  
printf("\\33\[s");  
fflush(stdout);  
printf("\\33\[K\\n\\33\[K\\n\\33\[K\\n");  
fflush(stdout);  
printf("\\33\[u");  
fflush(stdout);  
  
//输入的的同时，输出信息  
show\_mes\_smart(m\_my\_infor.username ,mes);  
  
//printf("\\t%s\\n%s\\n", m\_my\_infor.username,ctime(&timep),mes);  
//发送给客户端  
send\_pack(type,m\_my\_infor.username,mes\_recv\_name,mes);  
\}  
m\_flag\_print\_mes = EXIT;  
\}  
  
/\*  
\* 在聊天的同时启动,启动线程读取，存储区域的  
\* 消息，并显示出来  
\*/  
void \*show\_mes(void \*username)  
\{  
int id;  
char \*user\_name = (char \*)username;  
while(1)  
\{  
//如果退出聊天，就不再显示  
if (m\_flag\_print\_mes == EXIT)  
break;  
pthread\_mutex\_lock(&mutex\_local\_user);  
id = 0;  
  
//检索信息  
for(int i = 1 ;i <= m\_recv\_num\_chat; i++)  
\{  
if(strcmp(m\_pack\_recv\_chat\[i\].data.send\_name,user\_name) == 0)  
\{  
id = i;  
  
//输出信息  
print\_mes(id);  
m\_recv\_num\_chat--;  
for(int j = id; j <= m\_recv\_num\_chat&&m\_recv\_num\_chat ;j++)  
\{  
m\_pack\_recv\_chat\[j\] = m\_pack\_recv\_chat\[j+1\];  
\}  
break;  
\}  
\}  
  
pthread\_mutex\_unlock(&mutex\_local\_user);  
usleep(1);  
\}  
\}  
  
//根据寻找到的包把信息输出  
void print\_mes(int id)  
\{  
char group\_print\_name\[MAX\_CHAR\];  
memset(group\_print\_name,0,sizeof(group\_print\_name));  
if(m\_pack\_recv\_chat\[id\].type == CHAT\_ONE)  
\{  
show\_mes\_smart(m\_pack\_recv\_chat\[id\].data.send\_name,m\_pack\_recv\_chat\[id\].data.mes);  
\}  
else  
\{  
for(int i=0;i<SIZE\_PASS\_NAME;i++)  
\{  
group\_print\_name\[i\] = m\_pack\_recv\_chat\[id\].data.mes\[i\];  
\}  
show\_mes\_smart( group\_print\_name,m\_pack\_recv\_chat\[id\].data.mes+SIZE\_PASS\_NAME);  
\}  
\}  
  
  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
  
  
  
  
  
  
/\*  
\* 向服务端请求发送文件，并将文件的大小  
\* 发送给服务端  
\*/  
  
void send\_file()  
\{  
char recv\_name\[MAX\_CHAR\];  
char file\_path\[MAX\_CHAR\];  
int file\_size\_t;  
char mes\_t\[MAX\_CHAR\];  
friends\_see();  
printf("please input the friend name:\\n");  
scanf("%s",recv\_name);  
  
int id = judge\_same\_friend(recv\_name);  
if(id == 0)  
\{  
printf("you don't hava this friend!\\n");  
return ;  
\}  
printf("please input the path of file you want to send :\\n");  
scanf("%s",file\_path);  
  
//得到文件的大小  
file\_size\_t = get\_file\_size(file\_path);  
printf("file\_size :%d\\n", file\_size\_t);  
  
if(file\_size\_t == 0)  
\{  
printf("please input creact file path\\n");  
return ;  
\}  
//字符串分析  
int digit = 0;  
while(file\_size\_t != 0)  
\{  
mes\_t\[digit++\] = file\_size\_t%10;  
file\_size\_t /= 10;  
\}  
mes\_t\[digit\] = -1;  
  
for(int i=0 ;i< SIZE\_PASS\_NAME ;i++)  
\{  
mes\_t\[NUM\_MAX\_DIGIT+i\] = file\_path\[i\];  
\}  
//发送请求  
send\_pack\_memcpy(FILE\_SEND\_BEGIN,m\_my\_infor.username,recv\_name,mes\_t);  
\}  
  
  
  
//当接收到允许发送的消息时，开启线程发送文件  
void \*pthread\_send\_file(void \*mes\_t)  
\{  
char \*mes = (char \*)mes\_t;  
int begin\_location = 0;  
char file\_name\[MAX\_CHAR\];  
printf("\\033\[;31m \\nfunction:pthread\_send\_file\\033\[0m \\n");  
//解析到服务端已接收文件大小  
for(int i=0 ;i<NUM\_MAX\_DIGIT ;i++)  
\{  
if(mes\[i\] == -1)  
break;  
int t1 = 1;  
for(int l=0;l<i;l++)  
t1\*=10;  
begin\_location += (int)mes\[i\]\*t1;  
  
\}  
strcpy(file\_name,mes+NUM\_MAX\_DIGIT);  
send\_file\_send(begin\_location,file\_name);  
\}  
  
  
//从起始位置向服务端发送文件  
void send\_file\_send(int begin\_location,char \*file\_path)  
\{  
int fd;  
int length;  
int file\_size;  
int sum = begin\_location;  
char mes\[MAX\_CHAR\*2\];  
printf("\\33\[2J\\33\[1;1H\\n");  
printf("\\033\[;34m\\33\[1m^-^-^-^-^-^-^-^-^-^happychat^-^-^-^-^-^-^-^-^-^\\033\[0m\\n");  
printf("\\n\\nsending the file.........\\n");  
  
//打开文件  
if((fd = open(file\_path,O\_RDONLY)) == -1)  
\{  
my\_err("open",\_\_LINE\_\_);  
return ;  
\}  
file\_size=lseek(fd, 0, SEEK\_END);  
  
printf("file\_size=%d",file\_size);  
//文件内部指针移动  
lseek(fd ,begin\_location ,SEEK\_SET);  
  
bzero(mes, MAX\_CHAR\*2);  
  
// 每读取一段数据，便将其发送给客户端，循环直到文件读完为止  
while((length = read(fd ,mes+NUM\_MAX\_DIGIT ,MAX\_CHAR\*2 - NUM\_MAX\_DIGIT)) > 0)  
\{  
sum += length;  
// printf("length = %d\\n", length);  
int digit = 0;  
while(length != 0)  
\{  
mes\[digit++\] = length%10;  
length /= 10;  
\}  
mes\[digit\] = -1;  
int color;  
int jindu=(int)((double)sum/file\_size\*100);  
printf("have sended :");  
for(int i = 0 ;i<jindu/10;i++)  
\{  
color = i%6;  
printf("\\033\[;%dm\\33\[1m=\\033\[0m",color+32);  
fflush(stdout);  
\}  
printf("\\033\[;31m\\33\[1m>\\033\[0m");  
fflush(stdout);  
for(int j = 0;j<10-jindu/10;j++)  
\{  
printf(" ");  
fflush(stdout);  
\}  
printf("\\033\[;31m\\33\[1m|\\033\[0m %d%% %d \\n",jindu,sum);  
  
send\_pack\_memcpy(FILE\_SEND,m\_my\_infor.username,file\_path,mes);  
  
if(sum == file\_size)  
break;  
bzero(mes, MAX\_CHAR\*2);  
usleep(100000);  
printf("\\33\[1A\\33\[K");  
fflush(stdout);  
\}  
// 关闭文件  
close(fd);  
printf("send finished!!\\n");  
print\_main\_menu();  
\}  
  
  
  
  
  
  
  
  
  
/\*  
\* 显示文件处理消息，并根据提供选择  
\*/  
  
int file\_mes\_box()  
\{  
char choice\_t\[100\];  
int chioce;  
do  
\{  
get\_status\_mes();  
printf("\\033\[;34m\\33\[1m^-^-^-^-^-^-^-^-^-^file mes box^-^-^-^-^-^-^-^-^-^\\033\[0m\\n");  
for(int i = 1; i <= m\_recv\_num\_file\_mes;i++)  
\{  
if(m\_pack\_recv\_file\_mes\[i\].type == FILE\_SEND\_STOP\_RP)  
printf("\\t\\033\[;34m\\33\[1m\*\\033\[0m \\033\[;31m\\33\[1msend file %s filed\\033\[0m \\n",m\_pack\_recv\_file\_mes\[i\].data.send\_name);  
if(m\_pack\_recv\_file\_mes\[i\].type == FILE\_RECV\_BEGIN)  
printf("\\t\\033\[;34m\\33\[1m\*\\033\[0m \\033\[;33m\\33\[1m%s send file %s to you\\033\[0m \\n", m\_pack\_recv\_file\_mes\[i\].data.send\_name,m\_pack\_recv\_file\_mes\[i\].data.mes+SIZE\_PASS\_NAME);  
if(m\_pack\_recv\_file\_mes\[i\].type == FILE\_RECV\_STOP\_RP)  
printf("\\t\\033\[;34m\\33\[1m\*\\033\[0m \\033\[;31m\\33\[1mrecv file %s filed\\033\[0m \\n", m\_pack\_recv\_file\_mes\[i\].data.mes+NUM\_MAX\_DIGIT);  
\}  
printf("\\t\\033\[;34m\\33\[1m\*\\033\[0m 0.exit \\n");  
printf("\\033\[;34m\\33\[1m^-^-^-^-^-^-^-^-^-^end^-^-^-^-^-^-^-^-^-^-^-^-^-^-\\033\[0m\\n");  
printf("\\t\\tchoice：");  
scanf("%s",choice\_t);  
chioce = get\_choice(choice\_t);  
//进行处理  
if(chioce != -1)  
deal\_file\_mes(chioce);  
  
\}while(chioce!=0);  
return 0;  
\}  
  
  
  
  
//对文件信息进行分类处理  
void deal\_file\_mes(int id)  
\{  
if(m\_pack\_recv\_file\_mes\[id\].type == FILE\_SEND\_STOP\_RP)  
\{  
mes\_sendfile\_fail(id);  
\}  
else if(m\_pack\_recv\_file\_mes\[id\].type == FILE\_RECV\_BEGIN)  
\{  
mes\_recv\_requir(id);  
\}else if(m\_pack\_recv\_file\_mes\[id\].type == FILE\_RECV\_STOP\_RP)  
\{  
mes\_recvfile\_fail(id);  
\}  
\}  
  
  
//处理文件上传失败，并询问是否重发  
//进行断点续传  
void mes\_sendfile\_fail(int id)  
\{  
char chioce\[10\];  
//解析已经上传的字节数  
int begin\_location = 0;  
for(int i=0 ;i<NUM\_MAX\_DIGIT ;i++)  
\{  
if( m\_pack\_recv\_file\_mes\[id\].data.mes\[i\] == -1)  
break;  
printf("%d\\n\\n",m\_pack\_recv\_file\_mes\[id\].data.mes\[i\]);  
int t1 = 1;  
for(int l=0;l<i;l++)  
t1\*=10;  
begin\_location += (int)m\_pack\_recv\_file\_mes\[id\].data.mes\[i\] \* t1;  
  
\}  
  
  
//询问是否重传  
int file\_size\_t = get\_file\_size(m\_pack\_recv\_file\_mes\[id\].data.send\_name);  
printf("\\033\[;31m\\33\[1mthe file %s send failed ,have sended \\033\[;32m%d%%\\033\[;31m,do you want send again?\\033\[0m\\n", m\_pack\_recv\_file\_mes\[id\].data.send\_name,(int)((double)begin\_location/file\_size\_t\*100));  
printf("y/n :");  
scanf("%s",chioce);  
  
  
if(chioce\[0\] != 'Y' && chioce\[0\] != 'y')  
\{  
file\_infor\_delete(id);  
return ;  
\}  
  
//进行重传  
send\_file\_send(begin\_location,m\_pack\_recv\_file\_mes\[id\].data.send\_name);  
file\_infor\_delete(id);  
\}  
  
//处理下载文件请求，询问是否接收文件  
void mes\_recv\_requir(int id)  
\{  
pthread\_t pid\_recv\_file;  
char choice\[10\];  
int len ;  
int fd;  
char mes\_t\[MAX\_CHAR\];  
int file\_size = 0;  
char file\_name\[SIZE\_PASS\_NAME\];  
  
PTHREAD\_PAR \* par\_t = (PTHREAD\_PAR \*)malloc(sizeof(PTHREAD\_PAR));  
//解析文件大小  
for(int i=0 ;i<NUM\_MAX\_DIGIT ;i++)  
\{  
if(m\_pack\_recv\_file\_mes\[id\].data.mes\[i\] == -1)  
break;  
int t1 = 1;  
for(int l=0;l<i;l++)  
t1\*=10;  
file\_size += (int)m\_pack\_recv\_file\_mes\[id\].data.mes\[i\]\*t1;  
  
\}  
// for(int i=0 ;i<=50;i++)  
// printf("%d\\n", m\_pack\_recv\_file\_mes\[id\].data.mes\[i\]);  
// printf("%s\\n", m\_pack\_recv\_file\_mes\[id\].data.mes+NUM\_MAX\_DIGIT);  
strcpy(file\_name,m\_pack\_recv\_file\_mes\[id\].data.mes+NUM\_MAX\_DIGIT);  
  
  
printf("\\033\[;33m\\33\[1m %s send file %s size(%db)to you \\033\[0m\\n", m\_pack\_recv\_file\_mes\[id\].data.send\_name,file\_name,file\_size);  
printf(" do you want receive it? \\n");  
printf("(y/n) :");  
scanf("%s", choice);  
if(choice\[0\] != 'Y' && choice\[0\] != 'y')  
\{  
file\_infor\_delete(id);  
return ;  
\}  
  
  
//建立文件  
if((fd = open(file\_name,O\_WRONLY | O\_CREAT , S\_IRUSR | S\_IWUSR)) < 0)  
\{  
my\_err("open",\_\_LINE\_\_);  
return ;  
\}  
len = lseek(fd, 0, SEEK\_END);  
close(fd);  
  
par\_t->a = file\_size;  
par\_t->b = len;  
  
int digit = 0;  
while(len != 0)  
\{  
mes\_t\[digit++\] = len%10;  
len /= 10;  
\}  
mes\_t\[digit\] = -1;  
//发送同意同意  
send\_pack\_memcpy(FILE\_SEND\_BEGIN\_RP ,m\_my\_infor.username ,file\_name ,mes\_t);  
//开启线程接收文件  
pthread\_create(&pid\_recv\_file,NULL,pthread\_recv\_file,(void \*)par\_t);  
  
file\_infor\_delete(id);  
\}  
  
//处理接收文件中断信息，  
//并询问是否继续接收  
void mes\_recvfile\_fail(int id)  
\{  
pthread\_t pid\_recv\_file;  
char chioce\[10\];  
int begin\_location\_server;  
int file\_size;  
char file\_name\[SIZE\_PASS\_NAME\];  
char mes\_t\[MAX\_CHAR\];  
PTHREAD\_PAR \* par\_t = (PTHREAD\_PAR \*)malloc(sizeof(PTHREAD\_PAR));  
//解析已经接收的字节数  
for(int i=0 ;i<NUM\_MAX\_DIGIT ;i++)  
\{  
if(m\_pack\_recv\_file\_mes\[id\].data.mes\[i\] == -1)  
break;  
int t1 = 1;  
for(int l=0;l<i;l++)  
t1\*=10;  
file\_size += (int)m\_pack\_recv\_file\_mes\[id\].data.mes\[i\]\*t1;  
  
\}  
  
strcpy(file\_name,m\_pack\_recv\_file\_mes\[id\].data.mes+NUM\_MAX\_DIGIT);  
  
begin\_location\_server= get\_file\_size(file\_name);  
  
  
par\_t->a = file\_size;  
par\_t->b = begin\_location\_server;  
printf("\\033\[;31m\\33\[1mthe file %s recv failed ,have recved \\033\[;32m%d%%\\033\[;31m,do you want recv continue?\\033\[0m\\n", file\_name,(int)((double)begin\_location\_server/file\_size\*100));  
printf("y/n :");  
scanf("%s",chioce);  
  
  
  
if(chioce\[0\] != 'Y' && chioce\[0\] != 'y')  
\{  
file\_infor\_delete(id);  
return ;  
\}  
  
  
int len = begin\_location\_server;  
int digit = 0;  
while(len != 0)  
\{  
mes\_t\[digit++\] = len%10;  
len /= 10;  
\}  
mes\_t\[digit\] = -1;  
  
//返回同意信息  
send\_pack\_memcpy(FILE\_SEND\_BEGIN\_RP ,m\_my\_infor.username ,file\_name ,mes\_t);  
//开启线程接收文件  
pthread\_create(&pid\_recv\_file,NULL,pthread\_recv\_file,(void \*)par\_t);  
  
file\_infor\_delete(id);  
\}  
  
//接收文件线程，  
//从存储接收包的地方检索到信息  
//并写入文件  
//当文件写入完成，关闭线程  
void \*pthread\_recv\_file(void \*par\_t)  
\{  
PTHREAD\_PAR \* pthread\_par = (PTHREAD\_PAR \* )par\_t;  
int file\_size = pthread\_par->a ;  
int begin\_location\_server = pthread\_par->b;  
int sum = begin\_location\_server;  
while(1)  
\{  
pthread\_mutex\_lock(&mutex\_recv\_file);  
int fd;  
char file\_name\[MAX\_CHAR\];  
for(int i=1;i<=m\_recv\_num\_file ;i++)  
\{  
  
int len = 0;  
for(int j=0 ;j<NUM\_MAX\_DIGIT ;j++)  
\{  
if(m\_pack\_recv\_file\[i\].data.mes\[j\] == -1)  
break;  
int t1 = 1;  
for(int l=0;l<j;l++)  
t1\*=10;  
len += (int)m\_pack\_recv\_file\[i\].data.mes\[j\]\*t1;  
  
\}  
  
strcpy(file\_name,m\_pack\_recv\_file\[i\].data.send\_name);  
//you can creat this file when you get the file\_send\_begin  
if((fd = open(file\_name,O\_WRONLY | O\_CREAT | O\_APPEND, S\_IRUSR | S\_IWUSR)) < 0)  
\{  
my\_err("open",\_\_LINE\_\_);  
return NULL;  
\}  
  
if(write(fd,m\_pack\_recv\_file\[i\].data.mes + NUM\_MAX\_DIGIT,len) < 0)  
my\_err("write",\_\_LINE\_\_);  
// 关闭文件  
close(fd);  
sum += len;  
int color;  
int jindu=(int)((double)sum/file\_size\*100);  
printf("have recved :");  
for(int i = 0 ;i<jindu/10;i++)  
\{  
color = i%6;  
printf("\\033\[;%dm\\33\[1m=\\033\[0m",color+32);  
fflush(stdout);  
\}  
printf("\\033\[;31m\\33\[1m>\\033\[0m");  
fflush(stdout);  
for(int j = 0;j<10-jindu/10;j++)  
\{  
printf(" ");  
fflush(stdout);  
\}  
printf("\\033\[;31m\\33\[1m|\\033\[0m %d%% %d \\n",jindu,sum);  
  
m\_recv\_num\_file = 0;  
//文件接收完成，输出提示信息，跳出线程  
if(sum >= file\_size)  
\{  
send\_pack(FILE\_FINI\_RP,m\_my\_infor.username,"server",file\_name);  
printf("send finished!!\\n");  
print\_main\_menu();  
return NULL;  
\}  
\}  
  
pthread\_mutex\_unlock(&mutex\_recv\_file);  
usleep(10);  
\}  
\}  
  
  
  
  
  
  
  
//显示历史信息  
//向服务端发送请求消息  
int mes\_record()  
\{  
char username\[MAX\_CHAR\];  
printf("please input the username that you want see:\\n");  
scanf("%s",username);  
printf("the recording :\\n");  
send\_pack(MES\_RECORD,m\_my\_infor.username,"server",username);  
printf("\\33\[2J\\33\[20A\\033\[;33m\\33\[1m^-^-^-^-^-^-^-^-^message recordes^-^-^-^-^-^-^-^\\033\[0m\\n");  
while(!m\_flag\_print\_recorde) ;  
printf("printf recordes finished!!\\n");  
m\_flag\_print\_recorde = 0;  
return 0;  
\}  
  
  
  
//输出历史消息  
void print\_mes\_record(PACK\* pack\_t)  
\{  
if(strcmp(pack\_t->data.send\_name , "server") == 0)  
\{  
if(strcmp(pack\_t->data.mes,m\_my\_infor.username) == 0)  
\{  
printf("\\033\[;34m\\33\[1m%s\\033\[0m\\t\\033\[;34m\\033\[0m\\n",pack\_t->data.mes);  
printf("%s\\n", pack\_t->data.mes+SIZE\_PASS\_NAME);  
\}  
else  
\{  
printf("\\033\[;33m\\33\[1m%s\\033\[0m\\t\\033\[;33m\\033\[0m\\n",pack\_t->data.mes);  
printf("%s\\n", pack\_t->data.mes+SIZE\_PASS\_NAME);  
\}  
  
\}  
else  
m\_flag\_print\_recorde = 1;  
free(pack\_t);  
\}  
  
/\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
  
  
  
  
/\*void print\_file\_mes()  
\{  
for(int i=1 ;i<=5;i++)  
\{  
printf("hahahahahaha\*\*\*\*\*\\n");  
printf("%s\\n", m\_pack\_recv\_file\_mes\[i\].data.send\_name);  
printf("%s",m\_pack\_recv\_file\_mes\[i\].data.recv\_name);  
for(int j=0;j<=5;j++)  
printf("%d\\n\\n",m\_pack\_recv\_file\_mes\[i\].data.mes\[j\]);  
\}  
\}\*/  
tools.cpp

\#include "client.h"  
  
  
  
  
  
void my\_err(const char \* err\_string,int line)  
\{  
fprintf(stderr, "line:%d ", line);  
perror(err\_string);  
exit(1);  
\}  
  
void sig\_close(int i)  
\{  
//关闭客户端的描述符  
close(sockfd);  
exit(0);  
\}  
  
/\*you need creat the file before!\*/  
//得到文件大小  
int get\_file\_size(char \*file\_name)  
\{  
int fd;  
int len;  
if((fd = open(file\_name,O\_RDONLY)) == -1)  
\{  
my\_err("open",\_\_LINE\_\_);  
return 0;  
\}  
len = lseek(fd, 0, SEEK\_END);  
close(fd);  
return len;  
\}  
  
//从文件数组中删除文件信息  
void file\_infor\_delete(int id)  
\{  
pthread\_mutex\_lock(&mutex\_local\_user);  
for(int j = id ;j <=m\_recv\_num\_file\_mes ;j++)  
\{  
m\_pack\_recv\_file\_mes\[j\] = m\_pack\_recv\_file\_mes\[j+1\];  
\}  
m\_recv\_num\_file\_mes--;  
pthread\_mutex\_unlock(&mutex\_local\_user);  
\}  
  
  
  
//判断是否有重复的组  
int judge\_same\_group(char \*group\_name)  
\{  
int i;  
for(i=1;i<=m\_my\_infor.group\_num;i++)  
\{  
if(strcmp(m\_my\_infor.group\[i\],group\_name) == 0)  
return 1;  
\}  
return 0;  
\}  
  
  
  
//判断是否有重复的好友  
int judge\_same\_friend(char add\_friend\_t\[\])  
\{  
int i;  
for(i=1;i<=m\_my\_infor.friends\_num;i++)  
\{  
if(strcmp(m\_my\_infor.friends\[i\].name,add\_friend\_t) == 0)  
return i;  
\}  
return 0;  
\}  
  
//为避免输入时出现的意外错误，进行字符串解析  
int get\_choice(char \*choice\_t)  
\{  
int choice =0;  
for(int i=0;i<strlen(choice\_t) ;i++)  
if(choice\_t\[i\]<'0' || choice\_t\[i\]>'9')  
return -1;  
for(int i=0;i<strlen(choice\_t);i++)  
\{  
int t=1;  
for(int j=1;j<strlen(choice\_t)-i;j++)  
\{  
t \*=10;  
\}  
choice += t\*(int)(choice\_t\[i\] - 48);  
\}  
return choice;  
\}  
  
//根据参数信息发送包  
void send\_pack(int type,char \*send\_name,char \*recv\_name,char \*mes)  
\{  
PACK pack\_send\_pack;  
time\_t timep;  
pack\_send\_pack.type = type;  
strcpy(pack\_send\_pack.data.send\_name,send\_name);  
strcpy(pack\_send\_pack.data.recv\_name,recv\_name);  
strcpy(pack\_send\_pack.data.mes,mes);  
time(&timep);  
//pack\_send\_pack.data.time = timep;  
if(send(sockfd,&pack\_send\_pack,sizeof(PACK),0) < 0)\{  
my\_err("send",\_\_LINE\_\_);  
\}  
\}  
  
  
//根据参数信息发送包  
void send\_pack\_memcpy(int type,char \*send\_name,char \*recv\_name,char \*mes)  
\{  
PACK pack\_send\_pack;  
time\_t timep;  
pack\_send\_pack.type = type;  
strcpy(pack\_send\_pack.data.send\_name,send\_name);  
strcpy(pack\_send\_pack.data.recv\_name,recv\_name);  
memcpy(pack\_send\_pack.data.mes,mes,MAX\_CHAR\*2);  
time(&timep);  
// pack\_send\_pack.data.time = timep;  
if(send(sockfd,&pack\_send\_pack,sizeof(PACK),0) < 0)\{  
my\_err("send",\_\_LINE\_\_);  
\}  
\}  
view.cpp

\#include "client.h"  
  
  
  
//登陆菜单  
int login\_menu()  
\{  
char choice\_t\[100\];  
int chioce;  
do  
\{  
printf("\\n\\t\\t\\033\[;34m\\33\[1m\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 1.login in \\033\[;34m\\33\[1m\*\\033\[0m \\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 2.register \\033\[;34m\\33\[1m\*\\033\[0m \\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 0.exit \\033\[;34m\\33\[1m\*\\033\[0m \\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\\033\[0m\\n");  
printf("\\t\\tchoice：");  
scanf("%s",choice\_t);  
chioce = get\_choice(choice\_t);  
switch(chioce)  
\{  
case 1:  
if(login() == 1)  
return 1;  
break;  
case 2:  
registe();  
break;  
default:  
break;  
\}  
\}while(chioce!=0);  
return 0;  
\}  
  
  
  
  
  
  
//显示聊天信息  
void show\_mes\_smart(char \*name ,char \*mes)  
\{  
time\_t timep;  
int number = 6;  
char time1\[100\];  
int len ;  
time (&timep);  
strcpy(time1,ctime(&timep));  
len = strlen(time1);  
time1\[len-5\] = '\\0';  
  
  
if(m\_print\_mes\_num == number)  
\{  
for(int i=1;i<=5 ;i++)  
m\_print\_mes\[i\] = m\_print\_mes\[i+1\];  
strcpy(m\_print\_mes\[number\].name,name);  
// strcpy(m\_print\_mes\[number\].time,time);  
strcpy(m\_print\_mes\[number\].mes,mes);  
\}  
else\{  
strcpy(m\_print\_mes\[++m\_print\_mes\_num\].name,name);  
//strcpy(m\_print\_mes\[m\_print\_mes\_num\].time,time);  
strcpy(m\_print\_mes\[m\_print\_mes\_num\].mes,mes);  
\}  
  
  
printf("\\33\[s");  
fflush(stdout);  
  
printf("\\33\[25A\\n");  
  
for(int i=1;i<=20;i++)  
printf("\\33\[K\\n");  
printf("\\33\[21A\\n");  
  
for(int i=1;i<=m\_print\_mes\_num;i++)  
\{  
if(strcmp(m\_print\_mes\[i\].name,m\_my\_infor.username) == 0)  
\{  
printf("\\033\[;34m\\33\[1m%s\\033\[0m\\t\\033\[;34m%s\\033\[0m\\n",m\_print\_mes\[i\].name,time1+10);  
printf("%s\\n", m\_print\_mes\[i\].mes);  
\}  
else  
\{  
printf("\\033\[;33m\\33\[1m%s\\033\[0m\\t\\033\[;33m%s\\033\[0m\\n",m\_print\_mes\[i\].name,time1+10);  
printf("%s\\n", m\_print\_mes\[i\].mes);  
\}  
  
  
\}  
for(int i=1;i<=6- m\_print\_mes\_num ;i++)  
\{  
printf("\\n");  
printf("\\n\\n");  
  
\}  
  
printf("\\33\[u");  
fflush(stdout);  
\}  
  
  
  
  
//好友列表查看  
void friends\_see()  
\{  
  
pthread\_mutex\_lock(&mutex\_local\_user);  
printf("\\33\[2J\\n");  
printf("\\33\[1;1H\\n");  
printf("\\033\[;35m\\33\[1m\\t \*\*\*\*\*\*\*\*\*\*\*the list of friends\*\*\*\*\*\*\*\*\*\*\*\*\* \\033\[0m \\n");  
for(int i=1 ;i<=m\_my\_infor.friends\_num ;i++)  
\{  
switch(m\_my\_infor.friends\[i\].statu)  
\{  
case ONLINE:  
printf("\\033\[;35m\\33\[1m\\t ID\[%d\]: \\033\[0m \\033\[;32m\\33\[1m%s\\033\[0m \[ONLINE\] ", i,m\_my\_infor.friends\[i\].name);  
if(m\_my\_infor.friends\[i\].mes\_num)  
printf("\\033\[;33m%d messages\\033\[0m\\n", m\_my\_infor.friends\[i\].mes\_num);  
else  
printf("\\n");  
break;  
case DOWNLINE:  
printf("\\033\[;35m\\33\[1m\\t ID\[%d\]: \\033\[0m \\033\[;31m\\33\[1m%s\\033\[0m \[DOWNLINE\] ", i,m\_my\_infor.friends\[i\].name);  
if(m\_my\_infor.friends\[i\].mes\_num)  
printf("\\033\[;33m%d messages\\033\[0m\\n", m\_my\_infor.friends\[i\].mes\_num);  
else  
printf("\\n");  
break;  
\}  
\}  
printf("\\n\\n");  
printf("\\033\[;35m\\33\[1m\\t \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*end\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* \\033\[0m \\n");  
pthread\_mutex\_unlock(&mutex\_local\_user);  
\}  
  
  
  
  
//群组信息查看  
void group\_see()  
\{  
pthread\_mutex\_lock(&mutex\_local\_user);  
printf("\\33\[2J\\n");  
printf("\\33\[1;1H\\n");  
printf("\\033\[;35m\\33\[1m\\t \*\*\*\*\*\*\*\*\*\*\*the list of groups\*\*\*\*\*\*\*\*\*\*\*\*\* \\033\[0m \\n");  
for(int i=1 ;i<=m\_my\_infor.group\_num ;i++)  
\{  
printf("\\033\[;35m\\33\[1m\\t ID\[%d\]: \\033\[0m \\033\[;32m\\33\[1m%s\\033\[0m", i,m\_my\_infor.group\[i\]);  
\}  
printf("\\n\\n");  
printf("\\033\[;35m\\33\[1m\\t \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*end\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* \\033\[0m \\n");  
pthread\_mutex\_unlock(&mutex\_local\_user);  
\}  
  
  
  
  
void print\_main\_menu()  
\{  
printf("\\n\\t\\t\\033\[;34m\\33\[1m\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\\033\[0m \\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 1.show friends \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\* 2.add friends \*\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 3.delete friends \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 4.show group \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\* 5.create group \*\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 6.join group \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 7.quit group \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\* 8.delete group \*\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 9.chat with one \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 10.chat with many \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\* 11.send file \*\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 12.file message box %d \\033\[;34m\\33\[1m\*\\033\[0m\\n",m\_recv\_num\_file\_mes);  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 13.mes recording \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\\033\[0m 0.exit \\033\[;34m\\33\[1m\*\\033\[0m\\n");  
printf("\\t\\t\\033\[;34m\\33\[1m\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\\033\[0m\\n");  
printf("\\t\\tchoice：");  
\}  
client.cpp

CC=g++ -std=c++11  
OBJ = happychat\_client  
all:  
$(CC) -o $(OBJ) -cpp ./\*.cpp \`pkg-config --libs --cflags gtk+-2.0\` -pthread -g  
\# $(CC) -o $(OBJ) ./\*.o -I \`pkg-config --libs --cflags gtk+-2.0\` -pthread -g  
\# rm -rf \*.o  
clean:  
\-rm -rf \*.o

[Center]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/49fd7d90a6ff423ea2eeba57ab692457.png
[Center 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/19c6623842094a2b909692bef4790b42.png
[Center 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/bad424ea25e54f37b43735ff37dd82ee.png
[Center 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/12b2c409d8e14008b039e03b7e1dd30b.png
[Center 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/6354b78003b64ca1a4734cf4c8e6b3fd.png
[Center 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/ddd6c1dd647e4a048d4b3049863d7482.png
[Center 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/8a9106d2ad2c4abaab92fd10b3977ce5.png
[Center 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/17f5ba6e4540495dbeff3cf6e143a18e.png
[Center 8]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/94f3bb17306c4c2986868fd5197c600b.png