本代碼服務(wù)端引用了http://www.codeproject.com/KB/IP/IOCP_how_to_cook.aspx中的代碼，并作了少量修改，在這里對(duì)原作者表示感謝。。
功能描述：
* 封裝了心跳機(jī)制
* 封裝了一層應(yīng)用層協(xié)議，支持壓縮傳輸
* Client端封裝了掉線(xiàn)重連機(jī)制
示例代碼演示了文件傳輸并輸出傳輸速度
希望朋友們能不吝指教，幫助我進(jìn)步 :)
點(diǎn)擊下載源碼
服務(wù)端：
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, 0, 0, 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(9908, 5000, 8, 150000);
while( !_kbhit() ) ::Sleep(100);
ts.Stop();
return 0;
}
客戶(hù)端：
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;
}