UDP 测试代码不接收消息 (C++)

Posted

技术标签:

【中文标题】UDP 测试代码不接收消息 (C++)【英文标题】：UDP test code not receiving messages (C++) 【发布时间】：2013-12-08 17:10:22 【问题描述】：

首先，请原谅这个烂摊子。我一直在尝试修改示例 UDP 代码以跨 windows/linux 工作。可能还有一些特定于 Windows 的代码仍然存在于我一直试图弄清楚到底出了什么问题的地方。

这是我第一次使用 UDP 而不是 TCP。

如果我取消注释客户端中的 recvfrom 内容，它会无限期地阻止服务器正在运行的 IFF。否则，它会立即返回，如预期的那样。 我似乎无法弄清楚，为什么我的服务器在当前状态下似乎根本无法从客户端接收任何内容。

我在这里错过了什么？

顺便说一句，我还应该提到，如果我从客户端中绑定 serverAddress 的套接字并尝试让它从自身接收（完全省略服务器），这样做没有问题。 （另外，我还没有在linux上尝试过这个版本。）

谢谢

服务器（接收方）：

#ifdef _WIN32 || _WIN64 || _WINDOWS_
#include <WinSock2.h>
#pragma comment(lib, "Ws2_32.lib")
#define __COMPILE_FOR_WINDOWS__
#define SOCKET_INVALID(s) (s==INVALID_SOCKET)
#define SOCKET_TYPE SOCKET
#endif
#ifdef linux
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#define SOCKET_INVALID(s) (s<0)
#define SOCKET_TYPE int
#endif

#include <iostream>

#define BUFFER_LENGTH  1024

int main(int argc, char** argv)


#ifdef __COMPILE_FOR_WINDOWS__
    WSADATA wsaData;
    if (WSAStartup(MAKEWORD(2, 2), &wsaData) != NO_ERROR)
    
        std::cerr << "could not start up winsock-2.2\n";
        return 1;
    
#endif 

    struct sockaddr_in serverAddress,
        clientAddress;
    unsigned short Port = 27015;
    char RecvBuf[BUFFER_LENGTH];

    SOCKET_TYPE socketHandle = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP/* or 0? */);
    if (SOCKET_INVALID(socketHandle))
    
        std::cerr << "could not make socket\n";
        return 1;
    

    memset(&serverAddress, 0, sizeof(serverAddress));
    serverAddress.sin_family = AF_INET;
    serverAddress.sin_port = htons(Port);
    serverAddress.sin_addr.s_addr = htonl(INADDR_ANY);

    if (bind(socketHandle, (struct sockaddr*)&serverAddress, sizeof(serverAddress)) != 0)
    
        std::cerr << "could not bind socket\n";
        return 1;
    

    int len;
    int client_addr_len;// = sizeof(clientAddress);
    while (1)
    
        len = recvfrom(socketHandle,RecvBuf,BUFFER_LENGTH,0,(struct sockaddr*)&clientAddress,&client_addr_len);
        if (strncmp(RecvBuf,"END",3)==0) 
            break;
        if (len > 0)
        
            //sendto(socketHandle, RecvBuf, len, 0, (struct sockaddr*)&clientAddress, sizeof(clientAddress));
            RecvBuf[len] = 0;
            std::cout << "received: " << RecvBuf << std::endl;
        
    

#ifdef __COMPILE_FOR_WINDOWS__
    closesocket(socketHandle);
    WSACleanup();
#endif
#ifdef linux
    close(socketHandle);
#endif
    std::cout<< "done\n";
    return 0;


#ifdef __COMPILE_FOR_WINDOWS__
#undef __COMPILE_FOR_WINDOWS__
#endif

#undef BUFFER_LENGTH
#undef SOCKET_INVALID

#ifdef SOCKET_TYPE
#undef SOCKET_TYPE
#endif

客户（发件人）：

#ifdef _WIN32 || _WIN64 || _WINDOWS_
#include <WinSock2.h>
#pragma comment(lib, "Ws2_32.lib")
#define __COMPILE_FOR_WINDOWS__
#define SOCKET_INVALID(s) (s==INVALID_SOCKET)
#define SOCKET_TYPE SOCKET
#endif
#ifdef linux
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>
#define SOCKET_INVALID(s) (s<0)
#define SOCKET_TYPE int
#endif

#include <iostream>

#define BUFFER_LENGTH  1024

int main(int argc, char** argv)


#ifdef __COMPILE_FOR_WINDOWS__
    WSADATA wsaData;
    if (WSAStartup(MAKEWORD(2, 2), &wsaData) != NO_ERROR)
    
        std::cerr << "could not start up winsock-2.2\n";
        return 1;
    
#endif 

    struct sockaddr_in serverAddress,
        clientAddress;
    unsigned short Port = 27015;
    char msgBuf[BUFFER_LENGTH];

    SOCKET_TYPE socketHandle = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP/* or 0? */);
    if (SOCKET_INVALID(socketHandle))
    
        std::cerr << "could not make socket\n";
        return 1;
    

    //char address[512];
    //std::cout << "enter ip: ";
    //std::cin.getline(address, 512);

    memset(&serverAddress, 0, sizeof(serverAddress));
    serverAddress.sin_family = AF_INET;
    serverAddress.sin_port = htons(Port);
    serverAddress.sin_addr.s_addr = inet_addr("127.0.0.1");

    int len;
    std::cout << "gimme something: ";
    std::cin.getline(msgBuf, BUFFER_LENGTH);

    while (1)
    
        int n = sendto(socketHandle,msgBuf, strlen(msgBuf), 0,(struct sockaddr*)&serverAddress, sizeof(serverAddress));
        std::cout << "sent "<<n<<" bytes of the msg\n";
        /*len = recvfrom(socketHandle,msgBuf,BUFFER_LENGTH, 0, NULL, NULL);
        if (len > 0)
        
            msgBuf[len] = 0;
            fputs(msgBuf, stdout);
        else if(len < 0)std::cerr << "windowsy error\n";*/
    

#ifdef __COMPILE_FOR_WINDOWS__
    closesocket(socketHandle);
    WSACleanup();
#endif
#ifdef linux
    close(socketHandle);
#endif
    std::cout << "done\n";
    return 0;


#ifdef __COMPILE_FOR_WINDOWS__
#undef __COMPILE_FOR_WINDOWS__
#endif

#undef BUFFER_LENGTH
#undef SOCKET_INVALID

#ifdef SOCKET_TYPE
#undef SOCKET_TYPE
#endif

【问题讨论】：

【参考方案1】：

我没有看到任何错误，所以我在我的机器上编译了这两个程序（openSuSE 11.3）。我唯一需要改变的是int client_addr_len 到socklen_t client_addr_len 通信立即生效。 （当然客户端遇到了无休止的while(1)循环）。

您是在一台机器上还是在两台机器上执行此操作？客户端总是发送到 localhost，所以 2 台不同的机器不能工作。是否有防火墙阻止通信？

尝试做一个'netstat -au | grep 27015' 在启动服务器之前和之后。在您启动服务器之前，是否还有其他东西在该套接字上侦听？启动后服务器是否在监听？

尝试使用 strace 启动客户端和服务器。您是否看到任何系统调用错误？

【讨论】：

【参考方案2】：

发现问题了！我不得不取消对 client_addr_len=sizeof(clientAddress); 部分的注释。

出于某种原因，我认为该变量看起来更像是设计用于从 recvfrom() 函数接收不同大小的地址的长度，所以我怀疑它是否真的需要一个初始值。这是使数据报开始飞行的唯一方法。 :P

另外，对于任何未来的读者，socklen_t 问题可以通过添加快速修补

typedef int socklen_t;

到顶部指令的 windows 特定部分，并更改 int len;到 socklen_t len； - 就像 Guntram 说的那样。

【讨论】：

以上是关于UDP 测试代码不接收消息 (C++)的主要内容，如果未能解决你的问题，请参考以下文章

简单的UDP套接字代码，发送和接收消息

C++ UDP客户端/套接字编程：不能发送和接收

UDP - 是否可以在一次接收呼叫中接收多条消息？

接收 UDP 消息

UDP C++接收

发送UDP广播，接收多条消息