c++ - UDP测试代码收不到消息(C++)

Question

首先，请原谅我的困惑。我一直在尝试修改示例 UDP 代码以跨 windows/linux 工作。可能有一些特定于 Windows 的代码仍然存在于我一直试图弄清楚到底是哪里出了问题的地方。

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

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

我在这里错过了什么？

顺便说一句，我还应该提到，如果我从客户端绑定(bind) 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

Answer 1

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

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

尝试执行 'netstat -au | grep 27015' 在启动服务器之前和之后。在启动服务器之前，是否有其他任何东西在监听该套接字？服务器启动后是否在监听？

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