#include <winsock.h> #include <iostream.h> #include <stdio.h> #include <string.h> #include <windows.h> #define PORT 100 #define socklen_t int #pragma comment(lib, "wsock32.lib") SOCKET client; char server[50]; void ClientThread() {     char message[256];     while(1)     {         strcpy(message,"");         int len=recv(client,message,sizeof(message),0);         if (strcmp(message,"")!=0)         {             cout<<"从"<<server<<"得到消息:\n";             //cout<<"len:"<<len<<endl;             message[len]='\0';             cout<<message;         }     } } int main() {     char message[256];     sockaddr_in srv;     WSADATA wsadata;     WORD VersionRequested=MAKEWORD(1,1);     if (WSAStartup(VersionRequested,&wsadata))     {         cout<<"Wsadata start failed\n";         return -1;     }     client=socket(PF_INET,SOCK_STREAM,0);     if (client==INVALID_SOCKET)     {         cout<<"Socket create failed\n";         return -1;     }     srv.sin_family=PF_INET;     srv.sin_addr.s_addr=htonl(INADDR_ANY);     srv.sin_port=htons(PORT);     cout<<"请输入服务器IP:";     cin>>server;     srv.sin_addr.s_addr = inet_addr(server);     if (connect(client,(struct sockaddr *)&srv,sizeof(srv))==SOCKET_ERROR)     {         cout<<"无法连接服务器.\n";         WSACleanup();         return -1;     }     while(1)     {         DWORD thread;         CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(ClientThread),NULL,0,&thread);         while(fgets(message,strlen(message),stdin))         {             cout<<"发出消息:"<<message<<endl;             send(client,message,strlen(message),0);         }     }     closesocket(client);     WSACleanup(); }  

评论