• <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>
            隨筆 - 42  文章 - 3  trackbacks - 0
            <2009年7月>
            2829301234
            567891011
            12131415161718
            19202122232425
            2627282930311
            2345678

            常用鏈接

            留言簿(2)

            隨筆檔案

            文章檔案

            網頁收藏

            搜索

            •  

            最新評論

            閱讀排行榜

            評論排行榜

            IOCP(I/O Completion Port,I/O完成端口)是性能最好的一種I/O模型。它是應用程序使用線程池處理異步I/O請求的一種機制。在處理多個并發的異步I/O請求時,以往的模型都是在接收請求是創建一個線程來應答請求。這樣就有很多的線程并行地運行在系統中。而這些線程都是可運行的,Windows內核花費大量的時間在進行線程的上下文切換,并沒有多少時間花在線程運行上。再加上創建新線程的開銷比較大,所以造成了效率的低下。

            而IOCP模型是事先開好了N個線程,存儲在線程池中,讓他們hold。然后將所有用戶的請求都投遞到一個完成端口上,然后N個工作線程逐一地從完成端口中取得用戶消息并加以處理。這樣就避免了為每個用戶開一個線程。既減少了線程資源,又提高了線程的利用率。

            完成端口模型是怎樣實現的呢?我們先創建一個完成端口(::CreateIoCompletioPort())。然后再創建一個或多個工作線程,并指定他們到這個完成端口上去讀取數據。我們再將遠程連接的套接字句柄關聯到這個完成端口(還是用::CreateIoCompletionPort())。一切就OK了。

            工作線程都干些什么呢?首先是調用::GetQueuedCompletionStatus()函數在關聯到這個完成端口上的所有套接字上等待I/O的完成。再判斷完成了什么類型的I/O。一般來說,有三種類型的I/O,OP_ACCEPT,OP_READ和OP_WIRTE。我們到數據緩沖區內讀取數據后,再投遞一個或是多個同類型的I/O即可(::AcceptEx()、::WSARecv()、::WSASend())。對讀取到的數據,我們可以按照自己的需要來進行相應的處理。

            為此,我們需要一個以OVERLAPPED(重疊I/O)結構為第一個字段的per-I/O數據自定義結構。

            typedef struct _PER_IO_DATA
            {
                     OVERLAPPED ol;      // 重疊I/O結構
                     char buf[BUFFER_SIZE];  // 數據緩沖區
                     int nOperationType;         //I/O操作類型
            #define OP_READ 1
            #define OP_WRITE 2
            #define OP_ACCEPT 3
            } PER_IO_DATA, *PPER_IO_DATA;

            將一個PER_IO_DATA結構強制轉化成一個OVERLAPPED結構傳給::GetQueuedCompletionStatus()函數,返回的這個PER_IO_DATA結構的的nOperationType就是I/O操作的類型。當然,這些類型都是在投遞I/O請求時自己設置的。

            這樣一個IOCP服務器的框架就出來了。當然,要做一個好的IOCP服務器,還有考慮很多問題,如內存資源管理、接受連接的方法、惡意的客戶連接、包的重排序等等。以上是個人對于IOCP模型的一些理解與看法,還有待完善。另外各Winsock API的用法參見MSDN。

             

            補充IOCP模型的實現:

            //創建一個完成端口
            FCompletPort := CreateIoCompletionPort( INVALID_HANDLE_VALUE, 0,0,0 );

            //接受遠程連接,并把這個連接的socket句柄綁定到剛才創建的IOCP上
            AConnect := accept( FListenSock, addr, len);
            CreateIoCompletionPort( AConnect, FCompletPort, nil, 0 );

            //創建CPU數*2 + 2個線程
            for i:=1 to si.dwNumberOfProcessors*2+2 do
            begin
              AThread := TRecvSendThread.Create( false );
              AThread.CompletPort := FCompletPort;//告訴這個線程,你要去這個IOCP去訪問數據
            end;

            OK,就這么簡單,我們要做的就是建立一個IOCP,把遠程連接的socket句柄綁定到剛才創建的IOCP上,最后創建n個線程,并告訴這n個線程到這個IOCP上去訪問數據就可以了。

            再看一下TRecvSendThread線程都干些什么:

            procedure TRecvSendThread.Execute;
            var
              ......
            begin
              while (not self.Terminated) do
              begin
                //查詢IOCP狀態(數據讀寫操作是否完成)
                GetQueuedCompletionStatus( CompletPort, BytesTransd, CompletKey, POVERLAPPED(pPerIoDat), TIME_OUT );

                if BytesTransd <> 0  then
                   ....;//數據讀寫操作完成

                //再投遞一個讀數據請求
                WSARecv( CompletKey, @(pPerIoDat^.BufData), 1, BytesRecv, Flags, @(pPerIoDat^.Overlap), nil );
              end;
            end;

            讀寫線程只是簡單地檢查IOCP是否完成了我們投遞的讀寫操作,如果完成了則再投遞一個新的讀寫請求。
            應該注意到,我們創建的所有TRecvSendThread都在訪問同一個IOCP(因為我們只創建了一個IOCP),并且我們沒有使用臨界區!難道不會產生沖突嗎?不用考慮同步問題嗎?
            呵呵,這正是IOCP的奧妙所在。IOCP不是一個普通的對象,不需要考慮線程安全問題。它會自動調配訪問它的線程:如果某個socket上有一個線程A正在訪問,那么線程B的訪問請求會被分配到另外一個socket。這一切都是由系統自動調配的,我們無需過問。

            posted on 2009-07-29 11:21 鷹擊長空 閱讀(388) 評論(0)  編輯 收藏 引用
            久久精品无码一区二区无码| 亚洲午夜久久久| 久久婷婷五月综合国产尤物app| 亚洲国产精品综合久久一线| 香蕉久久久久久狠狠色| 久久青青草原亚洲av无码app| 国产福利电影一区二区三区久久老子无码午夜伦不 | 久久男人AV资源网站| 亚洲中文字幕伊人久久无码| 久久精品中文闷骚内射| 精品人妻伦九区久久AAA片69 | 精品久久久久久久| 亚洲综合久久久| 伊人丁香狠狠色综合久久| 久久婷婷五月综合成人D啪| 亚洲国产成人久久综合一| 久久精品国产亚洲AV影院| 精品久久久久久久久久中文字幕| 人妻久久久一区二区三区| 亚洲欧洲久久久精品| 国内精品久久久久久久coent| 久久久久人妻一区精品性色av| 久久夜色撩人精品国产| 嫩草影院久久国产精品| 潮喷大喷水系列无码久久精品| 国产亚洲精品久久久久秋霞| 久久久久一本毛久久久| 大蕉久久伊人中文字幕| 色综合久久中文综合网| 精品国产一区二区三区久久| 久久久久亚洲AV片无码下载蜜桃| 亚洲色大成网站www久久九| 久久亚洲AV成人无码| 久久精品国产亚洲AV不卡| 久久亚洲精品无码aⅴ大香| 久久乐国产综合亚洲精品| 久久久久久久免费视频| 久久亚洲精品国产精品婷婷| 精品久久久久成人码免费动漫| 香蕉久久影院| 久久久久av无码免费网|