服务端：
1 #include<sys/socket.h> 2 #include<sys/types.h> 3 #include<stdio.h> 4 #include<unistd.h> 5 #include<stdlib.h> 6 #include<string.h> 7 #include<netdb.h> 8 #include<netinet/in.h> 9 #include<arpa/inet.h> 10 #include<pthread.h> 11 12 13 void recv_data(void* fd) 14 { 15 int sockfd = *((int *)fd); 16 char buf[200]; 17 int renum; 18 while(1) 19 { 20 bzero(buf, 200); 21 22 if((renum = recv(sockfd, buf, 200, 0)) > 0) 23 { 24 printf("recv: %s ", buf); 25 } 26 else if(renum == -1) 27 { 28 printf("recv -1"); 29 exit(-1); 30 } 31 } 32 } 33 int main(void) 34 { 35 pthread_t pid; 36 int sockfd; 37 struct sockaddr_in serveraddr; 38 39 char buf[200]; 40 sockfd = socket(AF_INET, SOCK_STREAM, 0); 41 bzero(&serveraddr, sizeof(struct sockaddr)); 42 serveraddr.sin_family = AF_INET; 43 serveraddr.sin_port = htons(4444); 44 serveraddr.sin_addr.s_addr = inet_addr("192.168.0.100"); 45 46 47 if(connect(sockfd, (struct sockaddr *)&serveraddr, sizeof(struct sockaddr)) == -1) 48 { 49 printf("connect failed "); 50 exit(-1); 51 } 52 else 53 printf("connect succeed "); 54 pthread_create(&pid, NULL, (void*)recv_data,(void*)&sockfd); 55 while(1) 56 { 57 memset(buf, 0, 200); 58 gets(buf); 59 60 send(sockfd, buf, strlen(buf), 0); 61 if(strncmp(buf, "quit", 4) == 0) 62 { 63 close(sockfd); 64 return 0; 65 } 66 67 } 68 close(sockfd); 69 return 0; 70 }
客户端：
1 #include<sys/socket.h> 2 #include<sys/types.h> 3 #include<stdio.h> 4 #include<unistd.h> 5 #include<stdlib.h> 6 #include<string.h> 7 #include<netdb.h> 8 #include<netinet/in.h> 9 #include<arpa/inet.h> 10 #include<pthread.h> 11 12 void recv_data(void* fd) 13 { 14 int sockfd = *((int *)fd); 15 char buf[200]; 16 int renum; 17 while(1) 18 { 19 bzero(buf, 200); 20 21 //recv(sockfd, buf, 200, 0);//如果断开 ,recv不再阻塞 返回值 0 22 //printf("recv: %s ", buf); 23 24 if((renum = recv(sockfd, buf, 200, 0)) > 0) 25 printf("recv: %s ", buf); 26 else if(renum == -1) 27 { 28 printf("recv -1"); 29 exit(-1); 30 } 31 else 32 { 33 close(sockfd); 34 exit(1); 35 36 } 37 38 39 } 40 41 } 42 int main(void) 43 { 44 pthread_t pid; 45 int sockfd, clientfd; 46 int sinsize; 47 char buf[200]; 48 struct sockaddr_in myaddr, clientaddr; 49 sockfd = socket(AF_INET, SOCK_STREAM, 0); 50 if(sockfd == -1) 51 { 52 printf("socket failed "); 53 exit(-1); 54 } 55 printf("%d ", sockfd); 56 57 bzero(&myaddr, sizeof(struct sockaddr)); 58 myaddr.sin_family = AF_INET; 59 myaddr.sin_port = htons(4444); 60 myaddr.sin_addr.s_addr =inet_addr("192.168.0.100"); 61 sinsize = 1; 62 setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &sinsize, sizeof(int)); 63 if(bind(sockfd, (struct sockaddr*)&myaddr, sizeof(struct sockaddr)) == -1) 64 { 65 printf("bind failed "); 66 exit(-1); 67 } 68 69 if(listen(sockfd, 1) == -1) 70 { 71 printf("listen failed "); 72 exit(-1); 73 } 74 sinsize = sizeof(struct sockaddr); 75 if((clientfd = accept(sockfd, (struct sockaddr *)&clientaddr, &sinsize)) == -1) 76 { 77 printf("accept failed "); 78 exit(-1); 79 } 80 else 81 printf("accept succeed "); 82 pthread_create(&pid, NULL, (void*)recv_data,(void*)&clientfd); 83 while(1) 84 { 85 memset(buf, 0, 200); 86 gets(buf); 87 if(strncmp(buf, "quit", 4) == 0) 88 { 89 close(clientfd); 90 close(sockfd); 91 return 0; 92 } 93 send(clientfd, buf, strlen(buf), 0); 94 } 95 sleep(1); 96 97 close(clientfd); 98 close(sockfd); 99 100 return 0; 101 }