// server.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"
#include <stdio.h>
#include <string.h>
#include <winsock2.h>
#define BACKLOG 10
typedef struct sockaddr_in socketadd;
typedef struct sockaddr socketaddcm;
typedef struct
{
unsigned char active;
int socket;
socketadd add;
} socket_client;
DWORD do_accept_cleint_socket(socket_client * sct)
{
char buff[1024] = {0};
printf("do_accept_cleint_socket(%s)", inet_ntoa(sct->add.sin_addr));
while (1)
{
memset(buff, 0, 1024);
while (recv(sct->socket, buff, 1024, 0))
{
printf(buff);
}
printf("\n");
}
return 1;
}
void do_server_socket(void)
{
int socket_sv;
socketadd server_add;
int sin_size, connect_count = 0;
socket_client clientconnect[1000] = {0};
DWORD threadids[1000] = {0};
if ((socket_sv = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
printf("create socket error, exit(1)");
return;
}
server_add.sin_family = AF_INET;
server_add.sin_addr.s_addr = ADDR_ANY;
server_add.sin_port = htons(3000);
memset(&(server_add.sin_zero), 0, 8);
if (bind(socket_sv, (socketaddcm *)&server_add, sizeof(socketadd)) == -1)
{
printf("bind socket error, exit(1)");
return;
}
if (listen(socket_sv, BACKLOG) == -1)
{
printf("listen socket error, exit(1)");
return;
}
sin_size = sizeof(struct sockaddr_in);
while (1)
{
if ((clientconnect[connect_count].socket = accept(socket_sv,
(struct sockaddr *)&(clientconnect[connect_count].add), &sin_size)) == -1)
{
printf("accept error.");
continue;
}
else
{
clientconnect[connect_count].active = 1;
CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)(&do_accept_cleint_socket),
&clientconnect[connect_count], 0, &threadids[connect_count]);
connect_count++;
}
}
shutdown(socket_sv, SD_BOTH);
}
int main(int argc, char* argv[])
{
do_server_socket();
return 0;
}
