XX：那飘过的100~_~{2014/10/02 16:12}

    流式套接字(SOCK_STREAM):提供面向连接、可靠的数据传输服务、数据无差错、无重复的发送、且按发送顺序接受。程序的设计思路

    服务器端：

    流程：WSAStartup()->socket()->bind()->listen()->accept()->send()

    （1）创建套接字

    （2）将套接字绑定到一个本地地址和端口上

    （3）将套接字设为监听模式，准备接受客户端的请求

    （4）等待客户端请求的到来，当请求到来后，接受连接请求，返回一个对应与此次连接的套接字

    （5）用返回的套接字与客户端进行通讯

    （6）返回，等待另一个客户端的连接请求

    （7）关闭套接字

// socketTcp.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include "tchar.h"

#pragma comment(lib,"wsock32.lib")
#include <stdio.h>
#include <winsock2.h>

#define MAX_SER 10
#define HOST_PATH 256
#define HOSTNAME_SIZE HOST_PATH

char hostName[MAX_PATH]={0};
unsigned short maxService;
unsigned short port;


void Service(LPVOID lpv);
int LoopControl(SOCKET llistenfd,int isMultiTasking);
void initial();												
int initSockets(void);											//初始化Windows Socket

int main(int argc, char * argv[])  
{
	SOCKET listenFd;			             
	struct sockaddr_in serverAddr;		
	int err;

	initial();
	initSockets();
	
	//创建socket
	listenFd=socket(PF_INET,SOCK_STREAM,0);						
	if(listenFd==INVALID_SOCKET){
		printf("error:out of socket resource \n");
		return 1;		
	}

	//bind本机的端口
	serverAddr.sin_family=PF_INET;														//协议类型是INET
	serverAddr.sin_addr.S_un.S_addr=htonl(INADDR_ANY);									//本机IP
	serverAddr.sin_port=htons(port);													//绑定端口为5054

	err=bind(listenFd,(const struct sockaddr *)&serverAddr,sizeof(serverAddr));			
	if(err==INVALID_SOCKET){
		printf("error: unable to bind socket \n");
		return 1;
	}
	
	//listen 监听端口
	err=listen(listenFd,3);				
	if(err==INVALID_SOCKET){
		printf("error: listen socket failed \n");
		return 1;
	}
	printf("listen......");

	LoopControl(listenFd,1);
	printf("server is down \n");
	WSACleanup();

	return 0;
}

void initial()
{
	maxService=3;
	port=5054;
}

 /*
  *	Winsock服务初始化
 */
int initSockets(void)
{
	WSADATA wsaData;
	WORD sockVersion;                                              //typedef unsigned short WORD(16)
	int err;
	sockVersion=MAKEWORD(2,2);
	err=WSAStartup(sockVersion,&wsaData);						  
	if(err!=0)
	{
		printf("error %d :winsock not avaliable\n",err);
	}
	printf("environemnt invaild success.....\n");
	return 0;
}

/*
** 等待客户端的连接
*/
int LoopControl(SOCKET listenfd,int isMultiTasking){
	SOCKET acceptfd;
	struct sockaddr_in clientAddr;				//客户端地址信息
	int err;
	int serverNum=0;
	HANDLE handles[MAX_SER];
	int nSize;
	nSize=sizeof(clientAddr);
	int myID;
	
	//存在固定的次数[服务次数小于最大服务次数]
	while(serverNum<maxService)
	{
		acceptfd=accept(listenfd,(struct sockaddr *)&clientAddr,&nSize);			//接收客户连接的准备
		if(acceptfd==INVALID_SOCKET)
		{
			printf("error:accept failed \n");
			return 1;
		}
		printf("accepted connection from client at %s \n",inet_ntoa(clientAddr.sin_addr));
		if(isMultiTasking)
		{
			handles[serverNum]=CreateThread(NULL,1000,(LPTHREAD_START_ROUTINE)Service,(LPVOID)acceptfd,0,(unsigned long *)&myID);
		}
		else
		{
			Service((LPVOID)acceptfd);
		}
		serverNum++;
	}
	if(isMultiTasking)
	{
		err=WaitForMultipleObjects(maxService,handles,TRUE,INFINITE);
		printf("last thread to finish was thread # %d \n",err);
	}
	return 0;
}

			
/*
*接收客户端的数据,AND向客户端发送数据
*/			
void Service(LPVOID lpv){		
	SOCKET acceptfd=(SOCKET)lpv;
	const char *msg="message have recived";
	char response[4096];
	memset(response,0,sizeof(response));
	
	while(acceptfd!=SOCKET_ERROR)
	{
		int result=recv(acceptfd,response,sizeof(response),0);				//接受客户机的数据
		if(result>0)
		{
			printf("from client: %s ",response);
			send(acceptfd,msg,strlen(msg)+1,0);
		}

	}
	closesocket(acceptfd);
}

TCP的Socket技术之服务器端