zoukankan      html  css  js  c++  java
  • 网络聊天室

    1网络聊天室项目描写叙述

    1.1功能描写叙述

    MyQQv1採用C/S模式,构建网络聊天室,详细实现功能:

    A.能显示在线用户列表

    B.能在聊天室里进行群聊天

    C.能指定用户进行私聊

    D.某用户下线。其它用户能接到提示

    1.2所需技术

    MFCSocket套接字,TCP/IP协议。动态数组,CString字符串拼接与拆分

    2网络聊天室执行流程图

    2.1server执行流程图



    2.2client执行流程图


    3网络聊天室具体

    3.1通信格式

    每次client与server之间的通信都是发送“START&命令&自己名字&消息&私密者&END”(为标准格式字符串)的字符串,然后接受方会进行切割和依照“&”进行分段解析。

    3.1.1消息切割

    当某次(在接受所有在线用户列表时)次接受不止一条格式字符串时。把整个字符串分割成若干个标准格式字符串。程序清单例如以下所看到的。

    /********************************************************************
    函数名称:MsgCut
    函数功能:把数据流按通信格式切割处理
    传入參数:CString strText
    返回值:  无
    ********************************************************************/
    void CClientSocket::MsgCut(CString strText)
    {
    	UINT nfirst , nlast;
    	CString strTmp;
    	while(strText.GetLength() > 9)
    	{
    		nfirst = strText.Find("START");
    		nlast  = strText.Find("END");
    		strTmp = strText.Mid(nfirst, nlast+3);//每次截取从START到END的字符串
    		char * sTran = strTmp.GetBuffer(0);//CString转化为char *型
    		MsgDeal(sTran);
    		strText = strText.Mid(nlast+3,strText.GetLength()-nlast-3);
    	}
    }

    nfirst得到“START”子串的起始位置,nlast得到“END”子串的起始位置,strTmp为“START”開始到“END”(包含末尾D)的一个标准格式字符串。再把原始长串切掉刚形成的strTmpstrText使用Mid(上一个EDN位置+3,总长度-上一个EDN位置-3)函数得到分割完的字符串,直到strText满足最小标准长度。

    3.1.2按“&”分段解析

    每一个标准格式字符串中包括命令,发来username,消息,私密者4个信息。

    它们依照“&”连接在一起,接收端要按“&”分段解析,程序清单例如以下。

    /***********************************************************************
    函数名称:MsgExplain
    函数功能:对消息的拆解,消息传来的格式是 k&1&username&说的话&私密的人
    传入參数:char sMsgDeal[5][BUFMAX],char * sMsgInit
    返回值:  无
    ***********************************************************************/
    void CClientSocket::MsgExplain(char sMsgDeal[6][BUFMAX],char * sMsgInit)
    {
    	char *p;
    	bool bFlg = FALSE;
    	int iRow = -1;
    	int iCol = 0;
    	char c = 0;
    
    	p=sMsgInit;
    	while (*p != '')
    	{
    		c = *p;
    		if ( c != '&')
    		{
    			if (bFlg == FALSE)//假设碰到新的单词列
    			{
    				bFlg = TRUE;
    				iRow++;
    				iCol = 0;
    			}
    			sMsgDeal[iRow][iCol] = c;
    			iCol++;
    		} 
    		else
    		{
    			if (bFlg == TRUE)
    			{
    				sMsgDeal[iRow][iCol]='';
    			}
    			bFlg = FALSE;
    		}
    		p++;
    		sMsgDeal[iRow][iCol] = '';
    	}
    }

    当中最后一句是当解析到最后一个单词的时候没有&,可是还是要在字符串的末尾加’’的字符串结束符。避免最后一个sMsgDeal[6]串出错。

    3.2server类

    3.2.1重载OnAccept函数

    server使用Create(PORT)开启成功后,使用Listen()进行监听,当有client进行连接请求后,发生OnAccept消息响应,此时重载OnAccept函数。

    /***********************************************************************
    函数名称:OnAccept
    函数功能:接受连接
    传入參数:int nErrorCode
    返回值:  无
    ***********************************************************************/
    void CServerSocket::OnAccept(int nErrorCode) 
    {
    	// TODO: Add your specialized code here and/or call the base class
    	CClientSocket *_pNewClient = new CClientSocket();
    	
    	_pNewClient->GetServerPointer(this);//!!这句话至关重要。把server的套接字绑定到此
    	Accept(*_pNewClient);
    	m_ClientArr.Add(_pNewClient);//接受一个连接把它增加到动态数组中
    	CSocket::OnAccept(nErrorCode);
    }

    新建一个CClientSocket套接字,把client的连接绑定到此套接字上,并把此套接字添加到动态数组中。相当于server端自从接受新的连接后就不再管理,后面的发送与接受都使用自己刚刚新建的CClientSocket套接字来完毕。

    3.2.2发送给指定用户

    server负责全部消息的转发,当有私密消息发来时,进行分类处理。有私密消息时,扫描动态数字。把私密者的名字与动态数组每一个套接字的名字进行比較。同样则进行转发。

    3.3client类

    3.3.1初次连接

    client连接成功。发送包括自己名字的标注格式字符串。例如以下程序清单所看到的。

    /***********************************************************************
    函数名称:OnButLink
    函数功能:client连接server
    传入參数:无
    返回值:  无
    ***********************************************************************/
    void CSetDlg::OnButLink() 
    {
    	// TODO: Add your control notification handler code here
    	CMyQQDlg *pParent = (CMyQQDlg*)this->GetParent(); 
    	
    	pParent->m_Client.Create();
    	//pParent->m_Client.SetDialog(pParent);  //设置套接字成员变量
    	UpdateData(TRUE);
    	pParent->m_Client.m_strUserName = m_sName;
    	if(pParent->m_Client.Connect(m_sServerIP,PORT))
    	{
    		MessageBox("连接server成功");
    		CString str;
    		pParent->m_Client.m_strUserName = m_sName;
    		str.Format("START&0&%s&0&0&END",m_sName);
    		pParent->m_Client.Send(str,str.GetLength());
    		pParent->m_cChoseFlg = 2;
    		pParent->SetWindowText("client——"+m_sName);
    	}
    	else
    	{
    		MessageBox("连接失败","警告");
    	}
    	EndDialog(0);
    }

    server端接受到新上线的username,把它赋给新建CClientSocketm_strUserName。使动态数组里每一个套接字都有一个m_strUserName与之相应,为私密信息做好准备。

    3.3.2重载OnReceive函数

    client接收到消息。产生OnReceive消息,这里进行重写,进行字符串的拆分与解析。程序清单例如以下。

    /***********************************************************************
    函数名称:OnReceive
    函数功能:client的接受消息的响应函数
    传入參数:int nErrorCode
    返回值:  无
    ***********************************************************************/
    void CClientSocket::OnReceive(int nErrorCode) 
    {
    	// TODO: Add your specialized code here and/or call the base class
    	char strText[512] = {0};
    
    	Receive(strText, 512);
    	MsgCut(strText);
    	CSocket::OnReceive(nErrorCode);
    }

    client接收到消息后。是产生了OnReceive消息。

    重载OnReceive函数,把每次得到字符串进行拆分解析。

    4网络聊天室执行情况







  • 相关阅读:
    Redis安装部署
    传输方式Topic和Queue的对比
    Hudson配置及使用
    linux 绿色版 bes 6.6服务安装
    LINUX磁盘管理
    并发用户数与 TPS 之间的关系
    性能测试场景
    计算并发用户数的五种方法
    让selenium自动化脚本运行的更快的技巧
    Jmeter学习
  • 原文地址:https://www.cnblogs.com/brucemengbm/p/7301047.html
Copyright © 2011-2022 走看看