一本色道久久99精品综合,亚洲调教视频在线观看,欧美激情一区二区三区成人

Micro-Development-Kit 學(xué)習(xí)記錄 mdk 高性能網(wǎng)絡(luò)庫

庫地址：

https://github.com/huoyu820125/Micro-Development-Kit

=========================

ST**表示單線程

//開始監(jiān)聽

bool Start( int nMaxMonitor );

//增加一個(gè)監(jiān)聽對象

bool AddMonitor( SOCKET socket );

//等待事件發(fā)生,block無作用

bool WaitEvent( void *eventArray, int &count, bool block );

//增加一個(gè)接受連接的操作，有連接進(jìn)來，WaitEvent會返回

bool AddAccept(SOCKET listenSocket);

//增加一個(gè)接收數(shù)據(jù)的操作，有數(shù)據(jù)到達(dá)，WaitEvent會返回

bool AddRecv( SOCKET socket, char* recvBuf, unsigned short bufSize );

//增加一個(gè)發(fā)送數(shù)據(jù)的操作，發(fā)送完成，WaitEvent會返回

bool AddSend( SOCKET socket, char* dataBuf, unsigned short dataSize );

抽象控制的api

監(jiān)聽套接字對象的方法，

IOCPMonitor

==========================

typedef struct IO_EVENT

{

SOCKET sock;

EventType type;

SOCKET client;

char *pData;

unsigned short uDataSize;

}IO_EVENT;

MemoryPool m_iocpDataPool;//iocp投遞參數(shù)池

typedef struct IOCP_OVERLAPPED

{

/**

* OVERLAPPED類型指針

* 指向完成操作參數(shù)

* 傳遞給AcceptEx()的最后一個(gè)參數(shù)

* 傳遞給WSARecv()的第個(gè)參數(shù)

* GetQueuedCompletionStatus()返回的第個(gè)參數(shù)

OVERLAPPED m_overlapped;

/**

* 指向存有連接進(jìn)來的客戶端局域網(wǎng)和外網(wǎng)地址的內(nèi)存

* 必須使用動態(tài)分配的內(nèi)存塊

* 傳遞給AcceptEx()的第個(gè)參數(shù)

char m_outPutBuf[sizeof(SOCKADDR_IN)*2+32];

/**

* 客戶端局域網(wǎng)IP信息長度

* 傳遞給AcceptEx()的第個(gè)參數(shù)

unsigned long m_dwLocalAddressLength;

/**

* 客戶端外網(wǎng)IP信息長度

* 傳遞給AcceptEx()的第個(gè)參數(shù)

unsigned long m_dwRemoteAddressLength;

WSABUF m_wsaBuffer;//WSARecv接收緩沖數(shù)據(jù),傳遞給WSARecv()的第個(gè)參數(shù)

SOCKET sock;

EventType completiontype;//完成類型recv 2send

}IOCP_OVERLAPPED;

IOCPMonitor::Start( int nMaxMonitor )

端口啟動

創(chuàng)建完全端口

線程數(shù)cpu數(shù)*2+2

IOCPMonitor::AddMonitor( SOCKET sock )

加入套接字到 IOCP列隊(duì)

IOCPMonitor::WaitEvent( void *eventArray, int &count, bool block )

等待一次完全端口的事件

GetQueuedCompletionStatus( )

返回不同的iocp事件類型或數(shù)據(jù) 供上層循環(huán)控制

IOCPFrame : public NetEngine

繼承了 netengine 的通用和抽象的方法，

同時(shí)針對不同的os平臺實(shí)例化不同的網(wǎng)絡(luò)模型

IOCPFrame::IOCPFrame()

{

#ifdef WIN32

m_pNetMonitor = new IOCPMonitor;

#endif

IOCPFrame 控制監(jiān)聽接收發(fā)送，集成 NetEngine 抽象

Child： one new IOCPMonitor;

class NetServer

{

friend class NetEngine;

NetEngine* m_pNetCard;

Netserver為主要控制對象，里面抽象了邏輯的控制的函數(shù)，可以繼承城市

同時(shí) NetServer 和 NetEngine 是friend class

NetEngine 里面有監(jiān)聽過程中的一些寫業(yè)務(wù)的邏輯調(diào)用到 Netserver，幾個(gè)抽象的業(yè)務(wù) 接口實(shí)現(xiàn)的地方就獨(dú)立出來了。

NetEngine 業(yè)務(wù)控制抽象的幾種業(yè)務(wù)調(diào)用

Threeadpool的任務(wù)

三種:業(yè)務(wù)實(shí)現(xiàn)

OnConnect

Onclose

OnMsg

比如

監(jiān)聽到鏈接的調(diào)用NetEngine 調(diào)用了 iocpframe監(jiān)聽到連接的事件

調(diào)用父輩方法

NetEngine::OnConnect( SOCKET sock, bool isConnectServer )

創(chuàng)建一個(gè) NetConnect對象，通過內(nèi)存池分配的對象

投遞一個(gè) 連接的任務(wù)的task給線程池

Onclose

OnMsg

類似

內(nèi)存池設(shè)計(jì)

內(nèi)存池存儲 NetConnect對象，存儲管理netconnect對象使用memorypool

//初始化內(nèi)存池預(yù)分配內(nèi)存池

bool Init(unsigned short uMemorySize, unsigned short uMemoryCount);

// //分配內(nèi)存(鏈表方法)

一個(gè)線程讀一個(gè)線程寫無鎖隊(duì)列

Iobuffer

包含vector 一張 Iobufferblock 表，存儲多個(gè)緩沖塊

讀取的時(shí)候

Iobufferblock 托管在內(nèi)存池mempool BUFBLOCK_SIZE大小的內(nèi)存塊

Iobuffer

Readdata

/**

* IO緩沖

* 定義宏BUFBLOCK_SIZE

* 編譯期靜態(tài)確定類大小

* 不能使用指針在運(yùn)行時(shí)動態(tài)指定大小，參考池對象使用限制二

unsigned char m_buffer[BUFBLOCK_SIZE];

//已收到數(shù)據(jù)的長度

unsigned short m_uLength;

//Recv()函數(shù)下次讀取數(shù)據(jù)的開始位置

unsigned short m_uRecvPos;

unsigned short IOBufferBlock::ReadData( unsigned char *data, unsigned short uLength, bool bDel )

從當(dāng)前讀取位置開始讀取，如果越界就用剩下的大小獲取

bool IOBuffer::ReadData( unsigned char *data, int uLength, bool bDel )

//這里檢查m_uDataSize不需要原子操作

//cpu與內(nèi)存次交換最小長度就是byte,對于小于等于byte的類型的取值/賦值操作，

//本身就是原子操作

從頭來

遍歷所有bufferblock 如果是需要?jiǎng)h除的，那么原子操作減一，標(biāo)志不使用了內(nèi)存池，同時(shí)刪除清理block

一讀一寫，沒有線程安全問題

====================

SharedPtr

通過原子加減操作達(dá)到引用計(jì)數(shù)操作的線程安全

ShareMemory

依靠viewmap實(shí)現(xiàn) 內(nèi)存映射文件

* 創(chuàng)建/打開共享內(nèi)存

* 參數(shù)

* key 全局標(biāo)識，linux下只接收數(shù)字id

* size 共享大小

* if ( 是創(chuàng)建)

* 則創(chuàng)建size大小的共享內(nèi)存，

* else //是打開已存在的共享內(nèi)存

* if ( 是文件映射&& 是linux系統(tǒng))

* 則使用當(dāng)前共享內(nèi)存大小與size中較大的一個(gè),作為共享內(nèi)存的大小

* else 無效

* path 使用文件映射的共享內(nèi)存，文件路徑，key為文件名

ShareMemory(const char *key, unsigned long size, const char *path);

* 創(chuàng)建/打開共享內(nèi)存

* 參數(shù)

* key 全局標(biāo)識

* size 共享大小

* if ( 是創(chuàng)建)

* 則創(chuàng)建size大小的共享內(nèi)存，

* else //是打開已存在的共享內(nèi)存

* if ( 是文件映射&& 是linux系統(tǒng))

* 則使用當(dāng)前共享內(nèi)存大小與size中較大的一個(gè),作為共享內(nèi)存的大小

* else 無效

* path 使用文件映射的共享內(nèi)存，文件路徑，key為文件名

ShareMemory(const int key, unsigned long size, const char *path);

public:

void* GetBuffer();

unsigned long GetSize();

void Destory();

一次性獲取數(shù)據(jù)，初始化的時(shí)候指定了大小了。

內(nèi)存映射文件的方法，沒啥好看的

Signal

采用事件做信號通知，

=========================================

ThreadPool

包含一個(gè)vect的任務(wù)隊(duì)列里面帶的就是task

線程池采用事件信號通知。執(zhí)行的函數(shù) ThreadFunc

每次從從m_tasks取任務(wù)，加了鎖地取法。

然后執(zhí)行task的里面的Execute 方法這樣就調(diào)用到 Executor的CallMethod方法參數(shù)從入隊(duì)進(jìn)入就提交了。

Memorypool

一、

一塊對象數(shù)據(jù)MEMERY_INFO + uMemorySize

二、一個(gè) MemoryPool的數(shù)據(jù)結(jié)構(gòu)

存儲對象本身 8Byte

每一塊數(shù)據(jù)包含信息8byte 然后就是指向目標(biāo)管理對象的對象內(nèi)存

nBlockStartPos += MEMERY_INFO;

pObject = &(m_pMemery[nBlockStartPos]);

內(nèi)存塊數(shù) 初始化的時(shí)候設(shè)置的 m_uMemoryCount

三、Alloc()

找尋本身memorypool是否存在可用內(nèi)存，

有，就直接獲取地址出去使用

沒有的的話遍歷到最后會發(fā)現(xiàn) pBlock->m_pNext 為空，這個(gè)時(shí)候重新new memorypool對象教導(dǎo)鏈表上去

m_uFreeCount 未分配的個(gè)數(shù)

通過遍歷查詢AtomDec pBlock->m_uFreeCount 減1

if ( 0 < (int32)AtomDec(&pBlock->m_uFreeCount, 1) ) break; 執(zhí)行分配

class MemoryPool void* Alloc();

* 無鎖堆(n讀n寫并發(fā),不需加鎖)

* 內(nèi)存池結(jié)構(gòu)

* n個(gè)池組成鏈表

* 池結(jié)構(gòu)

* 每個(gè)池都是一段連續(xù)內(nèi)存保存在char數(shù)組中

* 0~7byte為池地址，后面是n個(gè)用于固定長度分配的內(nèi)存塊（即內(nèi)存塊是定長的）

* 內(nèi)存塊結(jié)構(gòu)

* 狀態(tài)byte+留空byte+內(nèi)存塊塊序號byte

* 所以一個(gè)內(nèi)存池最大可以保存的對象(內(nèi)存塊)數(shù)量為unsigned short的最大值

* 狀態(tài)就個(gè)(分配/未分配)，個(gè)byte就可以表示，使用byte是為了使用原子操作實(shí)現(xiàn)lock-free，而原子操作操作的是byte地址

* 2byte留空，是為了保證后面用于分配的內(nèi)存守地址都是byte對齊

* 因?yàn)檎鎸?shí)new出來的對象首地址是保證這點(diǎn)的，

* 且IOCP投遞緩沖struct，也要求首地址對齊，否則返回錯(cuò)誤

初始化

//預(yù)分配內(nèi)存=MemoryPool對象自身地址，byte，支持位機(jī)尋址

//記錄對象地址

//頭個(gè)字節(jié)保存對象自身地址，用于從內(nèi)存地址找到內(nèi)存池對象地址

if ( 8 == uAddrSize )

{

m_pMemery[nPos++] = (unsigned char)(uThis >> 56);

m_pMemery[nPos++] = (unsigned char)(uThis >> 48);

m_pMemery[nPos++] = (unsigned char)(uThis >> 40);

m_pMemery[nPos++] = (unsigned char)(uThis >> 32);

}

else

{

m_pMemery[nPos++] = 0;

}

m_pMemery[nPos++] = (unsigned char)(uThis >> 24);

m_pMemery[nPos++] = (unsigned char)(uThis >> 16);

m_pMemery[nPos++] = (unsigned char)(uThis >> 8);

m_pMemery[nPos++] = (unsigned char)uThis;

//初始化內(nèi)存

unsigned short i;

for ( i = 0; i < m_uMemoryCount; i++ )

{

//狀態(tài)未分配

m_pMemery[nPos++] = 0;

//留空字節(jié)

m_pMemery[nPos++] = 0;

//保存內(nèi)存序號

m_pMemery[nPos++] = (unsigned char) (i >> 8);

m_pMemery[nPos++] = (unsigned char) i;

nPos += uMemorySize;

}

鏈表內(nèi)存池組

每個(gè)內(nèi)存池

通過對象算出索引

通過索引算出對象都很方便

詳細(xì)參考另外一個(gè)筆記

posted on 2013-06-25 20:02 爬閱讀(2768) 評論(3) 編輯收藏引用所屬分類: 測試訓(xùn)練

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

相關(guān)文章: Micro-Development-Kit 學(xué)習(xí)記錄 mdk 高性能網(wǎng)絡(luò)庫 ZeroMQ 初體驗(yàn) 筆記做了一個(gè) xp 透明窗口幾百年沒有寫小程序玩，貼一個(gè)

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

常用鏈接

留言簿(7)

隨筆分類

隨筆檔案

文章分類

link

搜索

積分與排名

最新評論

閱讀排行榜