服务器无法连接到多个客户端？

Question

问题是它只连接到一个客户端而不是两个。谁能帮我找出原因吗？

服务器：

#include <SFML/System.hpp>
#include <SFML/Network.hpp>
#include <iostream>

void sendInfo(void *UserData)
{
    sf::IPAddress* ip = static_cast<sf::IPAddress*>(UserData);
    // Print something...
    while(true){
        // Create the UDP socket
        sf::SocketUDP Socket;

        // Create bytes to send
        char Buffer[] = "sending info.";

        // Send data to "192.168.0.2" on port 4567
        if (Socket.Send(Buffer, sizeof(Buffer), *ip, 4444) != sf::Socket::Done)
        {
            // Error...
        }
    }
}

void receiveInfo(void *userData)
{
    // Print something...
    while(true){
        // Create the UDP socket
        sf::SocketUDP Socket;

        // Bind it (listen) to the port 4567
        if (!Socket.Bind(4444))
        {
            // Error...
        }

        char Buffer[128];
        std::size_t Received;
        sf::IPAddress Sender;
        unsigned short Port;
        if (Socket.Receive(Buffer, sizeof(Buffer), Received, Sender, Port) != sf::Socket::Done)
        {
            // Error...
        }

        // Show the address / port of the sender
        std::cout << Buffer << std::endl;

        Socket.Close();

    }
}

int main()
{
    sf::IPAddress client[2];
    int connected = 0;
    while(connected < 2){
        // Create the UDP socket
        sf::SocketUDP Socket;

        // Bind it (listen) to the port 4567
        if (!Socket.Bind(4444))
        {
            // Error...
        }

        char Buffer[128];
        std::size_t Received;
        sf::IPAddress Sender;
        unsigned short Port;
        if (Socket.Receive(Buffer, sizeof(Buffer), Received, Sender, Port) != sf::Socket::Done)
        {
            // Error...
        }

        // Show the address / port of the sender
        client[connected] = Sender;

        Socket.Close();

        sf::Thread* send = new sf::Thread(&sendInfo, &client[connected]);
        sf::Thread* receive = new sf::Thread(&receiveInfo, &client[connected]);
        // Start it !
        send->Launch();
        receive->Launch();
        connected++;
    }

    while(true){

    }

    return EXIT_SUCCESS;
}

客户端：

#include <SFML/System.hpp>
#include <SFML/Network.hpp>
#include <iostream>

void sendInfo(void *UserData)
{
    // Print something...
    while(true){
        // Create the UDP socket
        sf::SocketUDP Socket;

        // Create bytes to send
        char Buffer[] = "client sending info.";

        // Send data to "192.168.0.2" on port 4567
        if (Socket.Send(Buffer, sizeof(Buffer),  "127.0.0.1", 4444) != sf::Socket::Done)
        {
            // Error...
        }
    }
}

void receiveInfo(void *userData)
{
    // Print something...
    while(true){
        // Create the UDP socket
        sf::SocketUDP Socket;

        // Bind it (listen) to the port 4567
        if (!Socket.Bind(4444))
        {
            // Error...
        }

        char Buffer[128];
        std::size_t Received;
        sf::IPAddress Sender;
        unsigned short Port;
        if (Socket.Receive(Buffer, sizeof(Buffer), Received, Sender, Port) != sf::Socket::Done)
        {
            // Error...
        }

        // Show the address / port of the sender
        std::cout << Buffer << std::endl;

        Socket.Close();

    }
}

int main()
{
    // Create the UDP socket
    sf::SocketUDP Socket;

    // Create bytes to send
    char Buffer[] = "Client Joined.";

    // Send data to "192.168.0.2" on port 4567
    if (Socket.Send(Buffer, sizeof(Buffer), "127.0.0.1", 4444) != sf::Socket::Done)
    {
        // Error...
    }

    sf::Thread* send = new sf::Thread(&sendInfo);
    sf::Thread* receive = new sf::Thread(&receiveInfo);
    // Start it !
    send->Launch();
    receive->Launch();


    while(true){

    }

    return EXIT_SUCCESS;
}

Answer 1

首先，这是一个聊天服务器还是一个“更典型”的服务器？

如果这是一个聊天服务器，那么您需要有一个连接到客户端的套接字列表（您可以使用 connect( ) 调用，非常方便，而且还有助于减少欺骗性对等点的机会）或您可以提供给 sendto() 的所有客户端地址列表> 或sendmsg()。

更“典型”的服务器不会尝试向除最近发出请求的客户端之外的任何客户端发送消息：这些服务器通常不会从客户端保存任何内容，而是使用 recvfrom() 或 recvmsg() 获取对等方的地址，以便在以后的 sendto() 或 sendmsg() 调用中使用。

此外，大多数协议仅依赖于一个众所周知的端口；服务器按照约定使用一个特定端口，但客户端选择任何开放且空闲的端口。 FTP 也严重依赖客户端上众所周知的端口，因此通过

这不仅仅是学术问题：您的客户端和您的服务器都在尝试bind()到端口4444。这意味着您需要在一台机器上至少两个 IP 地址进行测试，或者使用虚拟化软件在同一硬件上运行完全独立的机器，或者只有两台可用的机器。这比需要的工作量要多，而且客户端没有理由关心它们的本地端口号：

服务器：

    // Bind it (listen) to the port 4567
    if (!Socket.Bind(4444))
    {
        // Error...
    }

客户端：

    // Bind it (listen) to the port 4567
    if (!Socket.Bind(4444))
    {
        // Error...
    }

噗！ 如果没有显着的技巧，这两个永远不会在同一主机上运行。我希望你的“它连接到一个”可能只是服务器或客户端连接到它自己，但是没有一些代码来填充这些 // Error 块，它'很难确定。

（当我们在这里时，我想抽出时间来谈谈注释；简单地重新说明代码功能的注释并不是很有用。您会注意到，您的大多数注释实际上都是 < em>错误，指的是错误的 IP 或端口。有些只是不添加任何信息：

    // Create the UDP socket
    sf::SocketUDP Socket;

我知道我们被教导要添加注释，但遗憾的是我们并不总是被教导什么类型。 > 我要添加的两个程序中唯一的评论。建议保留这个，稍微修改一下：

    // udp doesn't require listen or accept
    if (!Socket.Bind(4444))

从阅读代码中看不出来，并且从环境变量、命令行参数、配置文件或注册表中读取端口号时不会出错（对于熟悉套接字 API 的团队来说，它可能太过多余，但对于不熟悉 UDP 和 TCP 之间差异的程序员来说可能是黄金。）

好的函数名称、变量名称等., 几乎每次都会赢得评论到此结束了：）

现在，更小的问题是：您的线程处理程序正在执行一些这样的任务：

while(1) {
    socket s;
    bind s;
    r = recv s;
    print r;
    close s;
}

这种不必要的创建、绑定和关闭都是浪费的能量，包括计算机的能量和（更多）。重要的是）你的能量。考虑以下两种重写：

recv_thread() {
    socket s;
    bind s;
    while (1) {
        r = recv s;
        print r;
    }
    close s;
}

或者

recv_thread(s) {
    while (1) {
        r = recv s;
        print r;
    }
}
/* ... */
socket s;
bind s;
sf::Thread* rt = new sf::Thread(&recv_thread);
rt->Launch(s);

第一个选项是对现有代码进行简单重构；它将套接字的创建和销毁保留在线程函数中，但将 循环不变量移出循环。循环内的代码现在仅执行必要的操作。

第二个选项是更彻底的改造：它将套接字创建移至主线程，其中错误处理可能容易得多，并且线程函数仅执行远程对等点需要该线程执行的操作做。 （如果您想从 UDP 更改为 TCP，那么第二个选项是迄今为止更容易更改的选项 — 您的线程代码可能根本不需要任何修改。）

我希望这会有所帮助。 :)