我在一臺電腦上開啟了兩個界面，一個做為服務器，一個為客戶端，不知道這樣登錄的方式對不對，用戶串列無顯示
代碼如下：
UpdateData();
if(LocaIP.IsBlank())
{
AfxMessageBox("請設定本機IP地址!");
return;
}
if(locaPort.IsEmpty())
{
AfxMessageBox("請指定通信埠號!");
return;
}
//初始化套接字與系結
WSADATA wsaData;
int iErrorCode;
if (WSAStartup(MAKEWORD(2,1),&wsaData)) //呼叫Windows Sockets DLL
{
m_MessageList.ReplaceSel("Winsock無法初始化!\r\n");
WSACleanup();
return;
}
m_MessageList.ReplaceSel("開始創建Socket…\r\n");
SelfRcvSocket = socket(PF_INET,SOCK_DGRAM,0); //創建本機行程的Socket，型別為SOCK_DGRAM，無連接的通信
if(SelfRcvSocket == INVALID_SOCKET)
{
m_MessageList.ReplaceSel("創建socket失敗!\r\n");
return;
}
//獲取本機行程的IP和埠
BYTE nFild[4];
CString sIP;
LocaIP.GetAddress(nFild[0],nFild[1],nFild[2],nFild[3]);
sIP.Format("%d.%d.%d.%d",nFild[0],nFild[1],nFild[2],nFild[3]);
m_sockSelfRcvAddr.sin_family = AF_INET;
m_sockSelfRcvAddr.sin_addr.S_un.S_addr = inet_addr(sIP);
m_sockSelfRcvAddr.sin_port = htons(atoi(locaPort));
//將套接字與本機行程系結
if(bind(SelfRcvSocket,(LPSOCKADDR)&m_sockSelfRcvAddr,sizeof(m_sockSelfRcvAddr)) == SOCKET_ERROR)
{
m_MessageList.ReplaceSel("系結失敗!\r\n");
return;
}
iErrorCode = WSAAsyncSelect(SelfRcvSocket,m_hWnd,WM_CLIENT_READCLOSE,FD_READ);
if (iErrorCode == SOCKET_ERROR)
{
m_MessageList.ReplaceSel("WSAAsyncSelect設定失敗!——用于連接請求的訊息\r\n");
return;
}
m_MessageList.ReplaceSel("本機行程啟動成功!\r\n");
m_MessageList.ReplaceSel("地址 " + sIP + " 埠 " + locaPort);
this->SetWindowTextA("本機行程（" + sIP + ":" + locaPort + "）正在運行… - ptopTalker");
//界面
m_Start.EnableWindow(false);
m_Stop.EnableWindow(true);
LocaIP.EnableWindow(false);
m_LcaPrt.EnableWindow(false);
m_Login.EnableWindow(true);
SevrIP.EnableWindow(true);
m_SvrPrt.EnableWindow(true);
m_nicnam.EnableWindow(true);
m_MessageList.EnableWindow(true);
m_exit.EnableWindow(false);
m_nicnam.SetFocus();
//
return;
//ADD
CDialog::OnOK();
}
void CP2PTalkerDlg::OnStop()
{
// TODO: 在此添加控制元件通知處理程式代碼
//ADD
//當程式停止運行時，把SOCKET清空
m_MessageList.ReplaceSel("\r\n正在關閉Socket…\r\n");
closesocket(SelfRcvSocket);
WSACleanup();
m_MessageList.ReplaceSel("本機行程停止運行!\r\n");
this->SetWindowTextA("ptopTalker");
//界面
m_Start.EnableWindow(true);
m_Stop.EnableWindow(false);
LocaIP.EnableWindow(true);
m_LcaPrt.EnableWindow(true);
m_exit.EnableWindow(true);
m_Login.EnableWindow(false);
m_nicnam.EnableWindow(false);
SevrIP.EnableWindow(false);
m_SvrPrt.EnableWindow(false);
LocaIP.SetFocus();
//
//ADD
}
void CP2PTalkerDlg::OnLogin()
{
// TODO: 在此添加控制元件通知處理程式代碼
//ADD
//輸入驗證
UpdateData();
if(nickname.IsEmpty())
{
AfxMessageBox("給自己取個昵稱吧!");
return;
}
if(SevrIP.IsBlank())
{
AfxMessageBox("請填寫選作P2P服務器的主機IP地址!");
return;
}
if(sevrPort.IsEmpty())
{
AfxMessageBox("請指定P2P服務行程的埠!");
return;
}
BYTE nFild[4];
CString sIP;
//生成登錄注冊報文
LocaIP.GetAddress(nFild[0],nFild[1],nFild[2],nFild[3]);
sIP.Format("%d.%d.%d.%d",nFild[0],nFild[1],nFild[2],nFild[3]);
RegisterAddr = "RGST_ADDR;";
RegisterAddr += nickname + "," + sIP;
RegisterAddr += ":" + locaPort;
//獲取P2P服務行程的IP和埠
SevrIP.GetAddress(nFild[0],nFild[1],nFild[2],nFild[3]);
sIP.Format("%d.%d.%d.%d",nFild[0],nFild[1],nFild[2],nFild[3]);
//發送報文
this->StartSndSocket(RegisterAddr,sIP,sevrPort);
this->SetWindowTextA("已登錄P2P服務器（" + sIP + ":" + sevrPort + "） - ptopTalker");
//界面
m_Stop.EnableWindow(false);
m_Login.EnableWindow(false);
m_Logout.EnableWindow(true);
SevrIP.EnableWindow(false);
m_SvrPrt.EnableWindow(false);
m_nicnam.EnableWindow(false);
m_UserList.EnableWindow(true);
m_EditWords.EnableWindow(true);
m_Send.EnableWindow(true);
m_EditWords.SetFocus();
//
//ADD
}
//ADD
LRESULT CP2PTalkerDlg::OnReadMsg(WPARAM wParam,LPARAM lParam)
{
//接收其他端系統發來的訊息
CString str,strHead,strData;
switch (WSAGETSELECTEVENT(lParam))
{
case FD_READ:
socklen = sizeof(m_sockSelfRcvAddr);
recvfrom(SelfRcvSocket,(char *)&msgbuf,sizeof(msgbuf),0,(LPSOCKADDR)&m_sockSelfRcvAddr,(int *)&socklen);
WSAAsyncSelect(SelfRcvSocket,m_hWnd,WM_CLIENT_READCLOSE,FD_READ);
str.Format("%s",msgbuf.msg);
//截取報文頭和資料部分
int n = str.ReverseFind(';');
strHead = str.Left(n);
strData = str.Right(str.GetLength() - (n + 1));
if(strHead == "RGST_ADDR")
{
this->EnrolUsr(strData);
}
if(strHead == "UPDT_USR")
{
this->UpdUsr(strData);
}
if(strHead == "REQ_ADDR")
{
this->PtoPsrvProvdr(strData);
}
if(strHead == "RSP_ADDR")
{
this->SendMsgtoPer(strData);
}
if(strHead == "SND_MSG")
{
this->ShowMsgfrmPer(strData);
}
break;
}
return 0L;
}
//ADD
//ADD
void CP2PTalkerDlg::EnrolUsr(CString strMsgData)
{
CString usrname,ipFild1,ipFild2,ipFild3,ipFild4,port;
int n;
//從報文中截取昵稱欄位
n = strMsgData.Find(",");
usrname = strMsgData.Left(n);
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//依次截取IP和埠各個欄位
n = strMsgData.Find(".");
ipFild1 = strMsgData.Left(n);
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
n = strMsgData.Find(".");
ipFild2 = strMsgData.Left(n);
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
n = strMsgData.Find(".");
ipFild3 = strMsgData.Left(n);
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
n = strMsgData.Find(":");
ipFild4 = strMsgData.Left(n);
port = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//下面開始進行用戶登記處理
BOOL BePresnc = false; //指示這個用戶是否已在服務器上注冊
for(int i = 0;i < rstUsrCont;i++)
{
if(CString(rstUsr[i].usrname) == usrname)
{
BePresnc = true;
if(rstUsr[i].onlStat)
{
rstUsr[i].onlStat = false;
onlUsrCont--;
}
else
{
//若用戶上線時改變了IP，服務器上注冊的用戶資訊也會隨著同步更新
rstUsr[i].ipFild[0] = _ttoi(ipFild1);
rstUsr[i].ipFild[1] = _ttoi(ipFild2);
rstUsr[i].ipFild[2] = _ttoi(ipFild3);
rstUsr[i].ipFild[3] = _ttoi(ipFild4);
rstUsr[i].port = atoi((LPCTSTR)port);
rstUsr[i].onlStat = true;
onlUsrCont++;
}
}
}
if(!BePresnc)
{
strcpy(rstUsr[rstUsrCont].usrname,(LPCTSTR)usrname);
rstUsr[rstUsrCont].ipFild[0] = _ttoi(ipFild1);
rstUsr[rstUsrCont].ipFild[1] = _ttoi(ipFild2);
rstUsr[rstUsrCont].ipFild[2] = _ttoi(ipFild3);
rstUsr[rstUsrCont].ipFild[3] = _ttoi(ipFild4);
rstUsr[rstUsrCont].port = atoi((LPCTSTR)port);
rstUsr[rstUsrCont].onlStat = true;
rstUsrCont++;
onlUsrCont++;
}
//更新用戶……以下為測驗代碼
m_UserList.EnableWindow(true);
m_UserList.ResetContent();
m_MessageList.SetWindowTextA("");
OnlUsrInfo = "UPDT_USR;";
for(int i = 0;i < rstUsrCont;i++)
{
if(rstUsr[i].onlStat)
{
OnlUsrInfo += CString(rstUsr[i].usrname) + "&"; //生成更新用戶類報文
m_UserList.AddString(CString(rstUsr[i].usrname));
CString sIP,sP,onlUsrStateView;
sIP.Format("%d.%d.%d.%d",rstUsr[i].ipFild[0],rstUsr[i].ipFild[1],rstUsr[i].ipFild[2],rstUsr[i].ipFild[3]);
sP.Format("%d",rstUsr[i].port);
onlUsrStateView = CString(rstUsr[i].usrname) + " -IP:";
onlUsrStateView += sIP + " 埠:";
onlUsrStateView += sP + "\r\n";
m_MessageList.ReplaceSel(onlUsrStateView);
}
}
for(int i = 0;i < rstUsrCont;i++)
{
if(rstUsr[i].onlStat)
{
CString sIP,sP;
sIP.Format("%d.%d.%d.%d",rstUsr[i].ipFild[0],rstUsr[i].ipFild[1],rstUsr[i].ipFild[2],rstUsr[i].ipFild[3]);
sP.Format("%d",rstUsr[i].port);
this->StartSndSocket(OnlUsrInfo,sIP,sP);
}
}
//測驗代碼
}
//ADD
//ADD
void CP2PTalkerDlg::UpdUsr(CString strMsgData)
{
CString array[100];
int b = 0;
for( int i = 0; i < strMsgData.GetLength(); i++ )
{
if(i != (strMsgData.GetLength() - 1))
{
if ( strMsgData[i] == '&' )
{
b ++;
}
else
{
array[b] = array[b] + strMsgData[i];
}
}
}
m_UserList.ResetContent();
for(int j = 0; j < b + 1; j ++)
{
m_UserList.AddString(array[j]);
}
}
//ADD
//ADD
void CP2PTalkerDlg::PtoPsrvProvdr(CString strMsgData)
{
CString usrname,ip,port,perUsrAddr;
int n;
//從報文中截取昵稱欄位
n = strMsgData.Find(",");
usrname = strMsgData.Left(n);
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//在本地服務器上搜索用戶請求的IP地址
for(int i = 0;i < rstUsrCont;i++)
{
if(CString(rstUsr[i].usrname) == usrname)
{
//找到匹配的用戶之后，組裝成P2P服務回應報文
CString perIP,perPort;
perIP.Format("%d.%d.%d.%d",rstUsr[i].ipFild[0],rstUsr[i].ipFild[1],rstUsr[i].ipFild[2],rstUsr[i].ipFild[3]);
perPort.Format("%d",rstUsr[i].port);
perUsrAddr = usrname + ",";
perUsrAddr += perIP + ":";
perUsrAddr += perPort;
PtoPsrvRspse = "RSP_ADDR;" + perUsrAddr;
break;
}
}
//截取請求發送者的IP和埠
n = strMsgData.Find(":");
ip = strMsgData.Left(n);
port = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//向用戶回傳回應報文
this->StartSndSocket(PtoPsrvRspse,ip,port);
}
//ADD
//ADD
void CP2PTalkerDlg::SendMsgtoPer(CString strMsgData)
{
CString ip,port;
int n;
//從報文中決議出對方地址資訊
n = strMsgData.Find(",");
strMsgData = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//截取對方的IP和埠
n = strMsgData.Find(":");
ip = strMsgData.Left(n);
port = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//組裝出攜帶聊天資訊的訊息
UpdateData();
if(strMessage == "")
{
AfxMessageBox("不能發送空訊息!");
m_EditWords.SetFocus();
return;
}
CTime time = CTime::GetCurrentTime();
CString t = time.Format("%H:%M:%S");
MsgTalktoPeer = "SND_MSG;" + nickname + ",";
MsgTalktoPeer += t + "\r\n " + strMessage + "\r\n";
//向對方發送聊天資訊
this->StartSndSocket(MsgTalktoPeer,ip,port);
MsgTalktoPeer = "\r\n" + nickname + " " + t + "\r\n " + strMessage + "\r\n";
m_MessageList.ReplaceSel(MsgTalktoPeer);
strMessage = "";
UpdateData(FALSE);
m_EditWords.SetFocus();
}
void CP2PTalkerDlg::ShowMsgfrmPer(CString strMsgData)
{
CString usrname,MsgfrmPer,str;
int n;
//從報文中取出昵稱和聊天資訊欄位
n = strMsgData.Find(",");
usrname = strMsgData.Left(n);
MsgfrmPer = strMsgData.Right(strMsgData.GetLength() - (n + 1));
//聊天內容顯示
str = "\r\n" + usrname + " " + MsgfrmPer;
m_MessageList.ReplaceSel(str);
}
uj5u.com熱心網友回復：
先看連接是否建立成功，然后就是獲取資訊后，是如何顯示到控制元件的轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/147860.html
標籤：網絡編程