按键盘上方向键 ← 或 → 可快速上下翻页,按键盘上的 Enter 键可回到本书目录页,按键盘上方向键 ↑ 可回到本页顶部!
————未阅读完?加入书签已便下次继续阅读!
TRY
{
//接收数据
pSocket…》ReceiveMsg(&msg);
//如果是新用户登录则更新用户列表
if(msg。code == SENDING_NICKNAME)
{
UpdateChattersListView(msg。m_strText ; pSocket);
}
//如果是普通信息则更新聊天信息列表,并将信息加入到 m_msgList 链表中
if(msg。code == NORMAL_MESSAGE)
{
UpdateMessageView(msg。m_strText);
m_msgList。AddTail(msg。m_strText);
}
}
CATCH(CFileException; e)
{
CString strTemp;
strTemp。Format(〃无法读取数据!〃);
UpdateMessageView(strTemp);
msg。m_bClose = TRUE;
}
END_CATCH
return &msg;
}
为 SendMsg()函数编写如下代码:
void CChatServerDoc::SendMsg(CClientSocket* pSocket; CMsg* pMsg)
·304 ·
…………………………………………………………Page 316……………………………………………………………
第 11 章 网络编程
{
TRY
{
//调用 CClientSocket 的函数发送消息
pSocket…》SendMsg(pMsg);
}
CATCH(CFileException; e)
{
CString strTemp;
strTemp。Format(〃无法发送数据!〃);
UpdateMessageView(strTemp);
}
END_CATCH
}
为函数 IsUsedName()编写如下代码:
BOOL CChatServerDoc::IsUsedName(CString sNickName)
{
CString tempStr; tempList; sName;
tempStr = 〃〃;
tempList = m_ChattersList;
do
{
//利用“:”得到名字并查找(客户端发送的消息前面都有用户名加“:”)
sName = tempList。Left(tempList。Find(〃:〃; 0));
tempList = tempList。Mid(tempList。Find(〃:〃; 0) + 1);
//找到则返回真
if(sName == sNickName)
return TRUE;
}while(tempList。Find(〃:〃 ; 0) != …1);
//未被使用则返回假
return FALSE;
}
为函数 AssembleMsg()编写如下代码:
CMsg* CChatServerDoc::AssembleMsg(CClientSocket* pSocket ; int nCode)
{
static CMsg msg;
msg。Init();
for (POSITION pos1 = m_msgList。FindIndex(pSocket…》m_nMsgCount); pos1 != NULL;)
{
//信息内容
·305 ·
…………………………………………………………Page 317……………………………………………………………
Visual C++ 6。0 程序设计从入门到精通
msg。m_strText = m_msgList。GetNext(pos1);
//信息类型
msg。code = nCode;
}
pSocket…》m_nMsgCount = m_msgList。GetCount();
return &msg;
}
为函数 SendForNewer()编写如下代码:
void CChatServerDoc::SendForNewer(CMsg* pMsg)
{
for(POSITION pos = m_connectionList。GetHeadPosition(); pos != NULL;)
{
//对每个客户端都发送信息
CClientSocket* pSocket = (CClientSocket*)m_connectionList。GetNext(pos);
if (pSocket != NULL)
SendMsg(pSocket; pMsg);
}
}
为函数 SendToAllClients()编写如下代码:
void CChatServerDoc::SendToAllClients(int nCode)
{
for(POSITION pos = m_connectionList。GetHeadPosition(); pos != NULL;)
{
//得到每个客户端
CClientSocket* pSocket = (CClientSocket*)m_connectionList。GetNext(pos);
//封装信息
CMsg* pMsg = AssembleMsg(pSocket; nCode);
//发送信息
if (pMsg != NULL)
SendMsg(pSocket; pMsg);
}
}
为函数 UpdateMessageView()编写如下代码:
void CChatServerDoc::UpdateMessageView(LPCTSTR lpszMessage)
{
for(POSITION pos=GetFirstViewPosition();pos!=NULL;)
{
CView* pView = GetNextView(pos);
CChatView* pChatView = DYNAMIC_DOWNCAST(CChatView; pView);
if (pChatView != NULL)
·306 ·
…………………………………………………………Page 318……………………………………………………………
第 11 章 网络编程
pChatView…》ShowMessage(lpszMessage);
}
}
为函数 UpdateChattersListView()编写如下代码:
void CChatServerDoc::UpdateChattersListView(CString sName ; CClientSocket* pSocket)
{
CString sIPAddress;
UINT iPort;
//得到 IP 地址和端口号
pSocket…》GetPeerName(sIPAddress ; iPort);
for(POSITION pos=GetFirstViewPosition();pos!=NULL;)
{
CView* pView = GetNextView(pos);
CChattersListView* pChattersListView = DYNAMIC_DOWNCAST(CChattersListView; pView);
//更新用户列表
if (pChattersListView != NULL)
pC