MFC TCP聊天程序，客户端为什么接受不到服务器发送的信息

客户端：//连接服务器端
void CChat_TCPClientDlg::OnButtonConnnet()
{
m_socket = socket(AF_INET,SOCK_STREAM,0);
int retconnect;
unsigned short temport;
UpdateData(TRUE);//刷新控件的值到变量上,刷新端口号
temport = (unsigned short)m_ClientPort;
DWORD dwIP;
((CIPAddressCtrl*)GetDlgItem(IDC_IPADDRESS))->GetAddress(dwIP);

sockaddr_in addrTo;
addrTo.sin_addr.S_un.S_addr = htonl(dwIP);
addrTo.sin_family = AF_INET;
addrTo.sin_port = htons(temport);

retconnect = connect(m_socket,(sockaddr*)&addrTo,sizeof(sockaddr));
if(SOCKET_ERROR == retconnect)
{
    SetDlgItemText(IDC_EDIT_STATE,"连接失败");
    return;
}
else
    SetDlgItemText(IDC_EDIT_STATE,"连接成功");

CButton *pButton=(CButton*)GetDlgItem(IDC_BUTTON_CONNNET);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_OUT);
pButton->EnableWindow(TRUE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_SEND);
pButton->EnableWindow(TRUE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_CLEAR);
pButton->EnableWindow(TRUE);


GetDlgItemText(IDC_EDIT_USERNAME,username);
char NewMember[200];
CTime tm=CTime::GetCurrentTime();
CString str=tm.Format("%Y-%m-%d %H:%M:%S");
sprintf(NewMember,"%s--->进入聊天室 %s",username,str);
send(m_socket,NewMember,sizeof(NewMember),0);


HANDLE thread;
thread=CreateThread(NULL,0,RecvProc,NULL,0,NULL);
CloseHandle(thread);

}

DWORD WINAPI CChat_TCPClientDlg::RecvProc(LPVOID lpParameter)
{
CChat_TCPClientDlg* pDlg = (CChat_TCPClientDlg*)(::AfxGetApp()->GetMainWnd());
SOCKET ClientSocket;
ClientSocket = pDlg->m_socket;
HWND hwnd = pDlg->m_hWnd;
int retrecv=0;
char recvbuf[1024];
while(1)
{
memset(recvbuf,0,sizeof(recvbuf));
retrecv = recv(ClientSocket,recvbuf,1024,0);
if(SOCKET_ERROR == retrecv)
{
::SetDlgItemText(hwnd,IDC_EDIT_STATE,"连接断开");
break;
}
else
{
pDlg->m_ListRecv.AddString(recvbuf);
pDlg->m_ListRecv.SetHorizontalExtent(10000);

    }
}
return 0;

}

void CChat_TCPClientDlg::OnButtonSend()
{
// TODO: Add your control notification handler code here
CString tempSend;
char strSend[300];
GetDlgItemText(IDC_EDIT_SEND,tempSend);
GetDlgItemText(IDC_EDIT_USERNAME,username);
sprintf(strSend,"%s说: %s",username,tempSend);
int retsend;
retsend = send(m_socket,strSend,strlen(strSend)+1,0);
if(retsend==SOCKET_ERROR)
{
CButton pButton=(CButton)GetDlgItem(IDC_BUTTON_OUT);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_SEND);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_CLEAR);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_CONNNET);
pButton->EnableWindow(TRUE);
SetDlgItemText(IDC_EDIT_STATE,"连接断开");
}
else
{
SetDlgItemText(IDC_EDIT_SEND,"");
}
}

void CChat_TCPClientDlg::OnButtonOut()
{
// TODO: Add your control notification handler code here
/* GetDlgItemText(IDC_EDIT_USERNAME,username);
char leavechar[50];
sprintf(leavechar,"%s<---离开聊天室",username);
send(m_socket,leavechar,sizeof(leavechar),0);*/

closesocket(m_socket);
SetDlgItemText(IDC_EDIT_STATE,"没有连接");
CButton *pButton=(CButton*)GetDlgItem(IDC_BUTTON_CONNNET);
pButton->EnableWindow(TRUE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_OUT);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_SEND);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_CLEAR);
pButton->EnableWindow(FALSE);

}

void CChat_TCPClientDlg::OnButtonClear()
{
// TODO: Add your control notification handler code here
m_ListRecv.ResetContent();
}
服务器：
// the minimized window.
HCURSOR CChat_TCPSrvDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}

BOOL CChat_TCPSrvDlg::InitSocket(unsigned short port)
{
//初始化连接套接字
ClientTotal = 0;
for(int i=0;i<20;i++)
{

ClientSocket[i] = 0;
ClientAddr[i] = "";
}

//创建绑定监听套接字
m_socket = socket(AF_INET,SOCK_STREAM,0);
if(INVALID_SOCKET==m_socket)
{
    SysStr = "创建socket失败";
    m_SysMsg.AddString(SysStr);
    return FALSE;
}
else
{
    SysStr = "创建socket成功";
    m_SysMsg.AddString(SysStr);
    m_SysMsg.SetHorizontalExtent(1000);
}

//地址族赋值
sockaddr_in addrsock;
addrsock.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
addrsock.sin_family = AF_INET;
addrsock.sin_port = htons(port);

//绑定套接字
int retbind;
retbind = bind(m_socket,(SOCKADDR*)&addrsock,sizeof(SOCKADDR));
if(SOCKET_ERROR==retbind)
{
    closesocket(m_socket);

    SysStr = "bind 失败";
    m_SysMsg.AddString(SysStr);
    SysStr = "启动失败";
    m_SysMsg.AddString(SysStr);
    return FALSE;
}
else
{
    SysStr = "bind成功";
    m_SysMsg.AddString(SysStr);
}

//设置监听模式
if(listen(m_socket,20)!=0)
{

    SysStr = "启动失败";
    m_SysMsg.AddString(SysStr);
    return FALSE;
}
else
{
    SysStr = "服务器启动成功";
    m_SysMsg.AddString(SysStr);
}

return TRUE;

}

//启动服务器
void CChat_TCPSrvDlg::OnButtonStart()
{
// TODO: Add your control notification handler code here
SrvState = TRUE;
ClientTotal = 0;
unsigned short temport;
BOOL InitSock;
UpdateData(TRUE);
temport = m_Port;
if(temport>=1025 && temport<=9999)
{
InitSock = InitSocket(temport); //调用初始化套接字

    //让“启动按钮”不可用，和让“关闭按钮”可用
    CButton *pButton=(CButton*)GetDlgItem(IDC_BUTTON_CLOSE);
    pButton->EnableWindow();
    pButton=(CButton*)GetDlgItem(IDC_BUTTON_START);
    pButton->EnableWindow(FALSE);

    //创建一级线程，用于监听用户的连接
    HANDLE hThread=CreateThread(NULL,0,AcceptClient,NULL,0,NULL);
    CloseHandle(hThread);
}
else
{
    SysStr="端口号不在使用范围内，启动失败";
    m_SysMsg.AddString(SysStr);
    m_SysMsg.SetHorizontalExtent(1000);
}

hMutex = CreateMutex(NULL,FALSE,NULL);

}

//一级线程,连接客户请求
DWORD WINAPI CChat_TCPSrvDlg::AcceptClient(LPVOID lpParameter)
{
CChat_TCPSrvDlg* pDlg = (CChat_TCPSrvDlg*)(::AfxGetApp()->GetMainWnd());
SOCKET socketacp = pDlg->m_socket;

sockaddr_in addrClient;
int len = sizeof(sockaddr);
while(pDlg->SrvState)
{
    pDlg->ClientSocket[pDlg->ClientTotal]=accept(socketacp,(SOCKADDR *)&addrClient,&len);
    WaitForSingleObject(pDlg->hMutex,INFINITE);
    pDlg->ClientTotal++;
    pDlg->SysStr = "新用户加入";
    pDlg->m_SysMsg.AddString(pDlg->SysStr);
    ReleaseMutex(pDlg->hMutex);
    if(pDlg->ClientTotal==1) //只是用来启动二级进程，当第二个客户端连接上后，if语句不执行，recv进程一直在执行
    {
        //创建二级线程，用于接收数据。
        HANDLE hThread=CreateThread(NULL,0,RecvProc,NULL,0,NULL);
        CloseHandle(hThread);
    }
}

return 0;

}

//二级线程，接收用户消息，并显示
DWORD WINAPI CChat_TCPSrvDlg::RecvProc(LPVOID lpParameter)
{
CChat_TCPSrvDlg* pDlg1 = (CChat_TCPSrvDlg*)(::AfxGetApp()->GetMainWnd());
fd_set fsRead;
timeval tm = {0,10000};
char recvBuf[200];
while(pDlg1->SrvState)
{
FD_ZERO(&fsRead);
for(int m=0;m<(pDlg1->ClientTotal);m++) //对所有用户进行select监视
FD_SET((pDlg1->ClientSocket[m]),&fsRead);
int retRead = select(pDlg1->ClientTotal+1,&fsRead,NULL,NULL,&tm);

    if(SOCKET_ERROR == retRead)
        return 1;
    else
    {
        for(int index=0;index<(pDlg1->ClientTotal);index++)
        {
            if(FD_ISSET(pDlg1->ClientSocket[index],&fsRead))
            {
                memset(recvBuf,0,sizeof(recvBuf));
                recv(pDlg1->ClientSocket[index],recvBuf,sizeof(recvBuf),0);
                if(strlen(recvBuf)==0)          //判断用户是否退出
                {

                    pDlg1->SysStr = "有一个用户离开";
                    pDlg1->m_SysMsg.AddString(pDlg1->SysStr);
                    pDlg1->ClientSocket[index] = pDlg1->ClientSocket[pDlg1->ClientTotal-1]; //将最后一个放到刚刚退出的client那里去
                    pDlg1->ClientSocket[pDlg1->ClientTotal-1] = 0; //保证所有未退出的客户端都在前面
                    if(pDlg1->ClientTotal==0)
                        return 0;
                    pDlg1->ClientTotal--;
                }
                else
                {
                    pDlg1->m_UserMsg.AddString(recvBuf);
                    pDlg1->m_UserMsg.SetHorizontalExtent(10000);
                    for(int n=0;n<(pDlg1->ClientTotal);n++)
                    {
                            send(pDlg1->ClientSocket[n],recvBuf,sizeof(recvBuf),0);
                    }

                }
            }
        }
    }
}

return 0;

}

//关闭服务器
void CChat_TCPSrvDlg::OnButtonClose()
{
// TODO: Add your control notification handler code here
WaitForSingleObject(hMutex,INFINITE);

SysStr="服务器已关闭";
m_SysMsg.AddString(SysStr);
SrvState = FALSE;
for(int k=0;k<ClientTotal;k++)
    send(ClientSocket[k],"服务器已关闭,请断开服务器重新连接",sizeof("服务器已关闭,请断开服务器重新连接")+1,0);
closesocket(m_socket);
while(ClientTotal>0)
{
    closesocket(ClientSocket[ClientTotal-1]);
    ClientTotal--;
}
CButton *pButton=(CButton*)GetDlgItem(IDC_BUTTON_CLOSE);
pButton->EnableWindow(FALSE);
pButton=(CButton*)GetDlgItem(IDC_BUTTON_START);
pButton->EnableWindow();

}

void CChat_TCPSrvDlg::OnClickedButtonSend()
{
// TODO: 在此添加控件通知处理程序代码
CString tempSend;
char strSend[300];
GetDlgItemText(IDC_EDIT_SEND,tempSend);
sprintf(strSend,"服务器: %s",tempSend);
send(m_socket,strSend,strlen(strSend)+1,0);
m_UserMsg.AddString(strSend);
SetDlgItemText(IDC_EDIT_SEND,"");
}

void CChat_TCPSrvDlg::OnClickedButtonClear()
{
// TODO: 在此添加控件通知处理程序代码
m_UserMsg.ResetContent();
}
图片说明

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

2条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
ljheee 2017-04-11 08:58
关注
SetDlgItemText(IDC_EDIT_STATE,"连接成功");
这里会提示连接成功吗

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

tcp keepalive设置时需不需要客户端和服务器端都设置 mfc 服务器
2017-06-21 03:07

回答 1 已采纳 1，keepalive需要client和server同时配合，都设置，底层的tcp会根据keepalive来选择是否保持链接 2，用netstats查看server上的链接是否正常，是否有大量TIM
MFC, TCP/IP客户端连接失败，API 错误码1967541584 c++
2019-05-11 17:04

回答 2 已采纳两个计算机是不是在同一个网段，本省的网能不能联通，你用的端口号是多少，不要使用太大的端口号，不要多个程序监听同一个端口。除了系统的防火墙，还要检查路由器。
在MFC中使用fstream读取不到文件为什么？ mfc
2018-11-07 14:58

回答 1 已采纳最好把文件放在桌面上，而不是丢在用户根目录下，否则会没有权限。还有检查下文件是不是叫1.txt，有没有别的程序占用这个文件。
modbus tcp/rtu客户端服务端通讯程序合集（C#、c++、mfc）
2019-10-17 14:11

整理了大批资源代码，肯定让你满意，包含c#、c++、mfc、c的各类基本、有难度的代码，modbus tcp/rtu和tcp等，也有modbus的类库及仿真软件，过段时间，我会再整理内容写篇博客，并且把整理好注释的代码提供到博客里，...
MFC单文档应用程序修改图标、标题及版本信息 c++ mfc visual studio 有问必答
2021-09-25 23:56

回答 1 已采纳你是不会建单文档应用程序，还是不会修改图标、标题及版本信息呢？图标在资源视图中修改Icon的IDR_MAINFRAME;也可以自己做一个图标文件，然后直接替换res中与程序名称同名的ico文件版本信息
在MFC中编写TCP/IP服务器端时，遇到读取访问权限冲突的问题 c++ mfc tcp/ip 有问必答
2021-12-14 22:01

回答 1 已采纳你到OnAccept的时候才创建pSocket对象，那如果程序先执行OnBnClickedButtonSend，此时pSocket还是个垃圾值，自然会崩溃了。首先CSessionSocket *pSo
UDP聊天程序MFC编程如何使用多线程 c++
2016-05-21 13:30

回答 2 已采纳 http://blog.sina.com.cn/s/blog_73df887801019171.html http://blog.sina.com.cn/s/blog_73df8878010191q
MFC实现多个客户端通过服务器进行通信的Socket多线程编程
2015-12-14 23:19

2.服务端通过维护一张转发表来实现对客户端信息的转发，比如客户端A向客户端B发送消息，服务器接收到客户端A发过来消息内容和客户端B信息之后，通过转发表查找到客户端B的Socket，将内容转发给客户端B，实现客户端...
MFC 编辑框为什么不能输入获取不到焦点？ mfc
2017-05-10 07:37

回答 2 已采纳呃。。已经知道了。我在对话框添加了PreTranslateMessage消息，处理了那个编辑框区域，先是写了框架，还没具体编码就return了，结果忘了这茬。现在知道了
MFC控件绑定变量时候为什么找不到我建立的类别 mfc
2015-10-20 13:18

回答 3 已采纳先选择别的类型，然后再改成你的类型
MFC中为什么会有这么一个虚函数？ c++ mfc
2023-03-12 18:26

回答 2 已采纳在MFC框架中，OnInitDialog()是CDialog类的一个成员函数，用于初始化对话框。它被声明为虚函数是为了方便派生类对该函数进行重写以实现对话框的特定需求。虚函数的主要作用是实现多态，使
Tcp多人聊天窗口：MFC客户端（2）
2019-06-17 23:39

何其不顾四月天的博客上一篇说明了LinuxTcp服务端,这篇说一下,Windows客户端，MFC。环境 Windows系统:Win10 IDE:VS2008,MFC 思路 客户端思路如下：登录：客户端Tcp连接服务端成功后，可以登录服务端，登录成功主界面：类似于QQ，能...
socket服务器与客户端连接2小时以上无数据传输，服务器会主动断开客户端连接 mfc tcp/ip
2021-12-27 08:49

回答 1 已采纳建议你自己写一个心跳,不依赖tcp的那套东西,每隔一分钟或者几十秒发送一次,客户端发送过去,服务端再返回回来,报文弄小点就行,如果超过一定时间双方任意一方没有收到心跳,则断开连接重连.tcp长链接非常
18 MFC TCP和UDP 网络通信
2023-07-10 15:26

吃个糖糖的博客 / TCPChatServerDlg.cpp: 实现文件。// TCPChatClientDlg.cpp: 实现文件。// TCPChatServerDlg.h: 头文件。// TCPChatClientDlg.h: 头文件。...在服务器里面创建客户端类。有错误代码可以进行查找。
[MFC]MFC实现UDP客户端和服务端信息交互
2022-09-05 16:26

胡须不排序H的博客最近继续在学习MFC的相关操作,本次博客以实现一个UDP协议的服务端和客户端之间的信息交互,本博客将具体进行以下分析.接下来可能会接着学习MFC的相关操作,并结合Modbus相关的串口连接助手进行调试,持续关注不迷路!
没有解决我的问题, 去提问

悬赏问题

¥15 python：excel数据写入多个对应word文档
¥60 全一数分解素因子和素数循环节位数
¥15 ffmpeg如何安装到虚拟环境
¥188 寻找能做王者评分提取的
¥15 matlab用simulink求解一个二阶微分方程，要求截图
¥30 乘子法解约束最优化问题的matlab代码文件，最好有matlab代码文件
¥15 写论文，需要数据支撑
¥15 identifier of an instance of 类 was altered from xx to xx错误
¥100 反编译微信小游戏求指导
¥15 docker模式webrtc-streamer 无法播放公网rtsp

MFC TCP聊天程序，客户端为什么接受不到服务器发送的信息

2条回答 默认 最新

悬赏问题

2条回答默认最新