• <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>

            學習、成長之路

              C++博客 :: 首頁 :: 聯系 :: 聚合  :: 管理
              16 Posts :: 0 Stories :: 27 Comments :: 0 Trackbacks

            常用鏈接

            留言簿

            我參與的團隊

            搜索

            •  

            最新評論

            閱讀排行榜

            評論排行榜

             

            本代碼服務端引用了http://www.codeproject.com/KB/IP/IOCP_how_to_cook.aspx中的代碼,并作了少量修改,在這里對原作者表示感謝。。

            功能描述:
            * 封裝了心跳機制
            * 封裝了一層應用層協議,支持壓縮傳輸
            * Client端封裝了掉線重連機制

            示例代碼演示了文件傳輸并輸出傳輸速度
            希望朋友們能不吝指教,幫助我進步 :)

            點擊下載源碼

            服務端: 

            class CMyTcpServer : public CFTcpServer  
            {
            public:
                CMyTcpServer();
                
            virtual ~CMyTcpServer();
                
                
            virtual BOOL OnReadF(SCSocket *pSocket, PBYTE pData, DWORD dwLen)
                {
                    
            static DWORD btCount = 0;
                    
            static DWORD dwTime = GetTickCount();
                    
            static DWORD lastTime = dwTime;
                    btCount 
            += dwLen;
                    HANDLE    hFile 
            = CreateFile("c:\\abc.dat", GENERIC_WRITE, FILE_SHARE_WRITE,
                        NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
                    SetFilePointer(hFile, 
            00, FILE_END);
                    DWORD dwBytesWrite 
            = 0;
                    WriteFile(hFile, pData, dwLen, 
            &dwBytesWrite, NULL);
                    CloseHandle(hFile);        
                    
                    DWORD dwTTT 
            = GetTickCount();
                    
            if (dwTTT - lastTime > 1000)
                    {
                        lastTime 
            = dwTTT;
                        printf(
            "%dkb/s %u\n", (int)(((double)btCount) * 1000 / (dwTTT - dwTime) / 1024), btCount);
                    }
                    
                    
            return TRUE;
                }
                
            virtual int OnConnected(SCSocket *pSocket){return TRUE};
            };


            int main(int argc, char* argv[])
            {
                CMyTcpServer::InitSocketLib();
                CMyTcpServer ts;
                ts.Start(
            990850008150000);
                
            while!_kbhit() ) ::Sleep(100);
                ts.Stop();
                
            return 0;
            }

              客戶端: 

            class CMyTcpClient : public CFTcpClient  
            {
            public:
                CMyTcpClient();
                
            virtual ~CMyTcpClient();
                
                
            virtual VOID OnConnected()
                {
                    
            char buff[BUFF_SIZE_C - 100];
                    HANDLE    hFile;
                    
                    hFile 
            = CreateFile("c:\\abc.dat", GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0);
                    DWORD nNumberOfBytesRead 
            = 0;
                    
            int pos = 0;
                    
            while (ReadFile(hFile, buff, BUFF_SIZE_C - 100&nNumberOfBytesRead, NULL))
                    {
                        
            if (BUFF_SIZE_C - 100 == nNumberOfBytesRead)
                            Send(buff, nNumberOfBytesRead);
                        
            else
                            
            break;
                    }
                    CloseHandle(hFile);
                    Send(buff, nNumberOfBytesRead, TRUE);
                };
                
            virtual int OnReadF(LPSTR pData, int nSize)
                {
                    
            return TRUE;
                }
            };


            int main(int argc, char* argv[])
            {
                CMyTcpClient::InitSocketLib();
                CMyTcpClient 
            *pcl = new CMyTcpClient;
                pcl
            ->Start("192.168.1.138"9908);
                
            while!_kbhit() ) ::Sleep(100);
                
            return 0;
            }

             


             


            posted on 2009-08-13 11:21 sToa 閱讀(3910) 評論(2)  編輯 收藏 引用 所屬分類: VC

            Feedback

            # re: 封裝一個TCP服務端(IOCP)與客戶端[未登錄] 2009-08-14 20:56 CC
            源代碼呢?  回復  更多評論
              

            # re: 封裝一個TCP服務端(IOCP)與客戶端 2009-08-15 14:22 sToa
            @CC
            這個模板鏈接沒有高亮顯示 呵呵 在前面找找 很好找的  回復  更多評論
              

            一本一道久久a久久精品综合| 青青青国产精品国产精品久久久久 | 国内精品久久久久久中文字幕| 国产精品伊人久久伊人电影| 久久夜色精品国产| 亚洲精品无码久久千人斩| 国产精品久久影院| 欧美成a人片免费看久久| 久久夜色精品国产噜噜亚洲AV| 日本精品久久久久中文字幕| 亚洲综合久久久| 91亚洲国产成人久久精品网址| 亚洲精品无码久久一线| 久久国产美女免费观看精品 | 久久精品无码免费不卡| 亚洲综合熟女久久久30p| 国产精品永久久久久久久久久 | 国产美女久久精品香蕉69| 久久久无码精品亚洲日韩软件| 97r久久精品国产99国产精| 香蕉99久久国产综合精品宅男自 | 久久久久亚洲精品天堂久久久久久 | 久久九九久精品国产免费直播| 久久91精品国产91久久户| 亚洲中文字幕久久精品无码APP| 久久er国产精品免费观看2| 国产亚州精品女人久久久久久 | 久久综合久久自在自线精品自| 天天躁日日躁狠狠久久| 国产亚洲精久久久久久无码AV| 人妻无码精品久久亚瑟影视 | 99久久久精品免费观看国产| 久久影视国产亚洲| 久久91精品国产91久久户| 亚洲精品高清国产一线久久| 亚洲国产精品成人久久蜜臀| 久久av高潮av无码av喷吹| 亚洲级αV无码毛片久久精品| 亚洲&#228;v永久无码精品天堂久久| 波多野结衣中文字幕久久| 久久精品国产亚洲av水果派|