青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

S.l.e!ep.¢%

像打了激速一樣,以四倍的速度運轉,開心的工作
簡單、開放、平等的公司文化;尊重個性、自由與個人價值;
posts - 1098, comments - 335, trackbacks - 0, articles - 1
  C++博客 :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理
IOCP的一個簡單封裝類(zz)
#pragma once
?
#include <winsock2.h>
#pragma comment( lib, "ws2_32.lib" )
?
const int OP_READ = 0;
const int OP_WRITE = 1;
const int OP_ACCEPT = 2;
?
/*
???? OVERLAPPEDPLUS 結構體設計思路
???? OVERLAPPED 是一個固定的用于處理網絡消息事件返回值的結構體變量
???? 在完成端口和重疊I/O模型里用于返回消息事件的結果
???? 因為在處理網絡消息的時候,發送的是一個返回值的結構體指針,只要結構體
???? 的前面部分滿足系統的要求,在系統操作成功的時候也就會把這個結構體指針
???? 發回給用戶,我們只要在系統定義的結構體后面擴展一些自己的東西,就可以
???? 很輕松的確定該消息是誰發過來的。
???? 不過好像完成端口在設計的時候也滿足了這樣的需求,所以在這里我只是放入
???? 一些與系統連接有關的數據,用戶需要存放的數據這里就不在存放
???? 這里存儲與系統相關的數據有:
???? socket
???? OpCode 本次消息的操作類型(在完成端口的操作里面,是以消息通知系統,
???????? 讀數據/寫數據,都是要發這樣的消息結構體過去的,所以如果系統要同時
???????? 進行讀寫操作的話,就需要有一個變量來區分操作了)
?
???? WSABUF?? wbuf;????????????????? //?? 讀寫緩沖區結構體變量
???? DWORD??? dwBytes, dwFlags;?//?? 一些在讀寫時用到的標志性變量
???? char buf[4096];????????????????? //?? 自己的緩沖區
???? 上面的4個變量存放的是一些與消息相關的數據,都是一些操作上用到的,
???? 這些東西都是固定的,具體作用需要參考一下完成端口相關函數的參數接口
*/
struct OVERLAPPEDPLUS
{
???? OVERLAPPED??? ol;
???? SOCKET??????? s;
???? int OpCode;
???? WSABUF?? wbuf;
???? DWORD??? dwBytes, dwFlags;
???? char buf[4096];
};
?
class CIOCP
{
protected :
???? HANDLE g_hwThread;???? //?? 工作線程句柄
???? DWORD?m_wthreadID;
???? HANDLE g_haThread;???? //?? 連接線程句柄
???? DWORD?m_athreadID;
public :
???? bool m_workThread;
???? bool m_acceptThread;
???? HANDLE m_hIocp;???????????? //?? 完成端口的句柄
???? SOCKET m_sSocket;
????
public :
???? CIOCP(void);
???? ~CIOCP(void);
???? virtualvoid OnRead(void * p, char *buf, int len){};
???? virtualvoid OnAccept(SOCKET socket);
???? virtualvoid OnClose(void * p){};
???? bool SetIoCompletionPort(SOCKET socket, void *p, char *buf = NULL, int len = 0);
???????? //?? 把一個socket與一個自定義的結構體關聯到完成端口(相當于把socket與一個結構體變量進行綁定),
???????? //?? 這樣當發送上面3種網絡事件的時候,該結構體變量會再傳回給程序
???????? //?? 這樣就可以區分當前網絡事件是那個socket發出的
???? bool Init(void);
???? bool Listen(int port);
???? static DWORD __stdcall WorkThread(LPVOID Param);
???? static DWORD __stdcall AcceptThread(LPVOID Param);
};
?
?
?
?
?
?
class CIOCPClient: public CIOCP
{
protected :
???? SOCKET m_socket;
public :
???? bool Connect(char *ip, int port);
???? void Send(char *buf, int len);
};
?
?
?
?
?
?
//////////////////////////////////////////////////////////////////////////////////////////
//?? Iocp 實現文件
?
#include "StdAfx.h"
#include "iocp.h"
?
static bool bInit = false;
?
DWORD __stdcall CIOCP::WorkThread(LPVOID Param)
{
???? CIOCP * pthis = (CIOCP *)Param;
?
???? void * re;
???? OVERLAPPED * pOverlap;
???? DWORD berByte;
???? while(pthis->m_workThread)
???? {
???????? int ret;
???????? ret = GetQueuedCompletionStatus(pthis->m_hIocp, &berByte, (LPDWORD)&re, (LPOVERLAPPED *)&pOverlap, INFINITE);
?
???????? if (ret == ERROR_SUCCESS)
???????? {
?
???????? }
?
???????? if (berByte == 0)
???????? {
????????????? //?? 客戶端斷開連接
????????????? pthis->OnClose(re);
????????????? OVERLAPPEDPLUS *olp = (OVERLAPPEDPLUS *)pOverlap;
????????????? closesocket(olp->s);
????????????? delete olp;??????? //?? 釋放 與socket綁定的結構體變量
????????????? continue;
???????? }
?
???????? if (re == NULL) return 0;
?
???????? OVERLAPPEDPLUS *olp = (OVERLAPPEDPLUS *)pOverlap;
?
???????? switch(olp->OpCode)
???????? {
???????? case OP_READ:
????????????? pthis->OnRead(re, olp->wbuf.buf, berByte);???? //?? 調用 OnRead() 通知應用程序,服務器收到來自客戶端的網絡數據
????????????? WSARecv(olp->s, &olp->wbuf, 1, &olp->dwBytes, &olp->dwFlags, &olp->ol, NULL);?//?? 繼續調用一個接收的 I/O 異步請求
????????????? break;
???????? default:
????????????? break;
???????? }
???? }
???? return 0;
}
?
DWORD __stdcall CIOCP::AcceptThread(LPVOID Param)
{
???? CIOCP * pthis = (CIOCP *)Param;
???? while(pthis->m_acceptThread)
???? {
???????? SOCKET client;
???????? if ((client= accept(pthis->m_sSocket, NULL, NULL)) == INVALID_SOCKET)
???????? {
????????????? //?? 錯誤處理
???????? }
???????? pthis->OnAccept(client);??? //?? 調用 OnAccept()通知應用程序有新客戶端連接
????????
???? }
???? return 1;
}
?
CIOCP::CIOCP(void)
{
}
?
CIOCP::~CIOCP(void)
{
}
?
bool CIOCP::Init(void)
{
???? if (bInit)
???????? returntrue;
?
???? WSADATA wsd;
???? if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
???????? returnfalse;
?
???? bInit = true;
???? returntrue;
}
?
bool CIOCP::Listen(int port)
{
???? if (!bInit)
???????? if (!Init())
????????????? returnfalse;
?
???? m_sSocket = socket(AF_INET, SOCK_STREAM, 0);
?
???? if (m_sSocket == INVALID_SOCKET)
???????? returnfalse;
?
???? //SOCKADDR_IN addr;
???? sockaddr_in addr;
???? addr.sin_family = AF_INET;
???? addr.sin_port = htons(port);
???? addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
???? //addr.sin_addr.S_un.S_addr = inet_addr(ip);
?
???? if (bind(m_sSocket, (struct sockaddr *)&addr, sizeof(addr)) == SOCKET_ERROR)
???????? returnfalse;
?
???? if (listen(m_sSocket, 10) == SOCKET_ERROR)
???????? returnfalse;
?
???? if ((m_hIocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, NULL, 0)) == NULL)???? //?? 創建完成端口的句柄
???????? returnfalse;
?
???? this->m_acceptThread = true;
???? g_haThread = CreateThread(NULL, 0, AcceptThread, (LPVOID)this, 0, &m_athreadID);??? //?? 創建連接線程,用來接收客戶端的連接
?
???? this->m_workThread = true;
???? g_hwThread = CreateThread(NULL, 0, WorkThread, (LPVOID)this, 0, &m_wthreadID); //?? 創建工作線程,用來處理完成端口消息的
???? returntrue;
}
?
bool CIOCP::SetIoCompletionPort(SOCKET socket, void *p, char *buf, int len)
{
???? if (CreateIoCompletionPort((HANDLE)socket, m_hIocp, (ULONG_PTR)p, 0) == NULL)
???????? returnfalse;
?
???? OVERLAPPEDPLUS *olp = new OVERLAPPEDPLUS;
???? memset(olp, 0, sizeof(OVERLAPPEDPLUS));
???? olp->s = socket;
???? if (buf)
???? {
???????? //?? 這里可以使用用戶自定義的緩沖區地址,如果用戶不想設置,也可以采用默認分配的緩沖區
???????? olp->wbuf.buf = buf;
???????? olp->wbuf.len = len;
???? }
???? else
???? {
???????? olp->wbuf.buf = olp->buf;
???????? olp->wbuf.len = 4096;
???? }
???? olp->OpCode = OP_READ;
???? int ret = WSARecv(olp->s, &olp->wbuf, 1, &olp->dwBytes, &olp->dwFlags, &olp->ol, NULL);
???? if (ret == SOCKET_ERROR)
???????? if (WSAGetLastError() != ERROR_IO_PENDING)
????????????? returnfalse;
???? returntrue;
}
?
void CIOCP::OnAccept(SOCKET socket)
{
???? this->SetIoCompletionPort(socket, NULL);
}
?
//===================================================================================
?
?
?
?
?
?
bool CIOCPClient::Connect(char *ip, int port)
{
???????? //?? 連接服務器
???? if (!bInit)
???????? if (!Init())
????????????? returnfalse;
?
???? //?? 初始化連接socket
???? m_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
???? if (m_socket == SOCKET_ERROR)
???? {
//?????? printf("cocket Create fail");
???????? returnfalse;
???? }
?
???? // 填寫服務器地址信息
???? // 端口為1982
???? // IP 地址為INADDR_ANY,注意使用htonl將IP地址轉換為網絡格式ServerAddr.sin_family = AF_INET;
???? sockaddr_in ClientAddr;
???? ClientAddr.sin_family = AF_INET;
???? ClientAddr.sin_port = htons(port);???
???? ClientAddr.sin_addr.s_addr = inet_addr(ip);
?
???? // 綁定監聽端口
???? bind(m_socket, (SOCKADDR *)&ClientAddr, sizeof(ClientAddr));
?
???? if (connect(m_socket, (SOCKADDR *)&ClientAddr, sizeof(ClientAddr)) == SOCKET_ERROR)
???? {
???????? returnfalse;
???? }
????
???? if ((m_hIocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, NULL, 0)) == NULL)???? //?? 創建完成端口的句柄
???????? returnfalse;
?
???? this->m_workThread = true;
???? g_hwThread = CreateThread(NULL, 0, WorkThread, (LPVOID)this, 0, &m_wthreadID); //?? 創建工作線程,用來處理完成端口消息的
?
???? this->SetIoCompletionPort(m_socket, &m_socket);??? //?? 設置完成端口監聽的socket
???? returntrue;
}
?
void CIOCPClient::Send(char *buf, int len)
{
???? send(m_socket, buf, len, 0);
}
?
?
?
?
?
?
?
?
?
///////////////////////////////////////////////////////////////////////////////////
// IOCPclient 應用代碼
?
#include "stdafx.h"
#include "IOCP.h"
#include "TClientSocket.h"
class Iocp :public CIOCPClient
{
???? ?void OnRead(void * p, char *buf, int len)
???? ?{
???????? ?printf(buf);
???????? ?Sleep(1000);
???????? ?this->Send(buf, len);
文件:IOCP的簡單類封裝_源文件.rar
大小:3KB
下載:下載
文件: IOCP的簡單應用實例.rar
大小: 318KB
下載: 下載
???? ?}
};
?
int _tmain(int argc, _TCHAR* argv[])
{
???? Iocp iocp;
???? iocp.Init();
???? iocp.Connect("127.0.0.1", 4311);
???? iocp.Send("test\0", 5);
????
???? gets(newchar[1000]);
???? return 0;
}

發表于: 2007-03-26,修改于: 2007-03-26 16:27,已瀏覽959次,有評論0條 推薦 投訴

Feedback

# re: IOCP的一個簡單封裝類(zz) [轉]  回復  更多評論   

2014-07-05 11:11 by dsa
例子不能運行
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            亚洲精品免费一二三区| 欧美日韩成人一区| 国产一区二区成人| 久久久久久久精| 久久综合伊人77777尤物| 亚洲精选91| 一本高清dvd不卡在线观看| 欧美天堂亚洲电影院在线观看| 亚洲深夜av| 午夜视频一区在线观看| 亚洲高清视频在线观看| 亚洲精品偷拍| 国产在线精品一区二区中文| 欧美刺激性大交免费视频| 欧美精品自拍| 久久精品国产96久久久香蕉| 欧美在线你懂的| 久久亚洲综合色| 亚洲视频碰碰| 久久婷婷av| 亚洲综合成人婷婷小说| 久久九九精品99国产精品| 亚洲美女福利视频网站| 午夜精品www| 亚洲毛片一区| 欧美一区二区福利在线| 亚洲精品中文在线| 小嫩嫩精品导航| 9人人澡人人爽人人精品| 午夜免费日韩视频| 一区二区三区蜜桃网| 久久久久久久一区二区| 亚洲欧美日韩精品综合在线观看| 久久久噜噜噜久久狠狠50岁| 亚洲在线视频| 欧美黑人在线播放| 麻豆freexxxx性91精品| 久久久久久久999| 亚洲欧美资源在线| 欧美—级高清免费播放| 久久影音先锋| 国产精品无码专区在线观看| 亚洲肉体裸体xxxx137| 黄色另类av| 午夜精品福利电影| 欧美一区二区日韩| 欧美色视频一区| 亚洲精品免费在线播放| 亚洲国产另类久久久精品极度| 欧美一区影院| 久久精品青青大伊人av| 狠狠色丁香久久综合频道| 国产精品99久久久久久宅男| 亚洲精品一区中文| 另类亚洲自拍| 欧美99久久| 尤物在线精品| 久久亚洲精品欧美| 美女脱光内衣内裤视频久久网站| 国产在线不卡| 久久九九久精品国产免费直播| 久久久久国产精品人| 国产欧美日韩视频在线观看| 亚洲欧美日韩精品综合在线观看| 亚洲欧美日韩直播| 国产日韩精品视频一区二区三区| 亚洲欧美日韩视频二区| 久久精品夜色噜噜亚洲a∨| 国产一区在线看| 久久久999成人| 你懂的视频欧美| 最新日韩中文字幕| 欧美日韩综合网| 亚洲在线不卡| 久久久视频精品| 亚洲国产欧美在线| 欧美屁股在线| 亚洲欧美激情视频| 久久久夜夜夜| 99国产精品99久久久久久| 欧美私人网站| 久久成人国产精品| 欧美激情第一页xxx| 亚洲午夜激情网站| 国产一区二区丝袜高跟鞋图片 | 性久久久久久| 狠狠久久五月精品中文字幕| 久久亚洲私人国产精品va| 亚洲欧洲一区二区天堂久久| 亚洲一级片在线观看| 狠狠干成人综合网| 欧美日韩1234| 久久国产精品久久久久久久久久| 欧美成人午夜影院| 亚洲综合欧美| 在线免费观看视频一区| 欧美体内谢she精2性欧美| 欧美在线视频导航| 亚洲精品乱码久久久久久| 久久爱另类一区二区小说| 亚洲精品乱码久久久久久久久| 国产精品多人| 麻豆freexxxx性91精品| 亚洲一区二区av电影| 欧美成人69av| 欧美在线精品一区| 一本色道久久综合| **网站欧美大片在线观看| 国产精品九色蝌蚪自拍| 欧美成人嫩草网站| 久久久国产精品一区二区中文| 一区二区三区欧美成人| 欧美激情一区二区三区在线| 欧美在线短视频| 9人人澡人人爽人人精品| 在线成人中文字幕| 国产日韩欧美不卡在线| 欧美午夜一区二区| 欧美成人三级在线| 久久综合电影| 久久精品99| 亚洲国产毛片完整版| 在线观看91精品国产入口| 国产精品入口麻豆原神| 欧美精品免费视频| 美女成人午夜| 久久久中精品2020中文| 欧美一区中文字幕| 亚洲欧美制服另类日韩| 亚洲欧美另类国产| 一区二区三区精品视频在线观看| 91久久国产综合久久蜜月精品 | 欧美亚洲一区二区在线| 亚洲桃花岛网站| 一区二区不卡在线视频 午夜欧美不卡在| 一区二区三区在线高清| 黄色成人小视频| 在线成人av.com| 影音先锋久久资源网| 激情久久婷婷| 在线精品视频免费观看| 亚洲大片av| 亚洲人成欧美中文字幕| 亚洲日本一区二区| 99热免费精品在线观看| 亚洲天堂成人在线视频| 亚洲与欧洲av电影| 欧美一级电影久久| 久久九九国产精品怡红院| 久久免费视频在线| 欧美高清在线一区| 亚洲日本va午夜在线电影| 日韩天堂在线视频| 亚洲天堂av在线免费| 欧美亚洲一区二区三区| 久久久精品免费视频| 欧美成人精品在线播放| 欧美日韩国产影院| 国产伦精品一区二区三区| 国产私拍一区| 亚洲国产精品ⅴa在线观看| 日韩午夜激情| 欧美在现视频| 欧美电影免费观看大全| 9色国产精品| 久久久久**毛片大全| 欧美刺激性大交免费视频| 欧美性感一类影片在线播放| 国产日韩亚洲| 亚洲精品一区二区三区不| 亚洲男人天堂2024| 免费黄网站欧美| 99精品国产在热久久| 欧美怡红院视频一区二区三区| 欧美成人精品三级在线观看| 国产精品va在线| 亚洲二区在线观看| 性欧美大战久久久久久久久| 欧美fxxxxxx另类| 亚洲视频一区二区免费在线观看| 欧美在线日韩精品| 欧美日韩蜜桃| 在线欧美三区| 久久成人国产精品| 亚洲美女少妇无套啪啪呻吟| 久久久久久尹人网香蕉| 国产精品久久999| 最近中文字幕mv在线一区二区三区四区| 亚洲一区激情| 亚洲黄色尤物视频| 久久久999| 国产日韩欧美一区二区| 亚洲天堂av图片| 欧美黑人多人双交| 久久成人精品| 国产欧美日韩视频一区二区| 亚洲一区二区视频在线| 亚洲经典三级| 美女图片一区二区| 国产在线乱码一区二区三区|