windows网络编程第8章介绍.ppt

3．工作线程函数WorkerThread() WorkerThread()函数用于循环处理新接入的客户端连接，接受客户端数据。 当有新的客户端连接被接受后，变量g_bNewConnectionArrived被设置为true。在WorkerThread()函数中，使用while语句循环检测变量g_bNewConnectionArrived的值，当等于true时，程序会初始化PER_IO_OPERATION_DATA结构体，并以它为参数调用WSARecv()函数，接收来自客户端的数据。WSARecv()函数被异步执行，即执行完成后直接返回。当数据到达时，程序将调用CompletinROUTINE()函数，处理接收到的数据。处理完成后，程序将g_bNewConnectionArrived变量设置为FALSE，表示变量g_sNewClientConnection中指定的接入连接已经被处理。 4．完成例程函数CompletinROUTINE() void CALLBACK CompletionROUTINE( DWORD dwError,// 重叠操作的完成状态 DWORD cbTransferred, // 发送的字节数 LPWSAOVERLAPPED lpOverlapped, // 指定重叠操作的结构体 DWORD dwFlags) // 标识位 { // 将LPWSAOVERLAPPED类型的lpOverlapped转化成了LPPER_IO_OPERATION_DATA LPPER_IO_OPERATION_DATA lpPerIOData = ( LPPER_IO_OPERATION_DATA) lpOverlapped; // 如果发生错误或者没有数据传输，则关闭套接字，释放资源 if (dwError != 0 || cbTransferred == 0) { closesocket( lpPerIOData- sClient) ; HeapFree( GetProcessHeap(), 0, lpPerIOData) ; } 4．完成例程函数CompletinROUTINE() else { lpPerIOData-szMessage[cbTransferred]=\0; // 标识接收数据的结束 // 向客户端发送接收到的数据 send(lpPerIOData-sClient, lpPerIOData-szMessage, cbTransferred, 0) ; // 执行另一个异步操作，接收数据 memset (lpPerIOData-overlap, 0, sizeof(WSAOVERLAPPED)); lpPerIOData-Buffer.len = MSGSIZE; lpPerIOData-Buffer.buf = lpPerIOData-szMessage; // 接收数据 WSARecv( lpPerIOData-sClient, lpPerIOData-Buffer, 1, lpPerIOData-NumberOfBytesRecvd, lpPerIOData-Flags, lpPerIOData-overlap, CompletionROUTINE); } } 5．主函数_tmain() 程序的工作组流程如下： 初始化Windows Sockets环境。 创建监听套接字sListen，并将其绑定到本地地址的9990端口。 在套接字sListen上进行监听。 创建工作线程，对客户端发送来的数据进行处理。 循环处理来自客户端的连接请求，接受连接，并将得到的与客户端进行通信的套接字保存到g_sNewClientConnection中。将变量g_bNewConnectionArried设置为TRUE，表示存在新的客户端连接。 8.7 基于完成端口模型的Socket编程 8.7.1 完成端口模型的工作原理 8.7.2 创建完成端口对象 8.7.3 等待重叠I/O的操作结果 8.7.4 基于完成端口模型的服务器应用程序实例 8.7.1 完成端口模型的工作原理 1．串行线程模型 2．并发线程模型 3．完成端口模型 1．串行线程模型 在串行线程模型中，服务器程序使用单个线程来处理客户端的请求。当客户端发送的数据到时服务器程序时，线程处理该请求。串行线程模型在同一时刻只能处理一个客户端请求，因此它只适用于比较简单的、客户端数量较少服务器程序。 2．并发线程模型 在并发线程模型中，服务器程