模拟UDP通信的发送与接收

亦凉 2022-03-06 13:20 635阅读 0赞

编译环境：系统:WIN7，Visual C++ 2015，创建ClientDlg对话框应用程序和创建ServerDlg的对话框程序

1、利用MFC创建一个CLidarReceiveDlg的对话框程序

2、设计发送端与接收端的界面，由于UDP通信是无连接，所以同一个程序即可当发送端与可当接收端

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70][]

图1、发送端与接收端的界面

3、给控件增加变量和处理函数，具体如下:

public:

CListBox m\_Message; //消息接收变量  
    CIPAddressCtrl m\_LocalIP; //本地IP地址变量  
    CEdit m\_LocalPort; //本地端口变量  
    CIPAddressCtrl m\_OtherIP; //目的地地址IP变量  
    CEdit m\_OtherPort; //目的地地址端口变量  
    CEdit m\_SendMessage; //发送信息变量  
    afx\_msg void OnBnStartInternect();  //启动网络按键  
    afx\_msg void OnBnStopInternect();  //停止网络按键  
    afx\_msg void OnBnSendMessage();  //发送信息按键  
    afx\_msg void OnBnStop();  //关闭软件按键  
    afx\_msg void OnBnAbout();    
public:  
    SOCKET Client;  
    SOCKET ServerSocket;  //定义Socket套接字  
    SOCKADDR\_IN m\_SocketServer;  //本地套接字通用地址结构  
    SOCKADDR\_IN m\_SocketTo;   //目的地套接字通用地址结构  
    MSG m\_message;    
    int m\_SocketLen;  //SOCKADDR\_IN结构体的大小  
private:  
    BYTE m\_SetIP\[4\];  //IP地址  
public:  
    afx\_msg void OnBnRecordClean();  //ClistBox框清空按键  
    LRESULT OnReadClose(WPARAM wParam, LPARAM lParam);  //接收数据函数  
    CButton m\_StartKey;  //启动按键变量  
    CButton m\_StopKey;   //停止按键变量  
    CButton m\_SendKey;   //发送数据变量

4、添加控件的处理函数

void CLidarReceiveDlg::OnBnStartInternect()  //网络启动函数，对应“启动”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    BYTE MIP\[4\];  //定义IP字节  
    char \*CharIP;  
    CString PortString, LocalIPString, LocalPort, InternectPort;  
    int ErrorCode;  
    DWORD m\_ip;  
    WSADATA WsaData;  
    UpdateData(TRUE);  
    if (m\_LocalIP.IsBlank())  
    \{  
        MIP\[0\] = m\_SetIP\[0\];  
        MIP\[1\] = m\_SetIP\[1\];  
        MIP\[2\] = m\_SetIP\[2\];  
        MIP\[3\] = m\_SetIP\[3\];  
        m\_LocalIP.SetAddress(MIP\[0\], MIP\[1\], MIP\[2\], MIP\[3\]);  //设置预先设置的IP地址  
        LocalIPString.Format(\_T("%d.%d.%d.%d"), MIP\[0\], MIP\[1\], MIP\[2\], MIP\[3\]);  
        m\_LocalPort.SetWindowTextW(\_T("2235"));  //设置预先设置的端口  
        m\_LocalIP.EnableWindow(FALSE);  
        m\_LocalPort.EnableWindow(FALSE);  
    \}  
    else  
    \{  
        m\_LocalIP.GetAddress(MIP\[0\], MIP\[1\], MIP\[2\], MIP\[3\]); //获取IP控件中的IP地址  
        m\_LocalIP.GetAddress(m\_ip);    
        LocalIPString.Format(\_T("%d.%d.%d.%d"), MIP\[0\], MIP\[1\], MIP\[2\], MIP\[3\]);  
        m\_LocalPort.GetWindowTextW(PortString); //获取端口号  
    \}  
    if (WSAStartup(MAKEWORD(2, 2), &WsaData)) //启动网络  
    \{  
        //AfxMessageBox(\_T("网络初始化失败"));  
        m\_Message.AddString(\_T("初始化Socket失败"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        WSACleanup();  
        return;  
    \}

m\_Message.AddString(\_T("创建Socket......"));  
    m\_Message.SetTopIndex(m\_Message.GetCount() - 1);

ServerSocket = socket(PF\_INET,SOCK\_DGRAM,0);  //创建一个Socket对象  
    if (ServerSocket == INVALID\_SOCKET)  
    \{  
        m\_Message.AddString(\_T("创建失败......"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}  
    USES\_CONVERSION;  
    CharIP = T2A(LocalIPString);  //把IP地址转化成Char类型  
    //strcpy(CharIP,(LPCTSTR)LocalIPString);  
    m\_LocalPort.GetWindowTextW(LocalPort);  //获取端口的端口号  
    m\_SocketServer.sin\_family = AF\_INET;  
    m\_SocketServer.sin\_addr.S\_un.S\_addr = inet\_addr(CharIP);  //把IP地址赋予IP通用结构体  
    m\_SocketServer.sin\_port = htons(\_ttoi(LocalPort));  //把端口号赋予IP地址通盈结构体  
      
    m\_SocketLen = sizeof(m\_SocketServer);  //获取IP地址通用结构体的大小

if (SOCKET\_ERROR == bind(ServerSocket, (LPSOCKADDR)&m\_SocketServer,sizeof(m\_SocketServer)))  //绑定IP地址  
    \{  
        m\_Message.AddString(\_T("绑定地址失败......"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}  
      
    ErrorCode = WSAAsyncSelect(ServerSocket,m\_hWnd,WM\_CLIENT\_READCLOSE,FD\_READ);  //设置接收回调函数  
    if (ErrorCode == SOCKET\_ERROR)  
    \{  
        m\_Message.AddString(\_T("WSAAsyncSelect函数出错！！！"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}

m\_Message.AddString(\_T("客户端网络初始化成功！！！"));  
    m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
    InternectPort.Format(\_T("IP:%d.%d.%d.%d 端口:%d"), MIP\[0\], MIP\[1\], MIP\[2\], MIP\[3\], \_ttoi(LocalPort));  
    m\_Message.AddString(InternectPort);  
    m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
    this->SetWindowTextW(\_T("本应用进程:"+InternectPort+""));  
    m\_StartKey.EnableWindow(FALSE);  
    m\_LocalIP.EnableWindow(FALSE);  
    m\_LocalPort.EnableWindow(FALSE);  
    //m\_SocketServer.sin\_addr.s\_addr = inet\_addr(LocalIPString);  
\}

void CLidarReceiveDlg::OnBnStopInternect()  //网络停止函数对应“停止”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    closesocket(ServerSocket);  //关闭网络  
    WSACleanup();  
    m\_Message.AddString(\_T("本网络进程停止运行......"));  
    m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
    m\_StartKey.EnableWindow(TRUE);  
    m\_LocalIP.EnableWindow(TRUE);  
    m\_LocalPort.EnableWindow(TRUE);  
\}

void CLidarReceiveDlg::OnBnSendMessage() //发送信息处理函数对应“发送”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    BYTE m\_IP\[4\];  
    CHAR \*CharMessage, \*CharIP;  
    CString SendIP, m\_SendMsg,IPString,m\_Port;  
    //UpdateData(TRUE);  
    m\_SendMessage.GetWindowTextW(m\_SendMsg);  //获取发送的信息  
    //m\_Message.AddString(\_T("发送信息为空！！！"));  
    if (m\_SendMsg.IsEmpty())  //判断发送的信息是否为空  
    \{  
        m\_Message.AddString(\_T("发送信息为空！！！"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}

m\_OtherPort.GetWindowTextW(m\_Port);  //获取目的地的端口号  
    USES\_CONVERSION;  
    CharMessage = T2A(m\_SendMsg);  //把发送的信息的格式转化为Char类型  
    m\_OtherIP.GetAddress(m\_IP\[0\], m\_IP\[1\], m\_IP\[2\], m\_IP\[3\]);  //  
    if (m\_OtherIP.IsBlank())  
    \{  
        m\_Message.AddString(\_T("IP地址为空！！！"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}  
    if (m\_Port.IsEmpty())  
    \{  
        m\_Message.AddString(\_T("端口号为空！！！"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return;  
    \}

IPString.Format(\_T("%d.%d.%d.%d"), m\_IP\[0\], m\_IP\[1\], m\_IP\[2\], m\_IP\[3\]);  
    CharIP = T2A(IPString);  //把发送地址转化成Char类型  
    m\_SocketTo.sin\_family = AF\_INET;  
    m\_SocketTo.sin\_addr.S\_un.S\_addr = inet\_addr(CharIP);  
    m\_SocketTo.sin\_port = htons(\_ttoi(m\_Port));  
    sendto(ServerSocket, CharMessage,strlen(CharMessage),0, (LPSOCKADDR)&m\_SocketTo,sizeof(m\_SocketTo));  //发动信息  
    m\_Message.AddString(\_T("发送:"+ m\_SendMsg +""));  
    m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
\}

void CLidarReceiveDlg::OnBnStop()  //对应“退出”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    CDialogEx::OnCancel();  //关闭软件  
\}

void CLidarReceiveDlg::OnBnAbout() //对应“关于”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    CAboutDlg aboutdlg;  
    aboutdlg.DoModal();  
\}

void CLidarReceiveDlg::OnBnRecordClean() //对应“清空记录”按键  
\{  
    // TODO: 在此添加控件通知处理程序代码  
    m\_Message.ResetContent(); //清空接收信息  
\}

5、UDP接收数据通过VC的宏映射机制接收信息

为了网络能够异步的接收信息需定义一个映射宏，该宏对应void CLidarReceiveDlg::OnBnStartInternect() 函数中的

WSAAsyncSelect(ServerSocket,m\_hWnd,WM\_CLIENT\_READCLOSE,FD\_READ)函数，其中WM\_CLIENT\_READCLOSE

就是自定义的宏。

自定义消息宏的步骤：

在头文件stdafx.h中定义：\#define WM\_CLIENT\_READCLOSE WM\_USER + 102

在CLidarReceiveDlg.cpp文件中BEGIN\_MESSAGE\_MAP与END\_MESSAGE\_MAP之间添加

ON\_MESSAGE(WM\_CLIENT\_READCLOSE,OnReadClose)，其中OnReadClose函数为宏WM\_CLIENT\_READCLOSE

的映射函数。

在CLidarReceiveDlg.h中定义LRESULT OnReadClose(WPARAM wParam, LPARAM lParam)映射函数

最后在在CLidarReceiveDlg.cpp文件中定义OnReadClose函数的实现如下所示：

LRESULT CLidarReceiveDlg::OnReadClose(WPARAM wParam, LPARAM lParam)  
\{  
    char rechar\[5000\] = \{0\};   //设置接收的缓冲区  
    CString stringchar;     
    int charlen;   //接收的字节数  
    if (WSAGETSELECTERROR(lParam))  //判断网络接收是否出错  
    \{  
        m\_Message.AddString(\_T("网络出错......"));  
        m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
        return 0;  
    \}

switch (WSAGETSELECTEVENT(lParam))  //  
    \{  
        case FD\_READ:  
            charlen = recvfrom(ServerSocket, rechar, 5000, 0, (LPSOCKADDR)&m\_SocketServer, (int\*)&m\_SocketLen);  //接收数据  
            if (charlen == SOCKET\_ERROR)  
            \{  
                m\_Message.AddString(\_T("接收失败......"));  
                m\_Message.SetTopIndex(m\_Message.GetCount() - 1);  
                return 0;  
            \}  
            rechar\[charlen\] = '\\0'; //缓冲区接收数据的最后一个字符后面加上一个结束符  
            stringchar = rechar;    //把缓冲区里面的char字符串转化成CString字符类型  
            stringchar.Format(\_T("收到:%s"), stringchar);    
            m\_Message.AddString(stringchar);  //把接收到的字符显示出来  
            m\_Message.SetTopIndex(m\_Message.GetCount() - 1);   
        break;

default:  
        break;  
    \}      
    return 0;  
\}

6、编译调试

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 1][]

图2编译成功之后的界面

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 2][]

图3、相互发送信息

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70]: /images/20220303/5699f7d5e0e1499c9676e365806a69b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 1]: /images/20220303/f781f875691148bb85d9242918f5b6c0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0OTExNjM2_size_16_color_FFFFFF_t_70 2]: /images/20220303/6a6476e815c7464eb6478885c9a8cad8.png