3

所以这是我第一次在这里提出问题，尽管我已经使用这个网站很多年了！

我的问题有点棘手。我正在尝试开发一个用于发送大文件的客户端服务器应用程序，使用带有我自己的错误检查和流量控制的 UDP。现在，我开发了一个功能齐全的服务器和客户端。客户端请求特定文件，服务器开始发送。文件被部分读入缓冲区，以避免每次发送数据包时都必须读取文件的一小部分，从而节省处理时间。数据包由 1400 字节的实际数据 + 28 字节的标头（序列号、确认号、校验和等）组成。

所以我掌握了基础知识，一个简单的停止等待协议。在发送下一个数据包之前发送数据包并接收确认。

为了能够实现更智能的流控制算法，对于只有一些窗口的初学者，我必须在两个不同的线程中运行发送部分和接收确认部分。现在这是我遇到问题的地方。这是我第一次使用线程，所以请多多包涵。

我的问题是从客户端的数据包写入的文件已损坏。好吧，当用一个小的 jpg 文件测试时，文件只有 50% 的时间损坏，当用 MP4 文件测试时，它总是损坏！所以我想也许线程以某种方式重新排列了数据包的发送顺序？我使用序列号，所以问题必须在将序列号分配给数据包之前出现......

我确定我拆分文件的部分是正确的，并且我在客户端重新组装它的部分也是正确的，因为我在尝试实现线程之前已经对此进行了测试。还应该注意的是，我将代码的确切发送部分复制到了发送线程中，这在将其放入线程之前也可以完美运行。这也是我只是发布我的线程部分的原因代码，因为这显然是造成问题的原因（并且由于项目的整个代码会占用大量空间）

我的发送线程代码：

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t condition_var = PTHREAD_COND_INITIALIZER;

static void *send_thread(void *){
if (file.is_open()) {
    while(!file.reachedEnd()){
        pthread_mutex_lock(& mutex);

        if(seq <= upperwindow) {

            int blocksize = file.getNextBlocksize();
            senddata = new unsigned char[blocksize + 28];
            Packet to_send;
            to_send.data = new char[blocksize];
            to_send.sequenceNumber = seq;
            to_send.ackNumber = 0;
            to_send.type = 55; // DATA

            file.readBlock(*to_send.data);
            createPacket(senddata, to_send, blocksize + 28);
            if (server.sendToClient(reinterpret_cast<char*>(senddata), blocksize + 28) == -1)
                perror("sending failed");

            incrementSequenceNumber(seq);

            /* free memory */
            delete [] to_send.data;
            delete [] senddata;

        }
        pthread_mutex_unlock(& mutex);
    }
    pthread_exit(NULL);
} else {
    perror("file opening failed!");
    pthread_exit(NULL);
}
}

我的接收确认线程代码：

static void *wait_for_ack_thread(void *){
while(!file.reachedEnd()){
    Packet ack;

    if (server.receiveFromClient(reinterpret_cast<char*>(receivedata), 28) == -1) {
        perror("error receiving ack");
    } else {
        getPacket(receivedata, ack, 28);
        pthread_mutex_lock(& mutex);
        incrementSequenceNumber(upperwindow);

        pthread_mutex_unlock(& mutex)

    }
}
pthread_exit(NULL);
}

非常感谢所有评论！:)

编辑：添加了 readBlock 函数的代码：

void readBlock(char & in){

memcpy(& in, buffer + block_position, blocksize);
block_position = block_position + blocksize;
if(block_position == buffersize){
    buf_position ++;
    if(buf_position == buf_reads){
        buffersize = filesize % buffersize;
    }
    fillBuffer();
    block_position = 0;
}
if(blocksize < MAX_DATA_SIZE){
    reached_end = true;
    return;
}
if((buffersize - block_position) < MAX_DATA_SIZE){
    blocksize = buffersize % blocksize;

}

}
4

1 回答 1

1

创建一个表示通信状态的数组。

0表示未发送，或已发送且接收方报告错误。 1是发送的意思。 2表示已发送，并收到确认。

分配这个数组，并用互斥锁保护对它的访问。

发送线程将两个指针保存到数组中——“已发送至”和“应该发送下一个”。这些由发送线程拥有。

ack 线程简单地获取 ack 数据包，锁定数组，并在状态上进行转换。

发送线程锁定数组，检查它是否可以推进“已发送到”指针（或者它是否应该重新发送旧的东西）。如果它注意到一个错误，它会减少“应该下一个发送”指针以指向它。

然后它会查看它是否应该接下来发送内容。如果应该，它将节点标记为“正在发送”，解锁数组并发送它。

如果发送线程没有工作，并且没有发现可做的事情，它会在超时时进入睡眠状态，并且可能会被 ack 线程“踢醒”。

现在，请注意客户端可能会以错误的顺序获取由此发送的数据包，除非您将其限制为只有 1 个数据包在传输中。

连接状态数组不必是文字数组，但如果从它开始并稍后优化，会更容易。

在接收端，您必须注意序列号，因为数据包可能会乱序到达。为了测试这一点，编写一个服务器，故意以错误的顺序发送数据包，并确保客户端设法将它们正确地拼接在一起。

于 2013-11-08T21:23:30.377 回答