服务端实现了验证用户是否已经存在#xff08;支持最大64用户连接#xff09;支持广播用户进入退…

多线程在线聊天室

客户端实现了判单用户登录结果、防止单回车字符发送、保存和显示历史聊天记录仅自己、退出聊天室功能。

服务端实现了验证用户是否已经存在支持最大64用户连接支持广播用户进入退出聊天室以及用户聊天内容。

客户端

Socket(AF_INET,SOCK_STREAM,0);//connectSIN

serverinfo;serverinfo.sin_family

htons(atoi(argv[2]));serverinfo.sin_addr.s_addr

addrlen

sizeof(SIN);Connect(socketfd,(SA*)serverinfo,addrlen);//send

nameprintf(请输入昵称\n);gets(namebuff);write(socketfd,namebuff,sizeof(namebuff));char

b[20];read(socketfd,b,sizeof(b));if(strstr(b,已存在)){printf(已存在\n);close(socketfd);return

}//print

端口:%d\n,inet_ntoa(serverinfo.sin_addr),ntohs(serverinfo.sin_port));//make

son

threadpthread_create(id,NULL,son_fun,(void

*)socketfd);//w

{list_history_msg(namebuff);continue;}//determine

whea***r

%s%s,namebuff,asctime(tinfo),退出聊天);write(socketfd,sendbuff,sizeof(sendbuff));close(socketfd);exit(0);}//sendchar

sendbuff[618]

%s%s,namebuff,asctime(tinfo),readbuff);write(socketfd,sendbuff,sizeof(sendbuff));//save

datasave(sendbuff,namebuff);}//关闭close(socketfd);return

void

0;sprintf(path,./userdata/%s.txt,nbuff);FILE

fopen(path,a);printf(********聊天记录*********\n);while(getline(line

len

-1)printf(%s,line);printf(************************\n);free(line);fclose(fp);

void

path[128];sprintf(path,./userdata/%s.txt,nbuff);FILE

fopen(path,a);fprintf(fp,%s\n,dbuff);fclose(fp);

}int

socket(domain,type,protocol);if(socketFd

-1){perror(socket);exit(1);}return

socketFd;

connect(sockfd,serv_addr,addrlen);if(val

-1){perror(connect);exit(1);}return

void

readbuff[512]{0};while(1){memset(readbuff,0,sizeof(readbuff));if(read(readpipefd,readbuff,sizeof(readbuff))0){printf(%s\n\n,readbuff);}else{close(readpipefd);pthread_exit(NULL);}}

}服务端

Socket(AF_INET,SOCK_STREAM,0);//需要进行重用地址及其端口号int

opt

1;setsockopt(socketfd,SOL_SOCKET,SO_REUSEADDR,opt,sizeof(opt));//绑定信息编写服务器信息SIN

serverinfo;serverinfo.sin_family

AF_INET;

sizeof(SIN);Bind(socketfd,(SA*)serverinfo,addrlen);//监听Listen(socketfd,MAXBACKLOG);//读写while(1){//等待连接SIN

clientinfo;int

Accept(socketfd,(SA*)clientinfo,clientaddrlen);printf(客户端地址:%s

端口号:%d\n,inet_ntoa(clientinfo.sin_addr),ntohs(clientinfo.sin_port));//创建子线程pthread_t

id;pthread_create(id,NULL,son_fun,(void

*)newfd);}//关闭close(socketfd);return

int

i){if(strcmp(username,Userlist[i])

0)return

{0};read(readfd,namebuff,sizeof(namebuff));//determine

wher***r

existif(is_exist(namebuff)){write(readfd,已存在,sizeof(已存在));close(readfd);pthread_exit(NULL);}else{write(readfd,登录成功,sizeof(登录成功));char

r[50];sprintf(r,%s

%s,namebuff,进入聊天室);printf(%s\n,r);broadcast(r,namebuff);}//save

username

i0;i10;i){if(strlen(Userlist[i])0){strcpy(Userlist[i],namebuff);Userfdlist[i]

readfd;break;}}while(1){memset(readbuff,0,sizeof(readbuff));if(read(readfd,readbuff,sizeof(readbuff))0){if(strlen(readbuff)0){//printf(%s\n\n,readbuff);//broadcastbroadcast(readbuff,namebuff);if(strstr(readbuff,退出聊天))for(int

i0;i10;i)if(strcmp(Userlist[i],namebuff)0){printf(%s\n,readbuff);strcpy(Userlist[i],\0);close(readfd);pthread_exit(NULL);}}}else{close(readfd);pthread_exit(NULL);}}

void

himselfif(strcmp(Userlist[i],n)!0

strlen(Userlist[i])!0)write(Userfdlist[i],r,strlen(r));

int

socket(domain,type,protocol);if(socketFd

-1){perror(socket);exit(1);}return

socketFd;

bind(sockfd,my_addr,addrlen);if(val){perror(bind);exit(1);}return

int

-1){perror(listen);exit(1);}return

val;

accept(s,addr,addrlen);if(NEWfd

-1){perror(listen);exit(1);}return

NEWfd;