Multi_Threaded_Client_Server.rar_Server_多线程

// HEADER FILE #include <windows.h> #include <stdio.h> #include <conio.h> #include <process.h> char buffer[]="ANY DATA"; // Static Global Data /*-------------------------------------------------------------------*/ void MyFunction( void* Arg ) { SOCKET Client=(*(int *)Arg); while(1) { send(Client,buffer,100,0); } _endthreadex(0); } /*--------------------------------------------------------------------*/ void main(void) { int a,b,c,d; // For Server Address or Address of P1. int port; // For Port No of Server or Port of P1. struct sockaddr_in serv_addr,cli_addr; SOCKET Server; SOCKET Client; int clilen=sizeof(cli_addr); /***************************************************/ /* SOCKET INITIALISATION */ /***************************************************/ WSADATA WsaDat; if (WSAStartup(MAKEWORD(1,1),&WsaDat) != 0) { printf("\n\n WSA Initialization failed! STOP!!!"); exit(1); } /***************************************************/ /* SOCKET CREATION */ /***************************************************/ Server = socket(AF_INET, SOCK_STREAM, 0); if (Server == INVALID_SOCKET) { printf("\n\n Socket creation failed!STOP!!!"); exit(1); } else printf("\n\n SOCKET IS CREATED SUCCESSFULLY..."); /***************************************************/ /* SERVER ADDRESS */ /***************************************************/ serv_addr.sin_family=AF_INET; printf("\n\n ENTER THE SERVER IP "); scanf("%d%d%d%d",&a,&b,&c,&d); serv_addr.sin_addr.S_un.S_un_b.s_b1 =a ; serv_addr.sin_addr.S_un.S_un_b.s_b2 =b ; serv_addr.sin_addr.S_un.S_un_b.s_b3 =c ; serv_addr.sin_addr.S_un.S_un_b.s_b4 =d ; printf("\n\n ENTER THE PORT NO "); scanf("%d",&port); serv_addr.sin_port = htons(port); /***************************************************/ /* BIND THE SOCKET*/ /***************************************************/ if (bind(Server,(struct sockaddr *)(&serv_addr),sizeof(serv_addr)) == SOCKET_ERROR) { printf("\n\n Attempt to bind failed!STOP!!!"); } else printf("\n\n BIND PROCESS IS CREATED SUCCESSFULLY...\n "); /***************************************************/ /* LISTEN FOR RECEIVING CONNECTION*/ /***************************************************/ if(listen(Server,5)==SOCKET_ERROR) printf("\n Error in Listenning The Socket!STOP!!!"); /*---------------------------------------------------*/ while(1) { printf("\n SERVER IS RUNNING ..."); Client=accept(Server,(struct sockaddr*)&cli_addr,&clilen); _beginthread(MyFunction,0,(void *)&Client); } getch(); }