狠狠色噜噜狠狠狠狠狠色综合久久,久久综合亚洲色HEZYO国产,97精品伊人久久大香线蕉

IOCP的例子

以前在書上看過了IOCP，不過一直都沒有寫過代碼。現(xiàn)在寫的時(shí)候，著時(shí)對(duì)很多問題摸不著頭腦。不過好在CSDN上有許多的對(duì)于IOCP問題的討論帖，讓我受益非淺啊，也把心中的一些迷茫解開了，下面給出的是可以運(yùn)行的IOCP的C/S代碼，自已試了在一個(gè)機(jī)器上開了一百來個(gè)客戶端，跑起來暫時(shí)沒出現(xiàn)問題（因?yàn)橥ㄐ艃?nèi)容太簡單了^-^)。

IOCP的三個(gè)函數(shù)：CreateIoCompletionPort、GetQueuedCompletionStatus、PostQueuedCompletionStatus；一個(gè)是用來創(chuàng)建想要的IOCP的HANDLE同時(shí)也是用來把我們想要的SOCKET綁定到這個(gè)HANDLE上，一個(gè)是獲取IO這個(gè)HANDLE上對(duì)應(yīng)的對(duì)列的狀態(tài)，看有沒有事件完成，一個(gè)是用來通知所有工作線程退出（這個(gè)函數(shù)我還沒用到，關(guān)于這個(gè)功用是看資料上說的）。

我在寫這個(gè)代碼的時(shí)候，最主要的問題就是當(dāng)通信完成了之后，是怎么樣來判斷是哪個(gè)SOCKET的哪個(gè)狀態(tài)（SEND還是RECV）完成了。《WINDOWS網(wǎng)絡(luò)編程》這本書里給的代碼不是很全的哦，它的配套光盤又沒有，不過好在CSDN里CB那塊中有個(gè)朋友剛好帖出了這一章的代碼。通過比較和一夜的思量，算是搞明白啦。主要的就是以下的數(shù)據(jù)：

1、在第二次CreateIoCompletionPort中，會(huì)傳進(jìn)去一個(gè)CompletionKey，這個(gè)就是要來關(guān)聯(lián)到我們想要的SOCKET上的一些感興趣的數(shù)據(jù)內(nèi)容，當(dāng)然最好是要一個(gè)SOCKET，也可以是其它，看自己程序的需要了。而通過GetQueueCompletionStatus的通過，就可以獲得這些數(shù)據(jù)的地址了。

typedef struct _PER_HANDLE_DATA
{
SOCKET sock;
}PER_HANDLE_DATA,* LPPER_HANDLE_DATA;

2、第二個(gè)主要的數(shù)據(jù)結(jié)構(gòu)就是這個(gè)了，現(xiàn)在真的是佩服當(dāng)初設(shè)計(jì)這個(gè)結(jié)構(gòu)的人啊（沒辦法，自己就是沒想到這樣利用法）。因?yàn)樵赑OST操作（SEND或是RECV）是，都要一個(gè)OVERLAPPED，所以就把這個(gè)OVERLAPPED和要指明這次POST操作類型的代碼OperationType（POST_SEND或POST_RECV）以及其它一些數(shù)據(jù)（比如接發(fā)收的緩沖）。這樣子，在GetQueueCompletionStatus的時(shí)候，通過獲取事件，也同時(shí)得到了OperationType和緩沖。這樣，知道了通信類型，也得到了緩沖數(shù)據(jù)的緩沖區(qū)。這樣就可以控制我們的通信了。

這個(gè)例子比較簡單，沒有復(fù)雜的數(shù)據(jù)處理過程（正在設(shè)計(jì)中，和大家交流交流）。用的是BCB的平臺(tái)，不過寫法上還是和VC里的一模一樣的啊。

typedef struct _PER_IO_OPERATION_DATA
{
    OVERLAPPED Overlapped;
    WSABUF DataBuff[1];
    char Buff[24];
    BOOL OperationType;
}PER_IO_OPERATION_DATA,* LPPER_IO_OPERATION_DATA;

簡單的客戶端：

//---------------------------------------------------------------------------

#pragma hdrstop
#include <winsock2.h>
#include <stdio.h>
#include <iostream>
using namespace std;
//---------------------------------------------------------------------------

#pragma argsused

SOCKET sockClient;
struct sockaddr_in addrServer;
char buf[24];
int n = 0;
int Init();

int main(int argc, char* argv[])
{
if(Init() != 0)
goto theend;

    sockClient = socket(AF_INET,SOCK_STREAM,0);
    if(sockClient == INVALID_SOCKET)
    {
        cout<<"socket 失敗"<<endl;
        WSACleanup();
        goto theend;
    }
    memset(&addrServer,0,sizeof(sockaddr_in));
    addrServer.sin_family = AF_INET;
    addrServer.sin_addr.s_addr = inet_addr("127.0.0.1");
    addrServer.sin_port = htons(9090);
    cout<<"連接服務(wù)器..."<<endl;
    if(connect(sockClient,(const struct sockaddr *)&addrServer,sizeof(sockaddr)) != 0)
    {
        cout<<"connect 失敗"<<endl;
        WSACleanup();
        goto theend;
    }
    cout<<"開始發(fā)送測試包"<<endl;
    memset(buf,0,24);
    while(true)
    {
        sprintf(buf,"第%d個(gè)包", n);
        cout<<"發(fā)送："<<buf<<endl;
        if(send(sockClient,buf,strlen(buf),0) <= 0)
        {
            cout<<"send失敗,可能連接斷開"<<endl;
            //break;
            goto theend;
        }
        memset(buf,0,24);

        //接收服務(wù)端應(yīng)答
        if(recv(sockClient,buf,24,0) <= 0)
        {
            cout<<"recv失敗,可能連接斷開"<<endl;
           //break;
           goto theend;
        }
        cout<<"服務(wù)器應(yīng)答："<<buf<<endl;
        memset(buf,0,24);

        Sleep(200);
        n++;
    }

theend:
    WSACleanup();
    getchar();
    return 0;
}
//---------------------------------------------------------------------------
int Init()
{
    WSAData wsaData;
    if(WSAStartup(MAKEWORD(2,2),&wsaData) != 0)
    {
        cout<<"WSAStartup失敗"<<endl;
        return -1;
    }

    if(LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    {
        cout<<"SOCKET版本不對(duì)"<<endl;
        WSACleanup();
        return -1;
    }
    return 0;
}

服務(wù)端。

//---------------------------------------------------------------------------

#pragma hdrstop

//---------------------------------------------------------------------------
#pragma argsused
#pragma comment(lib,"ws2_32.lib")
#include <stdio.h>
#include <memory.h>
#include <winsock2.h>
#include <iostream>
using namespace std;

#define RECV_POSTED 1001
#define SEND_POSTED 1002

int Init();

HANDLE hCompletionPort;
typedef struct _PER_HANDLE_DATA
{
SOCKET sock;
}PER_HANDLE_DATA,* LPPER_HANDLE_DATA;

typedef struct _PER_IO_OPERATION_DATA
{
    OVERLAPPED Overlapped;
    WSABUF DataBuff[1];
    char Buff[24];
    BOOL OperationType;
}PER_IO_OPERATION_DATA,* LPPER_IO_OPERATION_DATA;

DWORD WINAPI ServerWorkerThread(LPVOID CompletionPort);

int main(int argc, char* argv[])
{
    LPPER_HANDLE_DATA perHandleData;
    LPPER_IO_OPERATION_DATA ioperdata;
    SYSTEM_INFO siSys;
    SOCKET sockListen;
    struct sockaddr_in addrLocal;
    char buf[24];
    int nRet = 0;
    DWORD nThreadID;
    SOCKET sockAccept;
    DWORD dwFlags;
    DWORD dwRecvBytes;
    int nReuseAddr = 1;

    cout<<"初始環(huán)境..."<<endl;
    if(Init() != 0)
        goto theend;

    //創(chuàng)建一個(gè)IO完成端口
    cout<<"創(chuàng)建一個(gè)IO完成端口"<<endl;
    hCompletionPort = CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,0,0);
    if(hCompletionPort == INVALID_HANDLE_VALUE)
    {
        cout<<"創(chuàng)建IO完成端口失敗"<<endl;
        goto theend;
    }
    //獲取CPU數(shù)目
    GetSystemInfo(&siSys);
    //創(chuàng)建一定數(shù)目的工作者線程，本例中以一個(gè)處理器一個(gè)線程搭配
    for(int i = 0;i<(int)siSys.dwNumberOfProcessors*2;i++)//NumberOfProcessors
    {
        HANDLE hThread;
        hThread = CreateThread(NULL,0,ServerWorkerThread,(LPVOID)hCompletionPort,0,&nThreadID);
        cout<<"創(chuàng)建工作者線程"<<i<<endl;
        CloseHandle(hThread);
    }
    //創(chuàng)建監(jiān)聽SOCKET
    cout<<"創(chuàng)建監(jiān)聽SOCKET"<<endl;
    sockListen = WSASocket(AF_INET,SOCK_STREAM,0,NULL,0,WSA_FLAG_OVERLAPPED);
    if(sockListen == SOCKET_ERROR)
    {
        cout<<"WSASocket錯(cuò)誤"<<endl;
        goto theend;
    }

    if(setsockopt(sockListen,SOL_SOCKET,SO_REUSEADDR,(const char *)&nReuseAddr,sizeof(int)) != 0)
    {
        cout<<"setsockopt錯(cuò)誤"<<endl;
        goto theend;
    }
    addrLocal.sin_family = AF_INET;
    addrLocal.sin_addr.s_addr = htonl(INADDR_ANY);
    addrLocal.sin_port = htons(9090);
    if(bind(sockListen,(struct sockaddr *)&addrLocal,sizeof(sockaddr_in)) != 0)
    {
        cout<<"bind錯(cuò)誤"<<endl;
        int n = WSAGetLastError();
        goto theend;
    }
    //準(zhǔn)備監(jiān)聽
    cout<<"準(zhǔn)備監(jiān)聽"<<endl;
    if(listen(sockListen,5)!=0)
    {
        cout<<"listen錯(cuò)誤"<<endl;
        goto theend;
    }
    while(true)
    {
        //接收用戶連接，被和完成端口關(guān)聯(lián)
        sockAccept = WSAAccept(sockListen,NULL,NULL,NULL,0);
        perHandleData = (LPPER_HANDLE_DATA)malloc(sizeof(PER_HANDLE_DATA));
        if(perHandleData == NULL)
            continue;
        cout<<"socket number "<<sockAccept<<"接入"<<endl;
        perHandleData->sock = sockAccept;

        ioperdata = (LPPER_IO_OPERATION_DATA)malloc(sizeof(PER_IO_OPERATION_DATA));
        memset(&(ioperdata->Overlapped),0,sizeof(OVERLAPPED));
        (ioperdata->DataBuff[0]).len = 24;
        (ioperdata->DataBuff[0]).buf = ioperdata->Buff;
        ioperdata->OperationType = RECV_POSTED;
        if( ioperdata == NULL)
        {
            free(perHandleData);
            continue;
        }
        //關(guān)聯(lián)
        cout<<"關(guān)聯(lián)SOCKET和完成端口"<<endl;
        if(CreateIoCompletionPort((HANDLE)sockAccept,hCompletionPort,(DWORD)perHandleData,1) == NULL)
        {
            cout<<sockAccept<<"createiocompletionport錯(cuò)誤"<<endl;
            free(perHandleData);
            free(ioperdata);
            continue;
        }
        //投遞接收操作
        cout<<"投遞接收操作"<<endl;
        WSARecv(perHandleData->sock,ioperdata->DataBuff,1,&dwRecvBytes,&dwFlags,&(ioperdata->Overlapped),NULL);
    }
theend:
    getchar();
    return 0;
}
//---------------------------------------------------------------------------
int Init()
{
    WSAData wsaData;
    if(WSAStartup(MAKEWORD(2,2),&wsaData) != 0)
    {
        cout<<"WSAStartup失敗"<<endl;
        return -1;
    }

    if(LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
    {
        cout<<"SOCKET版本不對(duì)"<<endl;
        WSACleanup();
        return -1;
    }
    return 0;
}

DWORD WINAPI ServerWorkerThread(LPVOID CompletionPort)
{
    HANDLE ComPort = (HANDLE)CompletionPort;
    DWORD BytesTransferred;
    LPOVERLAPPED Overlapped;
    LPPER_HANDLE_DATA PerHandleData;
    LPPER_IO_OPERATION_DATA PerIoData;
    DWORD SendBytes,RecvBytes;
    DWORD Flags;
    BOOL bT;

    while(TRUE)
    {
        //等待完成端口上SOCKET的完成
        cout<<"等待完成端口上SOCKET的完成"<<endl;
        bT = GetQueuedCompletionStatus(ComPort,
            &BytesTransferred,(LPDWORD)&PerHandleData,
            (LPOVERLAPPED *)&PerIoData,INFINITE);

        //檢查是否有錯(cuò)誤產(chǎn)生
        if(BytesTransferred == 0 &&
            (PerIoData->OperationType == RECV_POSTED ||
            PerIoData->OperationType == SEND_POSTED))
        {
            //關(guān)閉SOCKET
            cout<<PerHandleData->sock<<"SOCKET關(guān)閉"<<endl;
            closesocket(PerHandleData->sock);
            free(PerHandleData);
            free(PerIoData);
            continue;
        }

        //為請(qǐng)求服務(wù)

        if(PerIoData->OperationType == RECV_POSTED)
        {
            //處理
            cout<<"接收處理"<<endl;
            cout<<PerHandleData->sock<<"SOCKET :"<<PerIoData->Buff<<endl;
            //回應(yīng)客戶端
            ZeroMemory(PerIoData->Buff,24);
            strcpy(PerIoData->Buff,"OK");
            Flags = 0;
            ZeroMemory((LPVOID)&(PerIoData->Overlapped),sizeof(OVERLAPPED));
            PerIoData->DataBuff[0].len = 2;
            PerIoData->DataBuff[0].buf = PerIoData->Buff;
            PerIoData->OperationType = SEND_POSTED;
            WSASend(PerHandleData->sock,PerIoData->DataBuff,
                1,&SendBytes,0,&(PerIoData->Overlapped),NULL);
        }
        else //if(PerIoData->OperationType == SEND_POSTED)
        {
            //發(fā)送時(shí)的處理
            cout<<"發(fā)送處理"<<endl;
            Flags = 0;
            ZeroMemory((LPVOID)&(PerIoData->Overlapped),sizeof(OVERLAPPED));
            ZeroMemory(PerIoData->Buff,24);
            PerIoData->DataBuff[0].len = 24;
            PerIoData->DataBuff[0].buf = PerIoData->Buff;
            PerIoData->OperationType = RECV_POSTED;
            WSARecv(PerHandleData->sock,PerIoData->DataBuff,
                1,&RecvBytes,&Flags,&(PerIoData->Overlapped),NULL);
        }
    }
}

posted on 2007-08-17 11:55 聶文龍閱讀(14550) 評(píng)論(7) 編輯收藏引用所屬分類: net work

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: 如何成為盛大的尊貴帳號(hào)“白金賬號(hào)” 百分之百解決ARP欺騙、聚生網(wǎng)管、P2P終結(jié)者導(dǎo)致頻繁掉線不能上網(wǎng)的問題 ARP防范理解I/O Completion Port 細(xì)說WinSock IOCP Linux環(huán)境下的Socket編程 Linux 下Socket編程基礎(chǔ) 完成端口模型代碼 SPI Multicasting

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

常用鏈接

留言簿(34)

隨筆分類

隨筆檔案

文章檔案

相冊(cè)

收藏夾

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜