MFC(基于VS2013)连接下位机简单实例（下位机连接以及Socket数据发送接收）
很多人需要编写基于MFC的上位机程序，而这类程序首先要解决的就是网络通信的问题，这里也抽出一点时间写了一个简单的额范例，如果你的需求是如下几幅图片所示（这里用TCP调试助手模拟下位机，以便更清楚的看到我们发的信息），那么不妨可以下载下来看一看，程序的代码已经给了非常详细的注释，这里不再赘述，只放一些核心代码：
这里附上程序的下载地址，自己手工 码的程序，收一点点豆子，核心代码我也直接附出来：程序下载地址
TCP调试助手程序下载地址（必须要设置下载豆，这个软件大家也可以网上下载，豆多的掠过）：TCP/UDP调试助手下载地址
先说一下程序的运行平台，以免各位下载程序跑的时候出现莫名的报错，本程序已经经过VS2013编译通过及运行：
同时要设置本机的IP地址，比如我的这里设置的是：192.168.0.105，具体设置方法请百度：
TCP模拟调试助手时，我们选择创建服务器，具体创建过程见图：
创建成功后启动：
//设备连接按钮的代码
void CconnectDlg::OnBnClickedConnect()
{
// TODO: 在此添加控件通知处理程序代码
//测试能不能ping通
int ping_ok = 1;
CString serv_addr, serv_port;
SECURITY_ATTRIBUTES sa;
HANDLE hRead, hWrite;
sa.nLength = sizeof(SECURITY_ATTRIBUTES);
sa.lpSecurityDescriptor = NULL;
sa.bInheritHandle = TRUE;
CString filename = "ipconfig.ini";
CStdioFile mFileIP(filename, CFile::modeCreate | CFile::modeWrite);
//CString str_ip;
GetDlgItem(IDC_IP)->GetWindowText(serv_addr);
mFileIP.WriteString(serv_addr);
mFileIP.Close();
filename = "portconfig.ini";
CStdioFile mFilePort(filename, CFile::modeCreate | CFile::modeWrite);
GetDlgItem(IDC_Port)->GetWindowText(serv_port);
mFilePort.WriteString(serv_port);
mFilePort.Close();
CString strCmd;
strCmd = "cmd /k ping ";//加上"cmd /k"是为了能执行类似dir的命令
strCmd += serv_addr;
//创建命名管道
if (!CreatePipe(&hRead, &hWrite, &sa, 0)) {
return;
}
STARTUPINFO si;
PROCESS_INFORMATION pi;
si.cb = sizeof(STARTUPINFO);
GetStartupInfo(&si);
si.hStdError = hWrite;//数据输出用的文件句柄
si.hStdOutput = hWrite;//数据输出用的文件句柄
si.wShowWindow = SW_HIDE;
si.dwFlags = STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES;
OutputDebugString("1");
if (!CreateProcess(NULL, strCmd.GetBuffer(strCmd.GetLength())//执行cmd命令,并在命名中管道中写入cmd命令返回的串
, NULL, NULL, TRUE, NULL, NULL, NULL, &si, &pi)) {
return;
}
CloseHandle(hWrite);
OutputDebugString("2");
char buffer[4096] = { 0 };
DWORD bytesRead;
CString strResult = "";
while (1)
{
memset(buffer, 0, 4096);
if (ReadFile(hRead, buffer, 4096, &bytesRead, NULL) != NULL)//从命名管道中读取数据
{
if (buffer[18] == 'T')
{
ping_ok = 0;
int port;
SOCKADDR_IN addr;
WORD wVersionRequested;//定义socket1.1或者socket2.0
WSADATA wsaData; //定义装载socket版本的变量
int err; //错误变量
wVersionRequested = MAKEWORD(2, 2); //定义连接为socket2.0
err = WSAStartup(wVersionRequested, &wsaData); //装载socket2.0支持
if (0 != err)//判断是否装载成功
{
return;
}
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)//判断版本号，是否和定义的一样
{
WSACleanup(); //若出问题，卸载支持，并结束程序返回-1
return;
}
m_socket = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, 0);
if (INVALID_SOCKET == m_socket)
{
MessageBox("创建套接字失败！");
return;
}
if (SOCKET_ERROR == WSAAsyncSelect(m_socket, m_hWnd, WM_SOCK, FD_READ))
{
MessageBox("注册网络读取事件失败！");
return;
}
if (serv_port == "" || serv_addr == "")
{
MessageBox("服务器地址或端口不能为空！！！");//该函数功能是弹出一个显示s你写的这些内容的框
}
else
{
port = atoi(serv_port.GetBuffer(1));//将端口字符串转换为数字
addr.sin_family = AF_INET;
addr.sin_addr.S_un.S_addr = inet_addr(serv_addr.GetBuffer(1));//转换服务器ip地址
addr.sin_port = ntohs(port);
//设置非阻塞模式
unsigned long ul = 1;
int ret = ioctlsocket(m_socket, FIONBIO, (unsigned long*)&ul);
if (ret == SOCKET_ERROR)
exit(0);
if (::connect(m_socket, (SOCKADDR*)&addr, sizeof(SOCKADDR)))
{
CString Str;
}
else
{
}
}
break;
}
OutputDebugString(buffer);
}
else
{
break;
}
}
CloseHandle(hRead);
if (ping_ok)
{
MessageBox("设备连接出错，请检查连接!");
}
else
{
m_connect.EnableWindow(0);
m_cut.EnableWindow(1);
GetDlgItem(IDC_STATIC_SHOW)->SetWindowText(_T("设备已连接"));
AddToInfRec("设备已连接", IDC_Zhuangtai, TRUE, TRUE);
CString connected;
connected = "设备已经连接";
send(m_socket, connected, 50, 0);
MyDevFounded = TRUE;
}
}
//发送命令按钮代码
void CconnectDlg::OnBnClickedButtonSend()
{
// TODO: 在此添加控件通知处理程序代码
CString message, showtext, datatest;
GetDlgItem(IDC_EDIT_Send)->GetWindowText(message); //从发送数据的edit框中获取信息，存储到message变量中
if (MyDevFounded == FALSE) //进行设备连接状态的判断，通过设置MyDevFounded，初始值为false，设备连接成功后置true
{
AddToInfRec("设备未找到", IDC_Zhuangtai, TRUE, TRUE);//设备未成功连接，提示设备未找到
return;
}
if (message == "")
{
MessageBox("消息不能为空！"); //对发送数据框进行判断
}
else
{
AddToInfRec("发送数据：", IDC_Zhuangtai,0,0);
AddToInfRec(message, IDC_Zhuangtai,1,1); //显示发送的数据到状态框
::send(m_socket, message.GetBuffer(1), message.GetLength(), 0); //通过sock发送数据
}
}//onsock函数代码
afx_msg LRESULT CconnectDlg::OnSock(WPARAM wParam, LPARAM lParam)
{
char cs[512] = ""; //定义一个用来存放接收数据的字符串cs
if (lParam == FD_READ) //sock收到消息，触发FD_READ
{
if (SOCKET_ERROR == recv(m_socket, cs, 512, NULL))//使用recv函数来进行判别收到的内容
{
MessageBox("接收数据失败！"); //如果触发连接错误，则弹出接收数据失败提示框
return FALSE;
}
else{
AddToInfRec("接收数据：", IDC_EDIT_REC, 0, 0);
AddToInfOut(cs, TRUE, TRUE);//如果没有出现错误，将cs中的数据传递给AddToInfOut来进行处理
}
}
return 0;
}//数据处理函数代码
void CconnectDlg::AddToInfOut(CString InStr, BOOL AddTime, BOOL NewLine)
{
CString str, str1;
UINT i;
CHAR SysTime[10];
GetDlgItemText(IDC_EDIT_REC, str); //从数据接收的Edit框中获取已经接收到的信息
str += InStr; //新收到的信息通过InStr传递到本函数中，声明一个字符串str来存放，此条命令是将新收到的信息叠加到以前的信息中
//需要添加时间信息
if (AddTime == TRUE)
{
_strtime(SysTime);
str1 = SysTime;
str1 = " (" + str1 + ")";
str += str1;
}
//需要换行
if (NewLine == TRUE)
{
str += "\r\n";
}
//设置新的文本
SetDlgItemText(IDC_EDIT_REC, str); //将处理后的信息显示到接收的编辑框中
//滚动条自动滚动到最后一行
i = ((CEdit*)GetDlgItem(IDC_EDIT_REC))->GetLineCount();
((CEdit*)GetDlgItem(IDC_EDIT_REC))->LineScroll(i, 0);
}
查看7道真题和解析