MFC实现简单的聊天功能

不念不忘少年蓝@ 2022-04-17 05:10 325阅读 0赞

**设计目标：**

2.设计二  简单的即时通信软件（6学时实验）

目的与要求： 利用WinSock进行点对点通信，工作机制模仿即时通信软件的基本功能，登陆，上线，传递信息等等。分为客户部分和服务器部分两块，客户部分类似一般通信软件例如QQ,服务器部分主要提供客户端用户基本数据配置。

**服务端代码：**

#include <WinSock2.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <pthread.h> 
    #include <string>
    #include <sstream>
    #pragma comment(lib,"pthreadVC2.lib")
    #pragma comment(lib,"ws2_32.lib")
    #include<iostream>
    using namespace std;
    /*void* recv1(SOCKET sockConn)
    {  char recvBuf[10000];
    memset(recvBuf, 0, sizeof(recvBuf));
    //接收数据
    while(true){
    
    int nRecv = ::recv(sockConn, recvBuf, sizeof(recvBuf), 0);
    cout<<endl;
    if(nRecv>0)cout<<"他说："<<recvBuf<<endl;
    else break;}
    }*/
    SOCKET sockConn[10];
    char password[] = "123456";	
    int pass = 0;
    const int nl = 100;
    string user[nl] = { "123","456","789","张三" };
    string pw[nl] = { "111","456","789","张三" };
    int online[nl] = {0,0,0};//判断是否在线的数组
    int match[nl] = {-1,-1,-1};//表示第i个用户名匹配的是第几个套接字
    int find(string a[], string b)
    {
    	bool exist = false;
    	for (int j = 0; j<nl; j++)
    	{
    		if (a[j] == b)
    		{
    			exist = true;
    			return j;
    		}
    	}
    	if (!exist)
    		return -1;
    }
    int find1(SOCKET sock)
    {
    	for (int i = 0; i < 10; i++)
    	{
    		if (sock == sockConn[i])
    		{
    			return i;
    			break;
                
    		}
    	}
    	return -1;
    }
    int finds(string s)//根据用户名找到对应的套接字
    {
    	int index = find(user,s);
    	if (index >= 0)
    		return match[index];
    	else
    		return -1;
    }
    int  findu(SOCKET sock )//根据套接字找用户名在数组中的位置
    {
    	int index = find1(sock);
    	for (int i = 0; i < nl; i++)
    	{
    		if (match[i] == index)
    			return i;
    	}
    	return -1;
    }
    int nul_index(string a[])//查找string数组的空位，以便于用户注册的插入
    {
    	for (int i = 0; i < nl; i++)
    	{
    		if (a[i].empty())
    			return i;
    	}
    	return nl;//没有空位，注册已满
    }
    void* recv1(void* args)
    {
    	char recvBuf[10000];
    	char users[1000];
    	char pws[1000];
    	//接收数据
    	bool success = false;//判断是否登录成功 
    	int id1 = (unsigned int)pthread_getw32threadid_np(pthread_self()) / 2;
    	SOCKET sockConn1 = *((SOCKET*)args);//建立套接字
    	memset(recvBuf, 0, sizeof(recvBuf));
    	int rel = 0;
    	rel = recv(sockConn1, recvBuf, sizeof(recvBuf), 0);
    	if (rel<0)
    		cout << "接受失败\n";
    	cout << rel<<" "<<recvBuf<<endl;
    	send(sockConn1, "ack", sizeof(recvBuf),0);
    	//cout<<recvBuf<<endl;
    	if (strcmp(recvBuf, "1") == 0)//客户端选择登录 
    	{
    		cout << "选择登录服务\n";
    		memset(users, 0, sizeof(users));
    		rel = recv(sockConn1, users, sizeof(users), 0);
    		if (rel<0)//接受用户名 
    			cout << "recv failed";
    		cout <<rel<<" "<< users << endl;
    		send(sockConn1, "ack", sizeof(recvBuf),0);
    		int index = find(user, users);//判断能否找到用户名 
    		int sockNum = find1(sockConn1);
    		if (index != -1)//找到用户名      
    		{
    			if (online[index] == 0)
    			{
    
    				cout << "找到用户名" << endl;
    				memset(pws, 0, sizeof(pws));
    				if (recv(sockConn1, pws, sizeof(pws), 0) < 0)//接受密码 
    					cout << "recv failed";
    				cout << pws << endl;
    				if (pws == pw[index])//密码正确 
    				{   
    					online[index] = 1;
    					success = true;
    					match[index] = sockNum;
    					if (send(sockConn1, "密码正确", sizeof(recvBuf), 0) < 0)
    					{
    						cout << "发送失败";
    					}
    				}
    				else//密码错误 
    				{
    					send(sockConn1, "密码错误", sizeof(recvBuf), 0);
    				}
    			}
    			else 
    			{
    				memset(pws, 0, sizeof(pws));
    				if (recv(sockConn1, pws, sizeof(pws), 0)<0)//接受密码 
    					cout << "recv failed";
    				if (send(sockConn1, "该用户已存在", sizeof(recvBuf), 0)<0)
    					cout << "发送失败";
    			}
    		}
    		if (index == -1)//未找到用户名 
    		{
    			memset(pws, 0, sizeof(pws));
    			if (recv(sockConn1, pws, sizeof(pws), 0)<0)//接受密码 
    				cout << "recv failed";
    			if (send(sockConn1, "用户名不存在", sizeof(recvBuf), 0)<0)
    					cout << "发送失败";
    		}
    		if (success)
    		{
    			char buf[1000];
    			int id = find1(sockConn1);
    			int n = findu(sockConn1);
    			const char*p=user[n].data();
    			//user[n].copy(p, 40, 0);//这里5，代表复制几个字符，0代表复制的位置  
    			//*(p + 40) = '\0';//要手动加上结束符
    
    			if (id >= 1)
    			{
    				for (int j = 1; j < id + 1; j++)//好友上线功能 
    				{
    
    					if (send(sockConn[j - 1], p, sizeof(p), 0) < 0) //,sizeof(buf),0)<0)
    						cout << "send failed";
    					if (send(sockConn[j - 1], "已上线", sizeof(buf), 0) < 0)
    						cout << "send failed";
    				}
    			}
    			while (true)
    			{
    				memset(recvBuf, 0, sizeof(recvBuf));
    				recv(sockConn1,recvBuf,sizeof(recvBuf),0);//接受要发送的用户名
    				int index = find(user,recvBuf);//查找要发送用户名的位置
    				if(strcmp(recvBuf, "all") == 0)//实现群发
    				{
    					memset(recvBuf, 0, sizeof(recvBuf));
    					recv(sockConn1, recvBuf, sizeof(recvBuf), 0);
    					for (int i = 0; i < nl; i++)
    					{
    						if (online[i] == 1&&i!=findu(sockConn1))
    						{
    							string a = user[n] + ": ";
    							const char* pp = a.data();
    							sockNum = finds(user[i]);
    							if (send(sockConn[sockNum], pp, sizeof(pp), 0) < 0) //,sizeof(buf),0)<0)
    								cout << "send failed";
    							send(sockConn[sockNum], recvBuf, sizeof(recvBuf), 0);
    						}
    					}
    				}
    				else
    				{
    					if (strcmp(recvBuf, "退出") == 0)//用户选择退出
    					{
    
    						int i = findu(sockConn1);
    						online[i] = 0;
    						closesocket(sockConn1);
    					}
    					if (online[index]==1&&index != -1)
    					{
    
    						int sockNum = match[index];//找到此用户名的套接
    						
    						int nRecv = ::recv(sockConn1, recvBuf, sizeof(recvBuf), 0);
    						cout << endl;
    						if (nRecv > 0)//实现转发给其他客户端 
    						{
    							string a=user[n] +": ";//实现能看到是谁发的
    							cout << id1 << "号客户说：" << recvBuf << endl;
    							const char* ppp = a.data();
    							send(sockConn[sockNum], ppp, sizeof(recvBuf), 0);
    							send(sockConn[sockNum], recvBuf, sizeof(recvBuf), 0);
    							//send(sockConn1, "发送的用户名存在", sizeof(recvBuf), 0);
    							//if (send(sockConn[0], recvBuf, sizeof(recvBuf), 0) < 0)
    								//cout << "发送失败";
    
    							//send(sockConn[0], recvBuf, sizeof(recvBuf), 0);
    						}
    						else
    							break;
    
    					}
    					if (online[index] == 0&&index!=-1)
    					{
    						memset(recvBuf, 0, sizeof(recvBuf));
    						recv(sockConn1, recvBuf, sizeof(recvBuf), 0);
    						send(sockConn1, "用户不在线", sizeof(recvBuf), 0);
    					}
    					if(index==-1)//发送的用户名不存在
    					{
    						memset(recvBuf, 0, sizeof(recvBuf));
    						recv(sockConn1, recvBuf, sizeof(recvBuf), 0);
    						send(sockConn1, "发送的用户名不存在", sizeof(recvBuf), 0);
    					}
    					
    				}
    				
    			}
    
    		}
    	}
    	if (strcmp(recvBuf, "2") == 0) //客户端选择注册
    	{
    		cout << "选择注册服务" << endl;
    		memset(users, 0, sizeof(users));
    		if (recv(sockConn1, users, sizeof(users), 0) < 0)//接收用户名
    			cout << "register failed" << endl;
    		int index = find(user, users);//看看是否已存在用户名
    		send(sockConn1, "ack", sizeof(recvBuf), 0);
    									  //cout << index <<users << endl;
    		if (index != -1)//find
    		{
    			cout << "用户名已存在" << endl;
    			if (send(sockConn1, "用户名已存在", sizeof(recvBuf), 0) < 0)
    			{
    				cout << "用户注册失败" << endl;
    			}
    		}
    		if (index == -1)//register
    		{
    			cout << "用户名未注册过" << endl;
    			memset(pws, 0, sizeof(pws));
    			if (recv(sockConn1, pws, sizeof(pws), 0) < 0)//接收密码
    				cout << "failed pws" << endl;
    			else//接收密码 添加用户和密码
    			{
    				cout << "已经接收到密码" << pws << endl;
    				int location = nul_index(user);//寻找可以插入的空位
    				cout << "找到空位在1+" << location << endl;
    				if (location == nl)//插入已满
    				{
    					cout << "注册已满" << endl;
    					if (send(sockConn1, "注册已满", sizeof(recvBuf), 0) < 0)//发给客户已满信息
    						cout << "send failed" << endl;
    				}
    				else//注册
    				{
    					cout << "开始注册：" << endl;
    					user[location] = users;
    					pw[location] = pws;
    					cout << pw[location] << "aaa" << user[location] << endl;
    					if (send(sockConn1, "注册成功", sizeof(recvBuf), 0) < 0)//发给客户已满信息
    						cout << location + 1 << "位用户" << "注册成功" << endl;
    				}
    
    			}
    
    		}
    	}
    	return recvBuf;
    }
    void* send1(void* args) {
    	int id2 = (unsigned int)pthread_getw32threadid_np(pthread_self()) / 2;
    
    	SOCKET sockClient1 = *((SOCKET*)args);//建立套接字
    	char buff1[10000];
    
    
    	while (true) {
    
    		//cout<<"请输入"<<endl;
    		cin >> buff1;
    		if (buff1 == "") {
    			break;
    		}
    		int e = send(sockConn[0], buff1, sizeof(buff1), 0);
    		if (e == SOCKET_ERROR) {
    			printf("send failed");
    			break;
    		}
    		/*e = send(sockConn[1], buff1, sizeof(buff1), 0);
    		if (e == SOCKET_ERROR) {
    			printf("send failed");
    			break;
    		}
    		cout << "我说：" << buff1 << endl;*/
    	}
    	return buff1;
    }
    void* setClient(void* args)
    {
    	char buf[10000] = "Server: hello, I am a server.....";
    	SOCKET sockClient = *((SOCKET*)args);//建立套接字
    										 // printf("Accept client IP:[%s]\n", inet_ntoa(addrClient.sin_addr));
    										 //发送数据
    										 //send1(sockConn);
    	
    	int iSend = send(sockClient, buf, sizeof(buf), 0);
    	if (iSend == SOCKET_ERROR) {
    		printf("send failed");
    
    	}
    	
    	pthread_t tidss[2];
    	int ret = pthread_create(&tidss[0], NULL, send1, (void*)&sockClient); //参数：创建的线程id，线程参数，线程运行函数的起始地址，运行函数的参数
    	if (ret != 0) //创建线程成功返回0
    	{
    		cout << "pthread_create error:error_code=" << ret << endl;
    	}
    	recv1((void*)&sockClient);
    	return buf;
    }
    int main()
    {
    	WSADATA wsaData;//WSADATA结构被用来保存函数WSAStartup返回的Windows Sockets初始化信息
    	int port = 5099;
    
    	char buf[] = "Server: hello, I am a server.....";
    
    	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) //加载套接字库
    	{
    		printf("Failed to load Winsock");
    		return 0;
    	}
    
    	//创建用于监听的套接字
    	SOCKET sockSrv = socket(AF_INET, SOCK_STREAM, 0);//ipv4协议，流式传输 
    	SOCKADDR_IN addrSrv;//此数据结构用做bind、connect、recvfrom、sendto等函数的参数，指明地址信息。 
    	addrSrv.sin_family = AF_INET;
    	addrSrv.sin_port = htons(port); //1024以上的端口号
    	addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY); //INADDR_ANY 代表任意ip
    													  //绑定套接字 
    	int retVal = bind(sockSrv, (LPSOCKADDR)&addrSrv, sizeof(SOCKADDR_IN));
    	if (retVal == SOCKET_ERROR) {
    		printf("Failed bind:%d\n", WSAGetLastError());
    		return 0;
    	}
    
    	if (listen(sockSrv, 10) == SOCKET_ERROR) {//10代表允许连接的个数
    		printf("Listen failed:%d", WSAGetLastError());
    		return 0;
    	}
    
    	SOCKADDR_IN addrClient;
    	int len = sizeof(SOCKADDR);
    
    	int i = 0;
    	while (1)
    	{
    		//等待客户请求到来
    		sockConn[i] = accept(sockSrv, (SOCKADDR *)&addrClient, &len);//会阻塞进程，直到有客户端连接上来为止
    		if (sockConn[i] == SOCKET_ERROR) {
    			printf("Accept failed:%d", WSAGetLastError());
    			break;
    		}
    		pthread_t tids[10];
    		int res = pthread_create(&tids[i], NULL, setClient, (void*)&sockConn[i]);
    		if (res != 0) //创建线程成功返回0
    		{
    			cout << "pthread_create error:error_code=" << res << endl;
    		}
    		i++;
    	}
    
    	closesocket(sockSrv);
    	WSACleanup();
    	system("pause");
    	return 1;
    }

客户端核心代码：

界面1：

// connent1Dlg.cpp: 实现文件
    //
    
    #include "stdafx.h"
    #include "connent1.h"
    #include "connent1Dlg.h"
    #include "afxdialogex.h"
    #include <WinSock2.h>
    #include <stdio.h> 
    #include <pthread.h>
    #include <io.h>  
    #include <fcntl.h>
    #pragma comment(lib, "pthreadVC2.lib")
    #pragma comment(lib, "ws2_32.lib")
    #include<iostream>
    #include "Cmessage.h"
    using namespace std;
    #ifdef _DEBUG
    #define new DEBUG_NEW
    #endif
    
    
    char user[10];
    char pw[20];
    Cmessage  Dlg;
    int num;
    char buff[1000];
    char nUser[1000];
    //SOCKET sockClient;
    bool success = false;
    class CAboutDlg : public CDialogEx
    {
    public:
    	CAboutDlg();
    
    // 对话框数据
    #ifdef AFX_DESIGN_TIME
    	enum { IDD = IDD_ABOUTBOX };
    #endif
    
    	protected:
    	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持
    
    // 实现
    protected:
    	DECLARE_MESSAGE_MAP()
    };
    
    CAboutDlg::CAboutDlg() : CDialogEx(IDD_ABOUTBOX)
    {
    }
    
    void CAboutDlg::DoDataExchange(CDataExchange* pDX)
    {
    	CDialogEx::DoDataExchange(pDX);
    }
    
    BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
    END_MESSAGE_MAP()
    
    
    // Cconnent1Dlg 对话框
    
    
    
    Cconnent1Dlg::Cconnent1Dlg(CWnd* pParent /*=nullptr*/)
    	: CDialogEx(IDD_CONNENT1_DIALOG, pParent)
    	, m_user(_T(""))
    	, m_pw(_T(""))
    	//, m_show(_T(""))
    	//, m_message(_T(""))
    	//, sUser(_T(""))
    	//, suser(_T(""))
    {
    	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
    }
    
    void Cconnent1Dlg::DoDataExchange(CDataExchange* pDX)
    {
    	CDialogEx::DoDataExchange(pDX);
    	//DDX_Control(pDX, IDC_EDIT1, user);
    	DDX_Text(pDX, IDC_EDIT2, m_pw);
    	DDX_Text(pDX, IDC_EDIT1, m_user);
    	//DDX_Text(pDX, IDC_EDIT3, m_show);
    	//DDX_Text(pDX, IDC_EDIT4, m_message);
    	//DDX_Control(pDX, IDC_EDIT3, edit3);
    	//DDX_Text(pDX, IDC_EDIT5, sUser);//之前的类变量用户名重复。不区分大小写
    	//DDX_Text(pDX, IDC_EDIT7, suser);
    	//DDX_Control(pDX, IDC_COMBO1, m_chosecom);
    }
    
    BEGIN_MESSAGE_MAP(Cconnent1Dlg, CDialogEx)
    	ON_WM_SYSCOMMAND()
    	ON_WM_PAINT()
    	ON_WM_QUERYDRAGICON()
    	ON_EN_CHANGE(IDC_EDIT1, &Cconnent1Dlg::OnEnChangeEdit1)
    	ON_BN_CLICKED(IDC_BUTTON1, &Cconnent1Dlg::OnBnClickedButton1)
    	//ON_BN_CLICKED(IDC_BUTTON2, &Cconnent1Dlg::OnBnClickedButton2)
    	ON_BN_CLICKED(IDC_BUTTON3, &Cconnent1Dlg::OnBnClickedButton3)
    	//ON_CBN_SELCHANGE(IDC_COMBO1, &Cconnent1Dlg::OnCbnSelchangeCombo1)
    END_MESSAGE_MAP()
    
    
    // Cconnent1Dlg 消息处理程序
    
    BOOL Cconnent1Dlg::OnInitDialog()
    {
    	CDialogEx::OnInitDialog();
    
    	// 将“关于...”菜单项添加到系统菜单中。
    
    	// IDM_ABOUTBOX 必须在系统命令范围内。
    	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
    	ASSERT(IDM_ABOUTBOX < 0xF000);
    
    	CMenu* pSysMenu = GetSystemMenu(FALSE);
    	if (pSysMenu != nullptr)
    	{
    		BOOL bNameValid;
    		CString strAboutMenu;
    		bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
    		ASSERT(bNameValid);
    		if (!strAboutMenu.IsEmpty())
    		{
    			pSysMenu->AppendMenu(MF_SEPARATOR);
    			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
    		}
    	}
    
    	// 设置此对话框的图标。  当应用程序主窗口不是对话框时，框架将自动
    	//  执行此操作
    	SetIcon(m_hIcon, TRUE);			// 设置大图标
    	SetIcon(m_hIcon, FALSE);		// 设置小图标
    
    	// TODO: 在此添加额外的初始化代码
    	//edit3 = (CEdit *)GetDlgItem(IDC_EDIT3);
    	//GetDlgItem(IDC_EDIT4)->SetWindowText(_T("this is a test program!"));
    	return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
    }
    
    void Cconnent1Dlg::OnSysCommand(UINT nID, LPARAM lParam)
    {
    	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
    	{
    		CAboutDlg dlgAbout;
    		dlgAbout.DoModal();
    	}
    	else
    	{
    		CDialogEx::OnSysCommand(nID, lParam);
    	}
    }
    
    // 如果向对话框添加最小化按钮，则需要下面的代码
    //  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序，
    //  这将由框架自动完成。
    
    void Cconnent1Dlg::OnPaint()
    {
    	if (IsIconic())
    	{
    		CPaintDC dc(this); // 用于绘制的设备上下文
    
    		SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);
    
    		// 使图标在工作区矩形中居中
    		int cxIcon = GetSystemMetrics(SM_CXICON);
    		int cyIcon = GetSystemMetrics(SM_CYICON);
    		CRect rect;
    		GetClientRect(&rect);
    		int x = (rect.Width() - cxIcon + 1) / 2;
    		int y = (rect.Height() - cyIcon + 1) / 2;
    
    		// 绘制图标
    		dc.DrawIcon(x, y, m_hIcon);
    	}
    	else
    	{
    		CDialogEx::OnPaint();
    	}
    }
    
    //当用户拖动最小化窗口时系统调用此函数取得光标
    //显示。
    HCURSOR Cconnent1Dlg::OnQueryDragIcon()
    {
    	return static_cast<HCURSOR>(m_hIcon);
    }
    
    
    
    void Cconnent1Dlg::OnEnChangeEdit1()
    {
    	// TODO:  如果该控件是 RICHEDIT 控件，它将不
    	// 发送此通知，除非重写 CDialogEx::OnInitDialog()
    	// 函数并调用 CRichEditCtrl().SetEventMask()，
    	// 同时将 ENM_CHANGE 标志“或”运算到掩码中。
    
    	// TODO:  在此添加控件通知处理程序代码
    }
    
    
    void Cconnent1Dlg::OnBnClickedButton1()
    {
    	// TODO: 在此添加控件通知处理程序代码
    	UpdateData(true);
    
    	
    	//加载套接字
    	WSADATA wsaData;
    	char buff[10000];
    	memset(buff, 0, sizeof(buff));
    
    	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
    	{
    		printf("Failed to load Winsock");
    		//return 0;
    	}
    
    	SOCKADDR_IN addrSrv; //服务端地址
    	addrSrv.sin_family = AF_INET;
    	addrSrv.sin_port = htons(5099);
    	addrSrv.sin_addr.S_un.S_addr = inet_addr("127.0.0.1 ");
    
    	//创建客户端套接字
    	 sockClient = socket(AF_INET, SOCK_STREAM, 0);//流步套接字
    	if (SOCKET_ERROR == sockClient) {
    		printf("Socket() error:%d", WSAGetLastError());
    		//return 0;
    	}
    
    	//向服务器发出连接请求
    	if (connect(sockClient, (struct  sockaddr*)&addrSrv, sizeof(addrSrv)) == INVALID_SOCKET) {
    		printf("Connect failed:%d", WSAGetLastError());
    		//return 0;
    	}
    	else
    	{   //先来一个把CString转换成char*方法
    		/*int i;
    		for (i = 0; i < m_user.GetLength(); i++) 
    		{
    			user[i] = (char)(m_user.GetAt(i));
    		}          
    		user[i] = '\0';
    		i = 0;
    		for (i = 0; i < m_pw.GetLength(); i++)
    		{
    			pw[i] = (char)(m_pw.GetAt(i));
    		}
    		pw[i] = '\0';*/
    		wchar_t *ptr1, *ptr2;
    		ptr1 = m_user.GetBuffer(m_user.GetLength() * sizeof(wchar_t));
    		WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr1, -1, user, sizeof(user), NULL, NULL);
    		m_user.ReleaseBuffer();
    		ptr2 = m_pw.GetBuffer(m_pw.GetLength() * sizeof(wchar_t));
    		WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr2, -1, pw, sizeof(pw), NULL, NULL);
    		m_pw.ReleaseBuffer();
    		recv(sockClient, buff, sizeof(buff), 0);
    		//printf("%s\n", buff);
    		int number;
    		    send(sockClient, "1", sizeof(user), 0);//发送服务情况 
    			//Sleep(1000);
    			recv(sockClient, buff, sizeof(buff), 0);
    			send(sockClient, user, sizeof(user), 0);//发送用户名 
    				//cout << "send user failed";
    			//Sleep(1000);
    			recv(sockClient, buff, sizeof(buff), 0);
    		    send(sockClient, pw, sizeof(pw), 0);
    			//Sleep(1000);
    				//cout << "send pw failed";
    			//recv(sockClient, buff, sizeof(buff), 0);
    			memset(buff, 0, sizeof(buff));
    			recv(sockClient, buff, sizeof(buff), 0);
    			if (strcmp(buff, "用户名不存在") == 0)
    			{
    				//cout << "用户名不存在";
    				AfxMessageBox(_T("用户名不存在！"));
    				//return ;
    			}
    		    if (strcmp(buff, "密码错误") == 0)
    			{
    				AfxMessageBox(_T("密码错误！"));
    				//return ;
    			}
    			if (strcmp(buff, "该用户已存在") == 0)
    			{
    				AfxMessageBox(_T("该用户已存在！"));
    				//return ;
    			}
    			if (strcmp(buff, "密码正确") == 0)
    			{
    				AfxMessageBox(_T("登录成功！"));
    				GetDlgItem(IDC_BUTTON1)->EnableWindow(FALSE);
    				success = true;
    			}
    			if (success)
    			{   
    				//AfxBeginThread(recv_thd, NULL);
    				//this->ShowWindows(SW_HIDE);//当前界面隐藏
    				  //需要添加该C***Dlg.h头文件，否则编译通不过
    				Dlg.sockClient1 = sockClient;
    				//Dlg.create();
    				//Dlg->Create(IDD_DIAGLOG_MAIN, GetDesktopWindow());
    				Dlg.DoModal();
    				/*pthread_t tids[10];
    				int res = pthread_create(&tids[0], NULL, recv1, (void*)&sockClient);
    				if (res != 0) //创建线程成功返回0
    				{
    					cout << "pthread_create error:error_code=" << res << endl;
    				}*/
    				
    				
    				//recv1((void*)&sockClient);
    				
    			}
    		//UpdateData(false);
    	}
    	
    	//关闭套接字
    	//closesocket(sockClient);
    	//WSACleanup();
    
    }
    void Cconnent1Dlg::Update(CString s)
    {
    	edit3.ReplaceSel(s);
    }
    /*void Cconnent1Dlg::OnBnClickedButton2()
    {
    	// TODO: 在此添加控件通知处理程序代码
    	UpdateData(true);
    	//num = (char)(.GetAt(0));
    	/*int i;
    	for (i = 0; i < m_message.GetLength(); i++)
    	{
    		buff[i] = (char)(m_message.GetAt(i));
    	}
    	buff[i] = '\0';
    	int i = 0;
    	memset(nUser,0,sizeof(nUser));
    	for (i=0; i < suser.GetLength(); i++)
    	{
    		nUser[i] = (char)(suser.GetAt(i));
    	}
    	nUser[i] = '\0';
    	//下面是将CString转为char*的方法
    	 wchar_t *ptr; ptr = m_message.GetBuffer(m_message.GetLength() * sizeof(wchar_t)); 
    	WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr, -1, buff, sizeof(buff), NULL, NULL);
    	m_message.ReleaseBuffer();
    	//char *buff1=(LPSTR)(LPCTSTR)m_message;
    	//buff[0] = num;
    	send(sockClient, nUser,sizeof(nUser), 0);
    	Sleep(1);
    	if (send(sockClient, buff, sizeof(buff), 0)<0)
    		AfxMessageBox(_T("发送失败！"));
    	
    		//AfxMessageBox(_T("发送成功！"));
    		//}
    	//memset(buff, 0, sizeof(buff));
    	//recv(sockClient,buff,sizeof(buff),0);
    	
    }*/
    
    
    void Cconnent1Dlg::OnBnClickedButton3()
    {
    	// TODO: 在此添加控件通知处理程序代码
    	UpdateData(true);
    
    	//加载套接字
    	WSADATA wsaData;
    	char buff[10000];
    	memset(buff, 0, sizeof(buff));//
    
    	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
    	{
    		printf("Failed to load Winsock");
    		//return 0;
    	}
    
    	SOCKADDR_IN addrSrv; //服务端地址
    	addrSrv.sin_family = AF_INET;
    	addrSrv.sin_port = htons(5099);
    	addrSrv.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    
    	//创建客户端套接字
    	sockClient = socket(AF_INET, SOCK_STREAM, 0);//流步套接字
    	if (SOCKET_ERROR == sockClient) {
    		printf("Socket() error:%d", WSAGetLastError());
    		//return 0;
    	}
    
    	//向服务器发出连接请求
    	if (connect(sockClient, (struct  sockaddr*)&addrSrv, sizeof(addrSrv)) == INVALID_SOCKET) {
    		printf("Connect failed:%d", WSAGetLastError());
    		//return 0;
    	}
    	else
    	{
    		wchar_t *ptr1,*ptr2; 
    		ptr1 = m_user.GetBuffer(m_user.GetLength() * sizeof(wchar_t));
    		WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr1, -1, user, sizeof(user), NULL, NULL);
    		m_user.ReleaseBuffer();
    		ptr2 = m_pw.GetBuffer(m_pw.GetLength() * sizeof(wchar_t));
    		WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr2, -1, pw, sizeof(pw), NULL, NULL);
    		m_pw.ReleaseBuffer();
    		recv(sockClient, buff, sizeof(buff), 0);
    		//发送给服务器注册信息
    		send(sockClient, "2", sizeof(user), 0);//发送请求服务类型，为1表示登录，为2表示注册
    		recv(sockClient,buff,sizeof(buff),0);
    		send(sockClient, user, sizeof(user), 0);//发送用户名 
    		recv(sockClient,buff,sizeof(buff),0);
    		send(sockClient, pw, sizeof(pw), 0);//发送密码
    		//清空buff以接收服务器传来的消息
    		memset(buff, 0, sizeof(buff));
    		recv(sockClient, buff, sizeof(buff), 0);
    		if (strcmp(buff, "用户名已存在") == 0)
    		{
    			AfxMessageBox(_T("用户名已存在！"));
    		}
    		else
    			if (strcmp(buff, "注册已满") == 0)
    			{
    				AfxMessageBox(_T("注册用户已满！"));
    			}
    			else
    				if (strcmp(buff, "注册成功") == 0)
    				{
    					AfxMessageBox(_T("注册成功！"));
    					success = true;
    				}
    	}
    }

界面2：

// Cmessage.cpp: 实现文件
    //
    
    #include "stdafx.h"
    #include "connent1.h"
    #include "Cmessage.h"
    #include "afxdialogex.h"
    #include <WinSock2.h>
    #include <stdio.h> 
    #include <pthread.h>
    #pragma comment(lib, "pthreadVC2.lib")
    #pragma comment(lib, "ws2_32.lib")
    #include<iostream>
    #include "connent1Dlg.h"
    using namespace std;
    // Cmessage 对话框
    char buff1[1000];
    char nUser1[1000];
    SOCKET sockClient2;
    char num;
    /*void* recv2(void* args)
    {
    	//SOCKET sockConn = *((SOCKET*)args);
    	//HWND hWnd = *((HWND *)args);
    
    	char recvBuf[10000];
    	//Cmessage * dlg = (Cmessage *)AfxGetApp()->GetMainWnd()->GetSafeHwnd();
    	
    	//HWND hWnd = ::FindWindow(NULL, _T("Dialog"));      //得到对话框的句柄
    	//Cmessage* pWnd = (Cmessage*)Cmessage::FromHandle(hWnd); //由句柄得到对话框的对象指针
    	//接收数据
    	if(hWnd==0)
    		AfxMessageBox(_T("获取当前句柄失败"));
    	while (hWnd!=0) {
    		memset(recvBuf, 0, sizeof(recvBuf));
    		int nRecv = ::recv(sockClient2, recvBuf, sizeof(recvBuf), 0);
    		if (nRecv > 0)
    		{
    			if (strcmp(recvBuf, "发送的用户名不存在") == 0)//检测用户名是否存在
    
    			{
    				AfxMessageBox(_T("发送的用户名不存在！"));
    
    			}
    			else
    			{
    				CString a = CString(recvBuf) + _T("\n\r");
    				//AfxMessageBox(_T("接收成功"));
    				//Dlg->m_show = a;
    				//pWnd->m_show1=a;
    				pWnd->Update1(a);
    				//m_show = a;
    			}
    		}
    		else
    			break;
    	}
    	return recvBuf;
    }*/
    UINT Cmessage::recv3(LPVOID p)
    {
    	//SOCKET sockConn = *((SOCKET*)args);
    	//HWND hWnd = *((HWND *)p);
    
    	char recvBuf[10000];
    	Cmessage * dlg = (Cmessage *)p;
    
    	//HWND hWnd = ::FindWindow(NULL, _T("Dialog"));      //得到对话框的句柄
    	//Cmessage* pWnd = (Cmessage*)Cmessage::FromHandle(hWnd); //由句柄得到对话框的对象指针
    															//接收数据
    	//if (hWnd == 0)
    	//	AfxMessageBox(_T("获取当前句柄失败"));
    	while (true) {
    		memset(recvBuf, 0, sizeof(recvBuf));
    		int nRecv = ::recv(sockClient2, recvBuf, sizeof(recvBuf), 0);
    		if (nRecv > 0)
    		{
    			if (strcmp(recvBuf, "发送的用户名不存在") == 0)//检测用户名是否存在
    
    			{
    				AfxMessageBox(_T("发送的用户名不存在！"));
    
    			}
    			else if (strcmp(recvBuf, "用户不在线") == 0)//检测用户名是否存在
    
    			{
    				AfxMessageBox(_T("用户不在线！"));
    
    			}
    			     else
    			   {
    				CString a = CString(recvBuf) + _T(" ");
    				//AfxMessageBox(_T("接收成功"));
    				//Dlg->m_show = a;
    				//pWnd->m_show1=a;
    				dlg->Update1(a);
    				//m_show = a;
    			    }
    		}
    		else
    			break;
    	}
    	//return recvBuf;
    	return true;
    }
    
    IMPLEMENT_DYNAMIC(Cmessage, CDialogEx)
    
    Cmessage::Cmessage(CWnd* pParent /*=nullptr*/)
    	: CDialogEx(IDD_DIALOG1_MAIN, pParent)
    	, userNumber(_T(""))
    	, m_message1(_T(""))
    	, m_show1(_T(""))
    {
    	//Cconnent1Dlg *parent = (Cconnent1Dlg*)GetParent();
    	//sockClient = parent->sockClient;
    	//recv1(sockClient);
    }
    
    Cmessage::~Cmessage()
    {
    }
    
    void Cmessage::DoDataExchange(CDataExchange* pDX)
    {
    	CDialogEx::DoDataExchange(pDX);
    	DDX_Text(pDX, IDC_EDIT1, userNumber);
    	DDX_Text(pDX, IDC_EDIT2, m_message1);
    	DDX_Text(pDX, IDC_EDIT4, m_show1);
    	DDX_Control(pDX, IDC_EDIT4, edit4);
    }
    
    
    BEGIN_MESSAGE_MAP(Cmessage, CDialogEx)
    	ON_EN_CHANGE(IDC_EDIT2, &Cmessage::OnEnChangeEdit2)
    	ON_BN_CLICKED(IDC_BUTTON1, &Cmessage::OnBnClickedButton1)
    	ON_EN_CHANGE(IDC_EDIT4, &Cmessage::OnEnChangeEdit4)
    	ON_BN_CLICKED(IDC_BUTTON3, &Cmessage::OnBnClickedButton3)
    	ON_BN_CLICKED(IDC_BUTTON2, &Cmessage::OnBnClickedButton2)
    END_MESSAGE_MAP()
    
    
    // Cmessage 消息处理程序
    
    
    void Cmessage::OnEnChangeEdit2()
    {
    	// TODO:  如果该控件是 RICHEDIT 控件，它将不
    	// 发送此通知，除非重写 CDialogEx::OnInitDialog()
    	// 函数并调用 CRichEditCtrl().SetEventMask()，
    	// 同时将 ENM_CHANGE 标志“或”运算到掩码中。
    
    	// TODO:  在此添加控件通知处理程序代码
    
    }
    void Cmessage::Update1(CString s)
    {
    	edit4.ReplaceSel(s);
    }
    
    void Cmessage::OnBnClickedButton1()
    {
    
    	
    
    	
    	// TODO: 在此添加控件通知处理程序代码
    	// TODO: 在此添加控件通知处理程序代码
    	UpdateData(true);
    	//num = (char)(.GetAt(0));
    	//实现CString到char*的转化
    	wchar_t *ptr1; ptr1 = userNumber.GetBuffer(userNumber.GetLength() * sizeof(wchar_t));
    	WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr1, -1, nUser1, sizeof(nUser1), NULL, NULL);
    	userNumber.ReleaseBuffer();
    	wchar_t *ptr2; ptr2 = m_message1.GetBuffer(m_message1.GetLength() * sizeof(wchar_t));
    	WideCharToMultiByte(CP_ACP, 0, (LPCTSTR)ptr2, -1, buff1, sizeof(buff1), NULL, NULL);
    	m_message1.ReleaseBuffer();
    	//buff[0] = num;
    	send(sockClient2, nUser1, sizeof(nUser1), 0);
    	Sleep(1);
    	if (send(sockClient2, buff1, sizeof(buff1), 0)<0)
    		AfxMessageBox(_T("发送失败！"));
    
    	//AfxMessageBox(_T("发送成功！"));
    	//}
    	//memset(buff, 0, sizeof(buff));
    	//recv(sockClient,buff,sizeof(buff),0);
    
    }
    
    
    void Cmessage::OnEnChangeEdit4()
    {
    	// TODO:  如果该控件是 RICHEDIT 控件，它将不
    	// 发送此通知，除非重写 CDialogEx::OnInitDialog()
    	// 函数并调用 CRichEditCtrl().SetEventMask()，
    	// 同时将 ENM_CHANGE 标志“或”运算到掩码中。
    	// TODO:  在此添加控件通知处理程序代码
    
    }
    
    
    void Cmessage::OnBnClickedButton3()
    {
    	Cconnent1Dlg *parent = (Cconnent1Dlg*)GetParent();
    	sockClient2 = parent->sockClient;
    	AfxBeginThread(recv3, this);
    	GetDlgItem(IDC_BUTTON3)->EnableWindow(FALSE);
    	/*pthread_t tids[10];
    	int res = pthread_create(&tids[0], NULL, recv2, (void*)&this->m_hWnd);
    	if (res != 0) //创建线程成功返回0
    	{
    		cout << "pthread_create error:error_code=" << res << endl;
    	}
    	*/
    }
    
    
    void Cmessage::OnBnClickedButton2()
    {
    	// TODO: 在此添加控件通知处理程序代码
    	char a[100] = "退出";
    	send(sockClient2, a, sizeof(a), 0);
    	this->SendMessage(WM_CLOSE);
    	AfxGetMainWnd()->SendMessage(WM_CLOSE);
    
    }

主要效果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4MjQ3NTQ0_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4MjQ3NTQ0_size_16_color_FFFFFF_t_70 1][]

（主要实现后面补充。。。）

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4MjQ3NTQ0_size_16_color_FFFFFF_t_70]: /images/20220417/ad9b7c16970f470299c2d3958d4005eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4MjQ3NTQ0_size_16_color_FFFFFF_t_70 1]: /images/20220417/02c9a28fb4d84edbbd8aeed70ab65a9a.png