TCP 服务器无法正确接收数据

TCP Server doesn't receive data correctly

本文关键字：数据 服务器 TCP      更新时间：2023-10-16

下面的代码有一个C中的TCP客户端和Qt C++中的TCP服务器。我的问题是，我使用TCP是为了提高可靠性，但它会丢失数据(而不是数据包(。在我的主代码中，如果我运行tcp客户端发送数据，tcp服务器只接收一个数据包。如果我在每次数据包传输之间向客户端添加sleep(1);，则TCP服务器接收数据。客户端和服务器都在同一台计算机上运行。

为了简化问题，并且不能在这里放太大的代码，我有下面的代码，它执行得更快，但它会丢失数据包的最后10-15个字节。

TCP C客户端

main.c

#include "socket_handler.h" //I didn't put the all includes here
#define     PORT             22208
//tcp server
int main(void)
{
    int sockfd;
    uint32_t senderAddress = 2130706433; //127.0.0.1
    if( connect_to_server_w_uint( &sockfd, senderAddress, PORT ) < 0 ){
        printf("error at line 454n");
        exit(1);
    }
    char data[] = "124b00068c158f$321$52712304$13.212779$0$O$0$0$b4$1$0$3$0$0$0$0$11$0$7$0$1$fe$f1$aaa9fffffffffd80$2132b00$eb460b5e$1$1$2016-02-22 03:01:00$0000-00-00 00:00:00$321$24754$321$13132$1$98$0$5.1$0$3c$64$1$96$4d$3e8$38$2$46$dc$4$3$f6$e6$17$0$e6$d3$1$0$e6$d3$2$0£";
    char buffer[512];
    int i=0;
    for(i=0; i<1000; i++){
        bzero(buffer, 512);
        sprintf(buffer, "%d***%s  -----",i,data);
        send_data_to_server(&sockfd, buffer, strlen(data)  +1 );
        printf("[%d]: data is sentn", i);
    }
    close_connection(&sockfd);
    return 0;
}

socket_handler.c

int connect_to_server(int *sockfd , struct in_addr senderAddress, uint16_t destPort){
    struct sockaddr_in serv_addr;
    *sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (*sockfd < 0)
        //error("ERROR opening socket");
    bzero((char *) &serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr = senderAddress;
    serv_addr.sin_port = htons(destPort);
    if (connect( *sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0){
        printf("connection error line 1413n");
         close( *sockfd );
        return -1;
    }
    return 0;
}

int connect_to_server_w_uint(int *sockfd, uint32_t senderAddress, uint16_t destPort){
    struct sockaddr_in serv_addr;
    *sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (*sockfd < 0){
        printf("ERROR opening socket");
        close(*sockfd);
        return -1;
    }
    bzero((char *) &serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(senderAddress);
    serv_addr.sin_port = htons(destPort);
    if (connect(*sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0)
    {
        printf("ERROR connecting");
        close(*sockfd);
        return -1;
    }
    return 0;
}
int send_data_to_server(int *sockfd, char *message, uint16_t msgLength){
    int n = write(*sockfd, message, msgLength);
    if (n < 0){
         printf("ERROR writing to socket");
         return -1;
    }
    return 0;
}
int close_connection(int *sockfd){
    close( *sockfd );
    return 0;
}

Qt C++TCP服务器

主窗口.cpp

class MainWindow;
}
class MainWindow : public QMainWindow
{
    Q_OBJECT
public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();
private slots:
    void ParseThePacket(QByteArray data);
private:
    Ui::MainWindow *ui;
    Server *server;
};

客户端.h

class Client : public QObject
{
    Q_OBJECT
public:
    explicit Client(QObject *parent = 0);
public slots:
    bool connectToHost(QString host);
    bool writeData(QByteArray data);
private:
    QTcpSocket *socket;
};

服务器.cpp

Server::Server(QObject *parent) : QObject(parent)
{
    server = new QTcpServer(this);
    connect(server, SIGNAL(newConnection()), this, SLOT(newConnection()));
    if( server->listen(QHostAddress::Any, PORT) ){
        qDebug() << "tcp server started!";
    }else{
        qDebug() << "tcp server couldn't start listening";
    }
}
void Server::newConnection()
{
    qDebug() << "new connection";
    while (server->hasPendingConnections())
    {
        socket = server->nextPendingConnection();
        connect(socket, SIGNAL(readyRead()), this, SLOT(readyRead()));
        connect(socket, SIGNAL(disconnected()), this, SLOT(disconnected()));
    }
}
void Server::disconnected()
{
    qDebug() << "disconnected";
     socket->deleteLater();
}
void Server::readyRead()
{
    qDebug() << "readyRead";
    QByteArray buffer = socket->readAll();
    emit dataReceived(buffer);
}

以下是TCP服务器的输出示例(qDebug((输出的末尾(：

00:00:00$321$224754$321$11312$1$98$0$5.1$0$3c$64$1$96$4d$3 e8$38$2$46$dc$4$3$6 e6$17$e6$d3$1$e6$1$d3$996***124b00068c158f$321$5272304$13.212779$0$0$0$0$b4$1$0$3$0$00$0$1$1$61$aaa9fffffffffd80$21322000$eb460b5e$1$1$12016-02-2203:01:00$00000-00-0000:00:00$321$224754$321$11312$1$98$0$5.1$0$3c$64$1$96$4d$3 e8$38$2$46$dc$4$3$6 e6$17$e6$d3$1$e6$1$d3$997***124b00068c158f$321$5272304$13.212779$0$0$0$0$b4$1$0$3$0$00$0$1$1$61$aaa9fffffffffd80$21322000$eb460b5e$1$1$12016-02-2203:01:00$00000-00-0000:00:00$321$224754$321$11312$1$98$0$5.1$0$3c$64$1$96$4d$3 e8$38$2$46$dc$4$3$6 e6$17$e6$d3$1$e6$1$d3$998***124b00068c158f$321$5721234$13.212779$0$0$0$0$b4$1$0$3$0$00$0$1$1$3$7$0$1$fe$f1$aaa9fffffffffd80$21322000$eb460b5e$1$1$12016-02-2203:01:00$00000-00-0000:00:00$321$224754$321$11312$1$98$0$5.1$0$3c$64$1$96$4d$3 e8$38$2$46$dc$4$3$6 e6$17$e6$d3$1$e6$1$d3$999***124b00068c158f$321$5272304$13.212779$0$0$0$0$b4$1$0$3$0$00$0$1$1$61$aaa9fffffffffd80$21322000$eb460b5e$1$1$12016-02-2203:01:00$00000-00-0000:00:00$321$24754$321$11312$1$98$0$5.1$0$3c$64$1$96$4d$3e 8$38$2$46$dc$4$3$f6$e6$17$0$e6$d3$1$0$e 6$d3$"断开

问题1与原始消息相比，它错过了(14字节(发送数据的"1$0$e6$d3$2$0£"部分。丢失信息的原因是什么？如何修复TCP服务器接收完整数据的代码。

问题2正如我在开头提到的，我使用的代码与大型代码的一部分相同，当我在每次数据包传输之间放入sleep(1(时，TCP服务器会接收数据包(否则它只接收第一个数据包(。它的原因是什么？如何解决？

我在Wireshark上观察到数据包传输，所有TCP数据包都发送成功，但接收部分似乎有问题。

我使用的是Ubuntu 15.04，内核3.19.0-69-generic，gcc版本4.9.2

int n = write(*sockfd, message, msgLength);
if (n < 0){

您只是在检查write()是否没有返回负值，这表明存在错误。

但是，对套接字的write()并不能保证所有请求的字节都会被写入。套接字上的write()可能返回一个正值，此处小于msgLength，表示写入的字节少于请求的字节。write()的手册页对此进行了详细记录。

你忽略了这种可能性，这可能就是你丢失数据的原因。在这种情况下，该怎么办由你自己决定。通常的方法是简单地返回并尝试写入剩余的字节(同样，这些字节可能不会全部写入(。

类似地，当从套接字读取时，不能保证发送者写入套接字的所有内容都会被一口气读取。由您来验证您的读取器是否已经读取了所有要读取的数据，如果读取器需要更多数据，请继续从套接字读取，直到收到为止。

readAll只读取当前时刻可用的所有数据。

相关文章：