Непонятная проблема с передачей сообщений по tcp между клиентом и сервером

[Alhin]

Стал реализовывать клиент и сервер обменивающиеся сообщениями по tcp, когда клиент подключается к серверу,  для него запускается отдельный поток. Так вот, если клиент шлет сообщения серверу, то все нормально, но после того как сервер посылает сообщение клиенту, клиентские сообщения до сервера больше не доходят, соответственно код клиента и сервера прилагается.

Код класса потока обрабатывающего прием и отправку сообщений на серверной стороне:

Код:

void ClientThread::readClientMessage(){
    this->__bufferForInputData += this->__clientSocket->readAll();
    forever{
        QDataStream in(&__bufferForInputData, QIODevice::ReadOnly/*this->__clientSocket*/);
        in.setVersion(QDataStream::Qt_4_5);
        if(this->__nextBlockSize == 0){
            if(this->__bufferForInputData.size() < sizeof(qint64)){
                return;
            }
            in >> this->__nextBlockSize;
        }
        if(this->__bufferForInputData.size() < sizeof(qint64) + this->__nextBlockSize){
            return;
        }
        QString message;    
        in >> message;
        this->__nextBlockSize = 0;
        emit gottenMessage(message);
        this->__bufferForInputData.clear();
        return;
    }
}

void ClientThread::sendMessage(QString message){
    QByteArray data;
    QDataStream out(&data, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_5);
    out << (qint64)0;
    out << message;
    out.device()->seek(0);
    out << (qint64)(data.size() - sizeof(qint64));

  
    this->__clientSocket->write(data, data.size());
    this->__clientSocket->waitForBytesWritten();
}

На стороне клиента прием и отправка сообщений реализованы точно также:

Код:

void TcpClient::sendMessage(QString message){
    if(this->__tcpSocket->state() != QAbstractSocket::ConnectedState){
        return;
    }
    QByteArray data;
    QDataStream out(&data, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_5);
    out << (qint64)0;
    out << message;
    out.device()->seek(0);
    out << (qint64)(data.size() - sizeof(qint64));


    this->__tcpSocket->write(data, data.size());
    this->__tcpSocket->waitForBytesWritten();
}

void TcpClient::readServerMessage(){
    this->__bufferForInputData += this->__tcpSocket->readAll();
    forever{
        QString message;
        QDataStream in(&__bufferForInputData, QIODevice::ReadOnly/*this->__tcpSocket*/);
        if(this->__nextBlockSize == 0){
            if(this->__bufferForInputData.size() < sizeof(qint64)){
                return;
            }
            in >> this->__nextBlockSize;
        }
        if(this->__bufferForInputData.size() < sizeof(qint64) + this->__nextBlockSize){
            return;
        }
        in >> message;
        this->__nextBlockSize = 0;
        emit gottenMessage(message);
        this->__bufferForInputData.clear();
        return;
    }
}

Есть идеи как решить эту проблему?
Заранее спасибо!

[BRE]

Смущает следующий кусок кода в обоих слотах чтения:

Код

C++ (Qt)
void ClientThread::readClientMessage(){
	...
        if(this->__bufferForInputData.size() < sizeof(qint64) + this->__nextBlockSize){
            return;
        }
	...
}
 

Размер блока (sizeof(qint64)) ты уже прочитал.

Попробуй так:

Код

C++ (Qt)
void ClientThread::readClientMessage(){
	...
        if(this->__bufferForInputData.size() < this->__nextBlockSize){
            return;
        }
	...
}
 

[Alhin]

Исправил, но проблема все равно осталась.

[BRE]

Исправил, но проблема все равно осталась.

И в TcpClient::readServerMessage() исправил?

Вопрос по протоколу:
* Клиент подключается к серверу
* Клиент посылает сообщение серверу (нормально доходит?)
* Сервер посылает сообщение клиенту (нормально доходит?)
* Клиент посылает сообщение серверу (сервер его не получает?)

[Alhin]

Да, там тоже исправил.
Клиент подключается к серверу - да.
Клиент посылает сообщение серверу - все доходит без проблем.
Сервер посылает сообщение клиенту - тоже все доходит и проблем не наблюдается.
(*) Клиент посылает сообщение серверу - здесь уже сервер не получает сообщений.
Причем заметил такую интересную вещь, что после того как серверу не дошло сообщение от клиента
переслать от сервера клиенту сообщение, то серверу приходит отправленное в случае (*) сообщение(
причем только первое из отправленных). Если же этого не делать, то сообщения не поступают.

Причем, если закоментить в коде клиента и сервера:

Код:

this->__tcpSocket->waitForBytesWritten();

то такого интересного эффекта не наблюдается.

Решил проверить свой код на debian - все работает без проблем.
В голове не укладывается в чем тут может быть дело...

[BRE]

Причем, если закоментить в коде клиента и сервера:

Код:

this->__tcpSocket->waitForBytesWritten();

то такого интересного эффекта не наблюдается.

А для чего ты вызываешь эту функцию?

[Alhin]

На самом деле первоначальный вариант был без нее,
дописал ее из соображения "авось поможет".

[BRE]

Так сейчас под linux все работает, а под вендой нет?

[Alhin]

Да, именно так.

[BRE]

А попробуй вместо

Код

C++ (Qt)
this->__tcpSocket->waitForBytesWritten();
 

поставить

Код

C++ (Qt)
this->__tcpSocket->flush();
 

[Alhin]

Пробовал - не помогает.

[BRE]

Пробовал - не помогает.

Хм, странно... С вендой помочь не смогу, не пользуюсь, но если захочешь выложи архив с проектом, я его под linux посмотрю, кто-то может под вендой попробует.

[Alhin]

Проект смогу выложить только утром в понедельник.

[Alhin]

Вот обещанный архив с исходниками, соответственно исходники клиента в папке Client, а сервера - Server.

[BRE]

Вот обещанный архив с исходниками, соответственно исходники клиента в папке Client, а сервера - Server.

Лучше и pro файлы в архив класть. 

Сейчас нет времени подробно разбираться... Посмотри на сообщения, которые выдаются в консоль при работе сервера.

Если объект создается в конструкторе Thread, то он создается и принадлежит контексту того потока из которой вызывается конструктор (в твоем случае это главный поток), а используешь ты его в контексте дочернего потока (в методе run). Нужно или переносить объект в контекст дочерней нити (см QObject::moveToThread), или непосредственно создавать объект в контексте дочерней нити (т.е. в методе run).