基于tcp協(xié)議網(wǎng)上聊天程序(已改無錯(cuò)字)
2023-07-01 12:00:21 本頁面
【正文】 )。 //接受客戶登錄信息 CTime time = CTime::GetCurrentTime()。 //獲取當(dāng)前系統(tǒng)時(shí)間 CString t = (%Y%m%d %H:%M:%S)。 //時(shí)間格式 CEdit *p_Edit = (CEdit *)::AfxGetMainWnd()GetDlgItem(IDC_EDIT_INFO)。 CString strTemp = t + : + CString(buff) + 進(jìn)入\r\n。 //顯示登錄信息 p_EditReplaceSel(strTemp)。 //更新在線客戶列表 m_strName = buff。 m_dlgServerUpdateUser(this)。 } if(type == SEND_MESSAGE) //如果接受的是客戶發(fā)送信息 { char buff[1000]。 memset(buff,0,sizeof(buff))。 Receive(buff,sizeof(buff))。 //接收消息內(nèi)容 CClientSocket *curr = NULL。 POSITION pos = clistGetHeadPosition()。 while (pos != NULL) //將消息發(fā)至在線客戶 { curr = (CClientSocket *)clistGetNext(pos)。 currSend((char *)header,sizeof(Header))。 currSend(buff, sizeof(buff))。 } } CSocket::OnReceive(nErrorCode)。} （4）客戶發(fā)送消息，先將消息發(fā)至服務(wù)器，具體代碼如下：void CMyChatDlg::OnSend() { UpdateData()。 if(m_strMessage == ) { AfxMessageBox(_T(不能發(fā)送空消息?。。?)。 CEdit *pEdit = (CEdit*)GetDlgItem(IDC_EDIT_MESSAGE)。 pEditSetFocus()。 return。 } Header head。 = SEND_MESSAGE。 = ()。 CTime time = CTime::GetCurrentTime()。 CString t = (%H:%M:%S)。 CString nikeName = 。 CString str = nikeName + + t + \r\n + +m_strMessage。 m_pSocketSend((char *)amp。head,sizeof(Header))。 //將發(fā)送時(shí)間和收信客戶信息發(fā)至服務(wù)器 if(m_pSocketSend((LPCTSTR)str, ())) //發(fā)送信息內(nèi)容 { m_strMessage = 。 UpdateData(FALSE)。 CEdit *pEdit = (CEdit*)GetDlgItem(IDC_EDIT_MESSAGE)。 pEditSetFocus()。 }else { AfxMessageBox(_T(網(wǎng)絡(luò)傳輸錯(cuò)誤！))。 }} （5）服務(wù)器接收消息并轉(zhuǎn)發(fā)，具體代碼如下：void CClientSocket::OnReceive(int nErrorCode) { char buff1[sizeof(Header)]。 memset(buff1, 0, sizeof(buff1))。 Receive(buff1,sizeof(buff1))。 Header *header = (Header*)buff1。 int length = headerlen。 char type = headertype。 if(type == LOGIN_IO) //如果收到的是登錄信息 { char buff[1000]。 memset(buff,0,sizeof(buff))。 Receive(buff,length)。 //接受客戶登錄信息 CTime time = CTime::GetCurrentTime()。 //獲取當(dāng)前系統(tǒng)時(shí)間 CString t = (%Y%m%d %H:%M:%S)。 //時(shí)間格式 CEdit *p_Edit = (CEdit *)::AfxGetMainWnd()GetDlgItem(IDC_EDIT_INFO)。 CString strTemp = t + : + CString(buff) + 進(jìn)入\r\n。 //顯示登錄信息 p_EditReplaceSel(strTemp)。 //更新在線客戶列表 m_strName = buff。 m_dlgServerUpdateUser(this)。 } if(type == SEND_MESSAGE) //如果接受的是客戶發(fā)送信息 { char buff[1000]。 memset(buff,0,sizeof(buff))。 Receive(buff,sizeof(buff))。 //接收消息內(nèi)容 CClientSocket *curr = NULL。 POSITION pos = clistGetHeadPosition()。 while (pos != NULL) //將消息發(fā)至在線客戶 { curr = (CClientSocket *)clistGetNext(pos)。 currSend((char *)header,sizeof(Header))。 currSend(buff, sizeof(buff))。 } } CSocket::OnReceive(nErrorCode)
公司管理相關(guān)推薦
鄂ICP備17016276號(hào)-1