vc++应用书籍包_4资源-CSDN文库

共6个文件

rar：3个

doc：2个

pdf：1个

VC++

电子书

IOCP

需积分: 10 61 浏览量 2012-09-17 11:29:03 上传评论收藏 58.26MB RAR 举报

资源详情

资源评论

收起资源包目录

vc++ 应用书籍包_4.rar （6个子文件）

vc++ 应用书籍包_4

IOCP完成端口详解.doc 56KB

COM原理及应用.rar 56.53MB

DOS常用命令宝典(让你成为DOS高手)_程序设.rar 898KB

IOCP完全解析.pdf 268KB

C语言技术文章_程序设计内存管理.rar 516KB

DirectShow编程技术资料（技术公司内部资料）.doc 246KB

#pragma comment(lib,"ws2_32.lib")

从本质上说，完成端口模型要求创建一个 windows 完成端口对象，该对象通过指定数量的线程，对重叠 I/O 请求进

行管理，以便为已经完成的重叠 I/O 请求提供服务。

首先要创建一个 I/O 完成端口对象，用它面向任意数量的套接字句柄，管理多个 I/O 请求。调用以下函数创建

完成端口对象：

HANDLE CreateIoCompletionPort(

HANDLE FileHandle,// 同 IOCP 关联在一起的套接字句柄

HANDLE ExistingCompletionPort,// IOCP 句柄

ULONG_PTR CompletionKey, // 完成健

DWORD NumberOfConcurrentThreads // 在 IOCP 上，同时允许执行的线程数量

);

该函数有两个作用：

（1）创建一个完成端口对象

（2）将一个句柄同完成端口关联到一起

然后就要创建一定数量的工作者线程，以便在套接字的 I/O 请求投递给完成端口后，为完成端口提供服务。写

文字描述很烦，还是看代码吧：

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

#include "stdafx.h"

#include "NetServer3.h"

#include <winsock2.h>

#pragma comment(lib, "ws2_32.lib")

#include <iostream>

using namespace std;

/**///////////////////////////////////////////////////////////////////////////

#ifdef _DEBUG

#define new DEBUG_NEW

#undef THIS_FILE

static char THIS_FILE[] = __FILE__;

#endif

/**///////////////////////////////////////////////////////////////////////////

// 单句柄数据

typedef struct tagPER_HANDLE_DATA

{

SOCKET Socket;

SOCKADDR_STORAGE ClientAddr;

// 将和这个句柄关联的其他有用信息，尽管放在这里面吧

}PER_HANDLE_DATA, *LPPER_HANDLE_DATA;

// 但 I/O 操作数据

typedef struct tagPER_IO_DATA

{

OVERLAPPED Overlapped;

WSABUF DataBuf;

char buffer[1024];

int BufferLen;

int OperationType; // 可以作为读写的标志，为简单，我忽略了

}PER_IO_DATA, *LPPER_IO_DATA;

DWORD WINAPI ServerWorkerThread(LPVOID lpParam);

/**//////////////////////////////////////////////////////////////////////////////

// The one and only application object

CWinApp theApp;

using namespace std;

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])

{

int nRetCode = 0;

// initialize MFC and print and error on failure

if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))

{

// TODO: change error code to suit your needs

cerr << _T("Fatal Error: MFC initialization failed") << endl;

nRetCode = 1;

}

else

{

// TODO: code your application's behavior here.

CString strHello;

strHello.LoadString(IDS_HELLO);

cout << (LPCTSTR)strHello << endl;

}

/**///////////////////////////////////////////////////////////////////////////

HANDLE CompletionPort;

WSADATA wsd;

SYSTEM_INFO SystemInfo;

SOCKADDR_IN InternetAddr;

SOCKET Listen;

// 加载 WinSock2.2

WSAStartup(MAKEWORD(2, 2), &wsd);

// 1.创建一个 I/O 完成端口

CompletionPort = CreateIoCompletionPort(INVALID_HANDLE_VALUE,

NULL,

0);

// 2.确定系统中有多少个处理器

GetSystemInfo(&SystemInfo);

// 3.基于系统中可用的处理器数量创建工作器线程

for (int i = 0; i < SystemInfo.dwNumberOfProcessors * 2; ++i)

{

HANDLE ThreadHandle;

// 创建一个服务器的工作器线程，并将完成端口传递到该线程

ThreadHandle = CreateThread(NULL,

ServerWorkerThread,

CompletionPort,

NULL);

CloseHandle(ThreadHandle);

}

// 4.创建一个监听套接字，以下的套路都是固定的。

Listen = WSASocket(AF_INET,

SOCK_STREAM,

NULL,

WSA_FLAG_OVERLAPPED);

InternetAddr.sin_family = PF_INET;

InternetAddr.sin_port = htons(5000);

InternetAddr.sin_addr.s_addr = htonl(INADDR_ANY);

bind(Listen, (SOCKADDR*)&InternetAddr, sizeof(InternetAddr));

listen(Listen, 5);

BOOL b = TRUE;

while (b)

{

PER_HANDLE_DATA * PerHandleData = NULL;

SOCKADDR_IN saRemote;

SOCKET Accept;

int RemoteLen;

// 5.接收连接，并分配完成端口，这儿可以用 AcceptEx 来代替，以创

// 建可伸缩的 Winsock 应用程序。

RemoteLen = sizeof(saRemote);

Accept = accept(Listen, (SOCKADDR*)&saRemote, &RemoteLen);

// 6.创建用来和套接字关联的单句柄数据信息结构

PerHandleData = (LPPER_HANDLE_DATA)GlobalAlloc(GPTR,

sizeof(PER_HANDLE_DATA));

cout << "Socket number " << Accept << " connected" << endl;

PerHandleData->Socket = Accept;

memcpy(&PerHandleData->ClientAddr, &saRemote, RemoteLen);

// 7.将接受套接字和完成端口关联起来

CreateIoCompletionPort((HANDLE)Accept,

CompletionPort,

(DWORD)PerHandleData,

0);

// 开始在接受套接字上处理 I/O

// 使用重叠 I/O 机制，在新建的套接字上投递一个或多个异步

// WSARecv 或 WSASend 请求。这些 I/O 请求完成后，工作者线程

// 会为 I/O 请求提供服务，之后就可以坐享其成了

static int const DATA_BUFSIZE = 4096; //

DWORD RecvBytes = 0;

DWORD Flags = 0;

// 单 I/O 操作数据

LPPER_IO_DATA PerIoData = NULL;

PerIoData = (LPPER_IO_DATA)GlobalAlloc(GPTR, sizeof(PER_IO_DATA));

ZeroMemory(&(PerIoData->Overlapped), sizeof(OVERLAPPED));

PerIoData->DataBuf.len = 1024;

PerIoData->DataBuf.buf = PerIoData->buffer;

PerIoData->OperationType = 0; // read

WSARecv(PerHandleData->Socket,

&(PerIoData->DataBuf),

&RecvBytes,

&Flags,

&(PerIoData->Overlapped),

NULL);

}

/**///////////////////////////////////////////////////////////////////////////

return nRetCode;

}

/**///////////////////////////////////////////////////////////////////////////

DWORD WINAPI ServerWorkerThread(LPVOID lpParam)

{

HANDLE CompletionPort = (HANDLE)lpParam;

DWORD BytesTransferred;

LPOVERLAPPED lpOverlapped;

LPPER_HANDLE_DATA PerHandleData = NULL;

LPPER_IO_DATA PerIoData = NULL;

DWORD SendBytes;

DWORD RecvBytes;

DWORD Flags;

BOOL bRet = FALSE;

while (TRUE)

{

bRet = GetQueuedCompletionStatus(CompletionPort,

&BytesTransferred,

(PULONG_PTR)

&PerHandleData,

评论收藏

内容反馈

vc++ 应用书籍包_4

评论0

最新资源

vc++ 应用书籍包_4

评论0

最新资源

相关推荐

c，c++书籍

c++书籍

vc++ 应用书籍包_21

vc++ 应用书籍包_6

vc++ 应用书籍包_1

vc++ 应用书籍包_22

c和c++的书籍

vc++ 应用书籍包_7

vc++ 应用书籍包_15

vc++ 应用书籍包_16

vc++ 应用书籍包_3

vc++ 应用书籍包_20

vc++ 应用书籍包_10

vc++ 应用书籍包_18

vc++ 应用书籍包_13

vc++ 应用书籍包_11

vc++ 应用书籍包_8

vc++ 应用书籍包_12

vc++ 应用书籍包_19

vc++ 应用书籍包_24

vc++ 应用书籍包_23

vc++ 应用源码包_3

Qt上位机软件串口通讯，视频源码，免费下载

代码随想录算法PDF.rar

张玉生《C语言程序设计》双色版 C语言程序设计理论教材习题参考答案.pdf