首页 文章

recv()没有使用send()获取客户端发送的所有数据

提问于
浏览
0

我真的不知道这是否是网络,我的电脑或其他任何类型的延迟,我对套接字编程很新,并且一直试图使这项工作暂时工作,实现一个简单的框架来简化我的工作在我的课程的未来项目中,我在我遇到的问题中使用这些函数:

void TCPSocket::send(const std::string& message, int flags) {

    if (isListening || !isConnected) {
        throw ConnectionException("Can't send message from a socket that is not connected");
    }

    int msgLength = message.length();
    int bytesLeft = msgLength;
    int bytesSent;
    const char* cMessage = message.c_str();

    while (bytesSent < msgLength) {

        const char* cMessageLeft = cMessage + bytesSent;

        int result = ::send(socketFd, cMessageLeft, bytesLeft, flags);
        if (result == -1) {
            throw ConnectionException("Could not send message. Error: " + std::string(strerror(errno)));
        }

        bytesLeft -= result;
        bytesSent += result;

    }

}

std::string TCPSocket::recv(unsigned int maxlen, int flags) {

    if (isListening || !isConnected) {
        throw ConnectionException("Can't receive message in a socket that is not connected");
    }

    char buffer[maxlen+1];
    int result = ::recv(socketFd, buffer, maxlen, flags);

    if (result == -1) {
        throw ConnectionException("Could not receive message. Error: " + std::string(strerror(errno)));
    }
    if (result ==  0) {
        isConnected = false;
        throw ClosedConnection("Client closed connection.");
    }
    buffer[result] = '\0';
    std::string message(buffer);

    return message;

}

它只使用一条消息就可以正常工作,我使用不同的可执行文件接收和发送完全没有任何问题,但我尝试发送多条消息并且我的问题已经开始,有时我让服务器接收1条消息,有时候它没有当我只添加几个printf()时它会全部收到它们,有人可以向我解释为什么会这样吗?

客户代码:

int main() {
    TCPSocket cl1(0);

    try {
        cl1.connect("localhost", 1170);
        for (int i = 0; i < 5; i++) {
            //printf("Esperando 5s... ");
            std::this_thread::sleep_for(std::chrono::milliseconds(1000));
            //printf("Pronto!\n\n");

            cl1.send("Thank you!\n");
            //printf("Msg enviada\n\n");

        }
        cl1.close();
    }
    catch( std::exception &e) {
        std::cout << e.what() << std::endl;
    }
}

服务器代码:

int main() {
    TCPSocket sv1(0);

    try {
        sv1.bind(1170);
        sv1.listen();
        TCPSocket client = sv1.accept();
        printf("Cliente conectado\n");
        try {
            for (;;) {
                //client.send("Welcome !\n");
                std::cout << client.recv(256) << std::endl;
            }
        }
        catch (const ClosedConnection & x) {
            printf("Connection closed\n");
        }

    }
    catch( std::exception &e) {
        std::cout << e.what() << std::endl;
    }
}

如果我取消注释客户端代码上的printfs,则在服务器上接收所有数据 .

澄清,我发送的消息是5s间隔,仍然recv()只读取第一个并且它阻塞直到 client 完成它的执行,从不读取应该在缓冲区中的其余消息 . 出于某种原因,在客户端代码上使用printfs使应用程序运行正常 .

1 回答

  • 1

    您似乎没有初始化 bytesSent 所以它实际发送数据的次数似乎是不确定的 .

    int bytesSent = 0;
    

相关问题