计算机网络实验实验报告

// }

return TRUE;

return Run(Port, PersTO); bRun = TRUE;

CloseHandle(ThreadLaunchedEvent);

if(WaitForSingleObject(ThreadLaunchedEvent, THREADWAIT_TO) != WAIT_OBJECT_0) { }

//LogMessage(LOGFILENAME, \CloseHandle(ThreadLaunchedEvent); return FALSE; // 启动接收线程

ResetEvent(ThreadLaunchedEvent);

ThreadA = (HANDLE)_beginthreadex(NULL, 0, AcceptThread, this, 0, &ThreadA_ID); if(!ThreadA) { }

//LogMessage(LOGFILENAME, \return FALSE;

errno);

specified Timeout ->\

2. 关闭服务：

BOOL QHttpServer::Shutdown()

{

if(!bRun)

return FALSE;

BOOL bResult = TRUE; HANDLE hArray[2]; hArray[0] = ThreadA; hArray[1] = ThreadC; //

// 关闭接收和helper线程 //

SetEvent(ShutdownEvent);

DWORD n = WaitForMultipleObjects(2, hArray, TRUE, THREADKILL_TO);

}

if(n == WAIT_TIMEOUT || n == WAIT_FAILED) { }

CloseHandle(ThreadA); CloseHandle(ThreadC); //

// 所有的客户线程都结束 //

THREADLIST::iterator it; while(ThreadList.size()) { }

DeleteCriticalSection(&cs); DeleteCriticalSection(&_cs); bRun = FALSE; return bResult;

Sleep(100);

//LogMessage(LOGFILENAME, \ //if(!TerminateThread(ThreadA, THREADEXIT_SUCCESS))

//LogMessage(LOGFILENAME, \

already terminated\

//if(!TerminateThread(ThreadC, THREADEXIT_SUCCESS))

//LogMessage(LOGFILENAME, \

already terminated\

bResult = FALSE;

3. 增加新链接：

BOOL QHttpServer::AddClient(SOCKET s, char* clientAddress, int port)

{

VISVECTOR::iterator it;

it = find(Visitors.begin(), Visitors.end(), clientAddress);//查找重复IP if(it == Visitors.end()) { }

Visitors.push_back(clientAddress);//增加新客户IP visitsip.push_back(clientAddress);

//输出用

}

InterlockedIncrement(&Stats.nTotalHits);//互斥 ThreadTag threadTag; HANDLE unsigned int

//进入临界区并创建连接对象 EnterCriticalSection(&cs);

NewConnectionTag *NewConn = new NewConnectionTag; NewConn->pHttpServer NewConn->s if(hThread) { } else

serverlog.push_back(\);

//LogMessage(LOGFILENAME, \ //else

LeaveCriticalSection(&cs); return TRUE;

threadTag.threadID = threadID; threadTag.hThread = hThread; ThreadList.push_back(threadTag);

= this;

= s;

hThread; threadID;

hThread = (HANDLE)_beginthreadex(NULL, 0, ClientThread, NewConn, 0, &threadID);

4. 分析请求数据：

BOOL QHttpServer::ParseRequest(string szRequest, string &szResponse, BOOL &bKeepAlive)

{

string szMethod; string szFileName; string szFileExt;

string szStatusCode(\); string szContentType(\); string szConnectionType(\); string szNotFoundMessage; string szDateTime;

char pResponseHeader[2048]; fpos_t lengthActual = 0, length = 0; char *pBuf = NULL; int n; //

// 检查提交方法 //

n = szRequest.find(\, 0); if(n != string::npos) { } else { } //

// 分析链接类型 //

n = szRequest.find(\, 0); if(n != string::npos) //

// 分析内容类型 //

bKeepAlive = TRUE; return FALSE;

szMethod = szRequest.substr(0, n); if(szMethod == \) { } else { }

szStatusCode = \; szFileName = ERROR501; //

// 获取文件名 //

int n1 = szRequest.find(\, n + 1); if(n != string::npos) { } else { }

return FALSE;

szFileName = szRequest.substr(n + 1, n1 - n - 1); if(szFileName == \) { }

szFileName = m_DefIndex;