学步园

在看unix网络编程，闲着的时候采用TCP实现了一个简单的cs通信示例：

tcpServer.c:

#include <stdio.h><br /> #include <stdlib.h><br /> #include <windows.h><br /> #define MAX_LISTEN_QUEUE_NUMBER 10<br /> #define HOST_PORT 10000<br /> #define MAX_PACKET_LENGTH 1400<br /> int main()<br /> {<br /> WORD wVersionRequested;<br /> WSADATA wsaData;<br /> int err;<br /> wVersionRequested = MAKEWORD( 2, 2 );<br /> err = WSAStartup( wVersionRequested, &wsaData );<br /> if ( err != 0 )<br /> {<br /> /* Tell the user that we could not find a usable */<br /> /* WinSock DLL. */<br /> return 0;<br /> }<br /> /* Confirm that the WinSock DLL supports 2.2.*/<br /> /* Note that if the DLL supports versions greater */<br /> /* than 2.2 in addition to 2.2, it will still return */<br /> /* 2.2 in wVersion since that is the version we */<br /> /* requested. */<br /> if ( LOBYTE( wsaData.wVersion ) != 2 ||<br /> HIBYTE( wsaData.wVersion ) != 2 )<br /> {<br /> /* Tell the user that we could not find a usable */<br /> /* WinSock DLL. */<br /> WSACleanup( );<br /> return 0;<br /> }<br /> int servfd, clientfd;<br /> servfd = socket(AF_INET, SOCK_STREAM, 0);<br /> if(servfd < 0)<br /> {<br /> printf("server create socket failed./n");<br /> return 0;<br /> }<br /> int on = 1;<br /> if(setsockopt(servfd, SOL_SOCKET, SO_REUSEADDR, (const char *)&on, sizeof(on)) < 0)<br /> {<br /> printf("set socket option failed./n");<br /> return 0;<br /> }<br /> struct sockaddr_in servaddr;<br /> struct sockaddr_in clientaddr;<br /> memset(&servaddr,0,sizeof(servaddr));<br /> memset(&clientaddr,0,sizeof(clientaddr));<br /> servaddr.sin_family = AF_INET;<br /> servaddr.sin_port = htons(HOST_PORT);<br /> servaddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);<br /> if(bind(servfd, (const struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)<br /> {<br /> printf("bind failed./n");<br /> return 0;<br /> }<br /> if(listen(servfd,10) < 0)<br /> {<br /> printf("listen failed./n");<br /> return 0;<br /> }<br /> char buf[MAX_PACKET_LENGTH];<br /> memset(buf,0,MAX_PACKET_LENGTH);<br /> int length = sizeof(clientaddr);<br /> int clientRecord[FD_SETSIZE];<br /> int index = 0;<br /> for(; index < FD_SETSIZE; index++)<br /> clientRecord[index] = -1;<br /> fd_set readSet;<br /> FD_ZERO(&readSet);<br /> FD_SET(servfd,&readSet);<br /> int maxfd = servfd;<br /> for(;;)<br /> {<br /> clientfd = accept(servfd, (struct sockaddr *)&clientaddr,&length);<br /> for(index = 0; index < FD_SETSIZE; index++)<br /> {<br /> if(clientRecord[index] < 0)<br /> {<br /> clientRecord[index] = clientfd;<br /> break;<br /> }<br /> }<br /> if(index == FD_SETSIZE)<br /> {<br /> printf("too many sockets./n");<br /> break;<br /> }<br /> for(index = 0; index < FD_SETSIZE; index++)<br /> {<br /> if(clientRecord[index] > 0)<br /> {<br /> FD_SET(clientRecord[index],&readSet);<br /> maxfd = maxfd > clientRecord[index] ? maxfd : clientRecord[index];<br /> }<br /> else<br /> break;<br /> }<br /> struct timeval time;<br /> time.tv_sec = 10;<br /> time.tv_usec = 0;<br /> if(select(maxfd,&readSet,NULL,NULL,&time) <= 0)<br /> break;<br /> int sockfd;<br /> for(index = 0; index < FD_SETSIZE; index++)<br /> {<br /> if((sockfd = clientRecord[index]) < 0)<br /> continue;<br /> if(FD_ISSET(sockfd,&readSet))<br /> {<br /> while(1)<br /> {<br /> recv(sockfd,buf,MAX_PACKET_LENGTH,0);<br /> printf("%s/n",buf);<br /> if(strcmp(buf,"end") == 0)<br /> break;<br /> }<br /> closesocket(sockfd);<br /> clientRecord[index] = -1;<br /> }<br /> }<br /> }<br /> closesocket(servfd);<br /> return 0;<br /> }<br />  

tcpClient.c

#include <stdio.h><br /> #include <stdlib.h><br /> #include <windows.h><br /> #include <string.h><br /> #define HOST_PORT 10000<br /> int main()<br /> {<br /> WORD wVersionRequested;<br /> WSADATA wsaData;<br /> int err;<br /> wVersionRequested = MAKEWORD( 2, 2 );<br /> err = WSAStartup( wVersionRequested, &wsaData );<br /> if ( err != 0 )<br /> {<br /> /* Tell the user that we could not find a usable */<br /> /* WinSock DLL. */<br /> return;<br /> }<br /> /* Confirm that the WinSock DLL supports 2.2.*/<br /> /* Note that if the DLL supports versions greater */<br /> /* than 2.2 in addition to 2.2, it will still return */<br /> /* 2.2 in wVersion since that is the version we */<br /> /* requested. */<br /> if ( LOBYTE( wsaData.wVersion ) != 2 ||<br /> HIBYTE( wsaData.wVersion ) != 2 )<br /> {<br /> /* Tell the user that we could not find a usable */<br /> /* WinSock DLL. */<br /> WSACleanup( );<br /> return;<br /> }<br /> int clientfd = socket(AF_INET, SOCK_STREAM, 0);<br /> if(clientfd < 0)<br /> {<br /> printf("client create socket failed./n");<br /> return 0;<br /> }<br /> int on = 1;<br /> if(setsockopt(clientfd, SOL_SOCKET, SO_REUSEADDR, (const char *)&on, sizeof(on)) < 0)<br /> {<br /> printf("set socket option failed./n");<br /> return 0;<br /> }<br /> struct sockaddr_in servaddr;<br /> memset(&servaddr, 0, sizeof(servaddr));<br /> servaddr.sin_family = AF_INET;<br /> servaddr.sin_port = htons(HOST_PORT);<br /> servaddr.sin_addr.S_un.S_addr = inet_addr("192.168.1.56");<br /> char buf[BUFSIZ];<br /> memset(buf,0,BUFSIZ);<br /> strncpy(buf,"shawn's client",14);<br /> //buf[BUFSIZ] = '/0';<br /> if(connect(clientfd,(const struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)<br /> {<br /> printf("%d/n",errno);<br /> return 0;<br /> }<br /> int index = 0;<br /> for(index = 0; index < 5; index++)<br /> {<br /> send(clientfd,buf,strlen(buf) + 1, 0);<br /> _sleep(10);<br /> }<br /> strcpy(buf,"end");<br /> send(clientfd,buf,strlen(buf) + 1, 0);<br /> closesocket(clientfd);<br /> getchar();<br /> return 0;<br /> }<br />