Передача данных в отдельном потоке. Сервер не успевает обработать данные. Опции Подписка на тему Сообщить другу Версия для печати Скачать тему Подписка на этот форум Режимы отображения Древовидный Переключить на: Стандартный Переключить на: Линейный

[kibsoft]

Есть сервер и клиент (отсылает данные, например файл):
Клиент:

void FileSender::sendFile()
{
    QFile file(filePath);
    if (file.open(QIODevice::ReadOnly)) {//если файл открылся
        QByteArray dataForPeer;//массив для данных
        QDataStream out(&dataForPeer, QIODevice::WriteOnly);//выходной поток
        QByteArray byteArray;//поток байтов из файла
        while(!file.atEnd()) {//пока не конец файла
             byteArray=file.read(1024);//читаем по килобайту
             out << quint16(0) << FILEBYTES << byteArray;
             out.device()->seek(0);
             out << quint16(dataForPeer.size() - sizeof(quint16));
             tcpSocket->write(dataForPeer);

             dataForPeer.clear();//очищаем массив для отправки серверу
        }
        //отправка уведомления об окончании передачи файла
        out << quint16(0) << SENDING_FINISHED;
        out.device()->seek(0);
        out << quint16(dataForPeer.size() - sizeof(quint16));
        tcpSocket->write(dataForPeer);

        file.close();//закрываем файл
    }
}

На сервере есть слот, соединенный с сигналом readyRead сокета, но видимо данные приходят так быстро, что сервер не успевает сделать нужные действия (а именно записать на диск). Что можно придумать? Можно ли как то на клиенте узнать считаны ли данные сервером или нет(и ждать этого момента)? В голову приходит только одно: от сервера высылать уведомление о принятых данных, чтобы клиент мог дальше передавать их (но мне кажется, что что-то не то).

[BRE]

Покажи как читаются данные на другой стороне.

[kibsoft]

/*
  Слот для обработки принятых из сокета данных.
*/
void FileWriter::readBytes()
{
    QTcpSocket *tcpSocket=(QTcpSocket*)sender();//получаем сокет
    QDataStream in(tcpSocket);
    quint16 nextBlockSize=0;//размер принятого блока
    for(;;) {
        if(!nextBlockSize) {
            if(tcpSocket->bytesAvailable()<sizeof(quint16)) break;//если данных принято меньше 2 байт, то выходим

            in>>nextBlockSize;//получаем размер блока
        }

        if(tcpSocket->bytesAvailable()<nextBlockSize) break;//если все данные получены, то продолжаем работать

        quint8 request;//получаем запрос
        in>>request;
        TypeOfRequest type=(TypeOfRequest)request;
        if (type==FILEBYTES) {//если данные - файл, то записываем их на жесткий диск
            writeBytes(in);
        }
        else if (type==SENDING_FINISHED) {//если пир окончил отправку файла, то отправляем ему
            sendFinishMessage(tcpSocket);//уведомление об окончании его принятия
        }
        nextBlockSize=0;
    }   
}

/*
  Функция записи принятых данных в файл. Параметры: поток данных из сокета(reference).
*/
void FileWriter::writeBytes(QDataStream &in)
{
    QByteArray bytes;
    in>>bytes;//получаем нужные байты
    QFile file("D:/ref.dat");
    if (file.open(QIODevice::Append)) {
        file.write(bytes);//записываем байты
        file.close();
    }
}


/*
  Функция отправки сообщения об окончании принятия файла. Параметры: принимающий сокет.
*/
void FileWriter::sendFinishMessage(QTcpSocket *tcpSocket)
{
    QByteArray dataForPeer;//массив для данных
    QDataStream out(&dataForPeer, QIODevice::WriteOnly);//выходной поток
    out << quint16(0) << quint8(RECEIVING_FINISHED);//соообщение об окончании
    out.device()->seek(0);
    out << quint16(dataForPeer.size() - sizeof(quint16));
    tcpSocket->write(dataForPeer);
}

[BRE]

Проверь несколько раз, сколько байт (какими порциями) реально читает эта функция из сокета:

void FileWriter::writeBytes(QDataStream &in)
{
    QByteArray bytes;
    in>>bytes;

    qDebug() << "Read data size from socket:" << bytes.size();

    QFile file("D:/ref.dat");
    if (file.open(QIODevice::Append)) {
        file.write(bytes);//записываем байты
        file.close();
    }
}

[kibsoft]

Проверь несколько раз, сколько байт (какими порциями) реально читает эта функция из сокета:

void FileWriter::writeBytes(QDataStream &in)
{
    QByteArray bytes;
    in>>bytes;

    qDebug() << "Read data size from socket:" << bytes.size();

    QFile file("D:/ref.dat");
    if (file.open(QIODevice::Append)) {
        file.write(bytes);//записываем байты
        file.close();
    }
}

Read data size from socket: 1024
Read data size from socket: 0
Файл 59 Кб.
Все рушится после 2 раза вызова слота обработки (readBytes), т.е. первый раз приходит как положено 1031 байт(вместе с nextBlockSize), при следующем вызове слота в nextBlockSize появляется 30 тысяч с лишним байт (размер следующего блока), потом if(tcpSocket->bytesAvailable()<nextBlockSize) break; тут пару раз происходит выход из слота, т.к.30 тысяч байт еще не пришли, а потом выходит косяк с этим:

quint8 request;//получаем запрос
        in>>request;
        TypeOfRequest type=(TypeOfRequest)request;
        if (type==FILEBYTES) {//если данные - файл, то записываем их на жесткий диск
            writeBytes(in);
        }

в reguest вместо 0 или 1 попадает 97 вроде.