【文章內(nèi)容簡介】 IdInfo=(IDInfo*)pParam。 char buf[1024]。 sockaddr_in addr。 = inet_addr(pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].UserIP)。 =AF_INET。 =LOCAL_PORT。 WSADATA wsaData。 WSAStartup(0x101,amp。wsaData)。 SOCKET g_ConnectSocket。 g_ConnectSocket = socket(AF_INET, SOCK_STREAM,0)。 if(g_ConnectSocket==INVALID_SOCKET) { return 1。 } if(connect(g_ConnectSocket,(sockaddr*)amp。addr,sizeof(addr))==1) { AfxMessageBox(無法連接到客戶機)。 return 1。 } pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].s=g_ConnectSocket。 CString temp,finishsize,fromsize。 (%d,pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].FromBytes)。 (%d,pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].ToBytes)。 temp=URL:。 temp+=pViewm_taskdowninfo[IdInfoTaskID].url。 temp+=lfromsize:。 temp+=fromsize。 temp+=lfinishsize:。 temp+=finishsize。 temp+=。 strcpy(buf,temp)。 int slen。 slen=0。 int tlen。 tlen=()。 while(slentlen) slen+=send(g_ConnectSocket,buf,tlen,0)。 CString temp2。 int rlen2。 char buf2[100]。 rlen2=0。 while(true) { rlen2=recv(g_ConnectSocket,buf2,100,0)。 temp2=buf2。 if((cmd:recv)=0) { break。 } else if((cmd:end)=0) { closesocket(g_ConnectSocket)。 ::PostMessage(pViewm_hWnd,WM_CHANGEUSR,(long)IdInfo,0)。 return 0。 } else { CString speed2,finishsize2,time2。 ParseBuf2(buf2,finishsize2,speed2,time2)。 pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].Rate=finishsize2。 pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].Speed=speed2。 pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].Time=time2。 } } CFile* rfile。 //打開在StartHttpDownLoad()中創(chuàng)建的文件 rfile=new CFile。 rfileOpen(pViewm_taskdowninfo[IdInfoTaskID].savepath+pViewm_taskdowninfo[IdInfoTaskID].filename,CFile::modeWrite|CFile::shareDenyNone)。 rfileSeek(pViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].FromBytes,CFile::begin)。 //設(shè)置文件指針位置 long rlength,len,buflen,startsize。 rlength=0。 char buf1[5024]。 while(rlengthpViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].ToBytespViewm_taskdowninfo[IdInfoTaskID].UserDownInfo[IdInfoThreadID].FromBytes) { len=recv(g_ConnectSocket,buf1,5024,0)。 rfileWrite(buf1,len)。 rlength+=len。 pViewm_taskdowninfo[IdInfoTaskID].finishsize+=pViewm_taskdowninfo[IdInfoTaskID].finishsize。 } rfileClose。 return 0。}3. 點對點互傳代碼UINT CHttpDowndLoad::SendFile(LPVOID pParam){ //得到視圖類的指針 // CDownLoadView* dlv。 CMDIFrameWnd *pFrame = (CMDIFrameWnd*)AfxGetApp()m_pMainWnd。 // Get the active MDI child window. CMDIChildWnd *pChild=(CMDIChildWnd *) pFrameGetActiveFrame()。 // Get the active view attached to the active MDI child window. POSITION pos=pChildGetActiveDocument()GetFirstViewPosition()。 CDownLoadView *pView=(CDownLoadView*)pChildGetActiveDocument()GetNextView(pos)。 ConnectInfo *ConInfo。 ConInfo=(ConnectInfo *)pParam。 long FileSize。 long ReadSize。 long SendSize。 long TempSize。 CString temp。 CString SFileSize。 char buf[128]。 char data[5*1024]。 CFile pFile。 if((ConInfoPath,CFile::modeRead|CFile::shareDenyNone)) { FileSize=()。 (%d,FileSize)。 temp=STATUS:HAVESIZE:。 temp+=SFileSize。 temp+=。 strcpy(buf,temp)。 send(ConInfos,buf,(),0)。 ReadSize=0。 SendSize=0。 while(SendSizeFileSize) { ReadSize=(data,5*1024)。 TempSize+=send(ConInfos,data,ReadSize,0)。 SendSize+=ReadSize。 } } else { temp=STATUS:NONESIZE:。 strcpy(buf,temp)。 send(ConInfos,buf,(),0)。 return 0。 } return 0。}Public Function DoEvent(ByVal str As String, ByVal ss As Socket) As Boolean Dim dv As DataView Dim userip As String Dim status As String status = ((STATUS:) + 7, (IP:) (STATUS:) 7) Select Case status Case START 39。用戶啟動命令 userip = ((IP:) + 3, () (IP:) 3) dv = (select * from UserIP where UserIP like 39。% + userip + %39。) 39。查詢用戶信息是否已經(jīng)在數(shù)據(jù)庫 If 0 Then 39。如果用戶已經(jīng)存在，則直接更新用戶狀態(tài)為在線 (update UserIP set status=39。139。 where UserIP like 39。% + userip + %39。) Else 39。如果用戶不存在，則插入用戶IP并且置狀態(tài)為在線 (insert into UserIP(UserIP,status) values(39。 + userip + 39。,39。139。)) End If RefreshUserList()