本文介紹了在Windows 作業系統下基於TCP/IP 協議Socket 套介面的通訊機制以及多執行緒程式設計知識與技巧，並給出多執行緒方式實現多使用者與服務端(C/S)併發通訊模型的詳細演算法，最後展現了用C++編寫的多使用者與伺服器通訊的應用例項並附有程式。

關鍵詞：Windows；套接字；多執行緒；併發伺服器；

    Socket 是建立在傳輸層協議（主要是TCP 和UDP）上的一種套接字規範，最初由美國加州Berkley 大學提出，為UNIX 系統開發的網路通訊介面，它定義了兩臺計算機之間通訊的規範，socket 遮蔽了底層通訊軟體和具體作業系統的差異，使得任何兩臺安裝了TCP 協議軟體和實現了Socket 規範的計算機之間的通訊成為可能，Socket 介面是TCP/IP 網路最為通用的應用介面，也是在Internet 上進行網路程式應用開發最通用的API[1]，本文介紹了Socket通訊的基本機制以及採用多執行緒技術實現併發通訊的基本原理，並給出例項。

//-----------------------------------------------------------------------------------
// 版權歸scut4009所有
//-----------------------------------------------------------------------------------
// 檔名：SocketSever.cpp
// 編寫人：ZP1015
// 編寫時間：2015/04/7
// 編譯工具: Visual Studio 2008
// 程式說明: socket多執行緒通訊,伺服器端,基於TCP
//------------------------------------------------------------------------------------
#include "stdafx.h"
#include "Socket.h"
#include<windows.h>

HANDLE hMutex;
//------------------------------------------------------------------------------------
//函式名稱:      Send(SOCKET sockClient)
/*函式功能:      傳送資料
/*入口引數:      SOCKET sockClient				 
//出口引數:     
//全域性變數引用:  
//呼叫模組:      無 
//------------------------------------------------------------------------------------*/
void Send(SOCKET sockClient)
{
	char sendBuf[MaxSize];
	int byte = 0;

	while(1)
	{
		WaitForSingleObject(hMutex, INFINITE);
		gets(sendBuf);
		byte= send(sockClient,sendBuf,strlen(sendBuf)+1,0);;//伺服器從客戶端接受資料
		if (byte<=0)
		{
			break;
		}	
		
		Sleep(1000);
		ReleaseMutex(hMutex);

	}
	closesocket(sockClient);//關閉socket,一次通訊完畢
}
//------------------------------------------------------------------------------------
//函式名稱:     Rec()
/*函式功能:     接收函式
/*入口引數:     SOCKET sockClient			 
//出口引數:     
//全域性變數引用:  
//呼叫模組:      無 
//------------------------------------------------------------------------------------*/
void Rec(SOCKET sockClient)
{
	char revBuf[MaxSize];
	int byte = 0;

	while(1)
	{
		WaitForSingleObject(hMutex, INFINITE);

		byte= recv(sockClient,revBuf,strlen(revBuf)+1,0);//伺服器從客戶端接受資料
		if (byte<=0)
		{
			break;
		}	

		printf("%s\n",revBuf);

		Sleep(1000);
		ReleaseMutex(hMutex);

	}
	closesocket(sockClient);//關閉socket,一次通訊完畢
}


//********************************************************************************************************/
//** 函式名 ** main()
//**  輸入  ** 無
//**  輸出  ** 無
//**函式描述** 主函式
//********************************************************************************************************/
int main()
{

	SOCKADDR_IN addrServer;
	int sockServer; 

	
 	if (SOCKET_ERROR ==SocketInit())
 	{
 		return -1;
 	}
	
	addrServer.sin_addr.S_un.S_addr=htonl(INADDR_ANY);		//htol將主機位元組序long型轉換為網路位元組序
	addrServer.sin_family=AF_INET;
	addrServer.sin_port=htons(6666);						//htos用來將埠轉換成字元，1024以上的數字即可
	
	
	sockServer=socket(AF_INET,SOCK_STREAM,0);				//面向連線的可靠性服務SOCK_STRAM
	bind(sockServer,(SOCKADDR*)&addrServer,sizeof(SOCKADDR));//將socket繫結到相應地址和埠上
	listen(sockServer,5);									//等待佇列中的最大長度為5

	printf("Welcome,the Host %s is running!Now Wating for someone comes in!\n",inet_ntoa(addrServer.sin_addr));


	int len=sizeof(SOCKADDR);

	SOCKADDR_IN addrClient;

	while(1)			
	{
		SOCKET sockClient=accept(sockServer,(SOCKADDR*)&addrClient,&len);//阻塞呼叫程序直至新的連接出現

		if(sockClient == INVALID_SOCKET)
		{	
			printf("Accept Failed!\n");
			continue; //繼續監聽
		}
		HANDLE hThread1 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)Send,(LPVOID)sockClient,0,0);//傳送

		if(hThread1!=NULL)
		{
			CloseHandle(hThread1);
		}
		HANDLE hThread2 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)Rec,(LPVOID)sockClient,0,0);//接收

		if(hThread2!=NULL)
		{
			CloseHandle(hThread2);
		}
		Sleep(1000);	//一定要
	}

	getchar();
	return 0;
}
 

//-----------------------------------------------------------------------------------
// 版權歸scut4009所有
//-----------------------------------------------------------------------------------
// 檔名：SocketClient.cpp
// 編寫人：ZP1015
// 編寫時間：2015/04/7
// 編譯工具: Visual Studio 2008
// 程式說明: socket多執行緒通訊
//------------------------------------------------------------------------------------
#include "stdafx.h"
#include "Socket.h"

#pragma comment(lib,"WS2_32.LIB")

const char *SeverIp = "192.168.1.100";
HANDLE hMutex;

//------------------------------------------------------------------------------------
//函式名稱:      Send(SOCKET sockClient)
/*函式功能:      傳送資料
/*入口引數:      SOCKET sockClient				 
//出口引數:     
//全域性變數引用:  
//呼叫模組:      無 
//------------------------------------------------------------------------------------*/
void Send(SOCKET sockClient)
{
	char sendBuf[MaxSize];
	int byte = 0;

	while(1)
	{
		WaitForSingleObject(hMutex, INFINITE);
		gets(sendBuf);
		byte= send(sockClient,sendBuf,strlen(sendBuf)+1,0);;//伺服器從客戶端接受資料
		if (byte<=0)
		{
			break;
		}	
		
		Sleep(1000);
		ReleaseMutex(hMutex);

	}
	closesocket(sockClient);//關閉socket,一次通訊完畢
}
//------------------------------------------------------------------------------------
//函式名稱:     Rec()
/*函式功能:     接收函式
/*入口引數:     SOCKET sockClient			 
//出口引數:     
//全域性變數引用:  
//呼叫模組:      無 
//------------------------------------------------------------------------------------*/
void Rec(SOCKET sockClient)
{
	
	char revBuf[MaxSize];
	int byte = 0;

	while(1)
	{
		WaitForSingleObject(hMutex, INFINITE);

		byte= recv(sockClient,revBuf,strlen(revBuf)+1,0);//伺服器從客戶端接受資料
		if (byte<=0)
		{
			break;
		}	

		printf("%s\n",revBuf);

		Sleep(1000);
		ReleaseMutex(hMutex);

	}
	closesocket(sockClient);//關閉socket,一次通訊完畢
}

int main()
{
	
	if (SOCKET_ERROR ==SocketInit())
	{
		return -1;
	}

	while(1)
	{
		SOCKET sockClient=socket(AF_INET,SOCK_STREAM,0);
		SOCKADDR_IN addrSrv;
		addrSrv.sin_addr.S_un.S_addr=inet_addr(SeverIp);//設定需要連線的伺服器的ip地址
		addrSrv.sin_family=AF_INET;
		addrSrv.sin_port=htons(6666);//設定需要連線的伺服器的埠地址
		connect(sockClient,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));//與伺服器進行連線

		
		HANDLE hThread1 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)Rec,(LPVOID)sockClient,0,0);

		if(hThread1!=NULL)
		{
			CloseHandle(hThread1);
		}

		HANDLE hThread2 = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)Send,(LPVOID)sockClient,0,0);

		if(hThread2!=NULL)
		{
			CloseHandle(hThread2);
		}

		Sleep(1000);
		
	}
	getchar();

    WSACleanup();
	return -1;
}