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

Question

下面的代码在Qt C++中有C和TCP服务器中的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 454\n");
        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 sent\n", 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 1413\n");
         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服务器

MainWindow.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;
};

Client.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;

};

Server.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 $ 24754 $ 321 $ 13132 $ 1 $ 98 $ 0 $ 5.1 $ 0 $ 3C $ $ 64 1 $ $ 96 4D $ 3E8 $ $ 38 2 $ $ 46直流$ 4 $ 3 $ F6 $ E6 $ $ 17 0 $ E6 $ D3 $ 1 $ 0 $ E6 $ D3 $ 996***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直流$ 4 $ 3 $ F6 $ E6 $ $ 17 0 $ E6 $ D3 $ 1 $ 0 $ E6 $ D3 $ 997***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直流$ 4 $ 3 $ F6 $ E6 $ $ 17 0 $ E6 $ D3 $ 1 $ 0 $ E6 $ D3 $ 998***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直流$ 4 $ 3 $ F6 $ E6 $ $ 17 0 $ E6 $ D3 $ 1 $ 0 $ E6 $ D3 $ 999产品***124b00068c158f $ 321 $五二七一二三○四$ 13.212779 $ 0 $ö$ 0 $ 0 $ B4 $ 1 $ 0 $ 3 $ 0 $ 0 $ 0 $ 0 $ $ 11 0 $ 7 $ 0 $ 1 $ FE $ F1 $ aaa9fffffffffd80 $ 2132b00 $ eb460b5e $ 1 $ 1 $ 201 6-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 $"断开连接

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

问题2 正如我在开始时提到的,我使用相同的代码作为大代码的一部分,当我在每个数据包传输之间放入sleep(1)时,TCP服务器接收数据包(否则它只接收第一个数据包).它的原因是什么以及如何解决？

我观察到Wireshark上的数据包传输是否所有TCP数据包都成功发送,但看起来接收部分有问题.

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

Answer 1

int n = write(*sockfd, message, msgLength);

if (n < 0){

您只检查write()没有返回负值,表示错误.

但是,write()套接字不保证将写入所有请求的字节.write()在套接字上可能返回一个正值,少于msgLength此处,表示已写入少于所请求的字节.详细说明请参见write()手册页.

你忽略了这种可能性,这就是你错过数据的可能原因.在这种情况下,由你决定要做什么.通常的方法是简单地返回并尝试写入剩余的字节(再次,可能不会完整地写入).

类似地,当从套接字读取时,不能保证发送方写入套接字的所有内容都将被读取.由您来验证您的阅读器是否已阅读所有要阅读的内容,如果阅读器需要更多数据,请继续从套接字读取,直到收到它为止.