- 模拟QQ聊天室（线程并发）

#include #include #include #include #include #include #include #include #include #include #define MAXLINE 512 #define NAMELEN 20 #define PORT 8080 int sockfd; //发送消息的函数snd void snd() { char name[NAMELEN]; char buff[MAXLINE]; gets(name); write(sockfd,name,strlen(name)); while(1) { gets(buff); write(sockfd,buff,strlen(buff)); if(strcmp("bye",buff)==0) { exit(0); } } } int main(int argc,char **argv) { pthread_t thread; struct sockaddr_in servaddr; if(argc != 2) { printf("usage: echo ip\n"); return -1; } //调用socket函数创建客户端的套接字 sockfd=socket(AF_INET,SOCK_STREAM,0); if(sockfd<0) { printf("Socket create failed\n"); return -1; } //初始化服务器端的地址 servaddr.sin_family=AF_INET; servaddr.sin_port=htons(PORT); if(inet_aton(argv[1],&servaddr.sin_addr)<0) { printf("inet_aton error.\n"); return -1; } //调用connect函数实现与服务器端建立连接 printf("Connecting...\n"); if(connect(sockfd,(struct sockaddr*)&servaddr,sizeof(servaddr))<0) { printf("Connect server failed.\n"); return -1; } //从此处开始程序分做两个线程 //创建发送消息的线程，调用了发送消息的函数snd pthread_create(&thread,NULL,(void*)(&snd),NULL); //从此处开始向下为接收消息的线程 char buff[MAXLINE]; int len; while(1) { if((len=read(sockfd,buff,MAXLINE))>0) { buff[len]=0; printf("\n%s\n\n",buff); } } return 0; }