Как правильно читать данные с многопоточным сервером? Опции

[Andrewshkovskii]

Есть клиент (наслденик QTcpSocket) , в нем реализованы функции запроса к серверу :

client::client(QWidget *parent) :
    QWidget(parent)
{
    socket = new QTcpSocket(this);
    this->setSocketConnections();
    connect(this->connectButton,SIGNAL(clicked()),this,SLOT(connectToServer()));
}

void client::setSocketConnections()
{
    connect(socket, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displayError(QAbstractSocket::SocketError)));
    connect(socket,SIGNAL(connected()),this,SLOT(readTask()));
}

void client::connectToServer()
{
    netxBlockSize=0;
    serverIp = ipLineEdit->text();
    serverPort = portLineEdit->text().toInt();
    socket->abort();
    socket->connectToHost(serverIp,serverPort);
}

void client::readTask()
{
    QByteArray block;
    QDataStream out(&block,QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_6);
    out << quint16(0) << 10;
    out.device()->seek(0);
    out << quint16 (block.size() - sizeof(quint16));
    socket->write(block);
}

Сервер от QTcpServer :

server::server(QObject *parent) :
    QTcpServer(parent)
{
    connectToDB();
    QList<QHostAddress> ipAddressesList = QNetworkInterface::allAddresses();
         for (int i = 0; i < ipAddressesList.size(); ++i) {
             if (ipAddressesList.at(i) != QHostAddress::LocalHost &&
                 ipAddressesList.at(i).toIPv4Address()) {
                 this->listen(ipAddressesList.at(i),27015);
                 break;
             }
         }
         if (this->serverAddress().isNull())
             this->listen(QHostAddress::LocalHost,27015);
}

void server::incomingConnection(int socketDescriptor)
{
 ClientThread * thread= new ClientThread(socketDescriptor,colors,specifications, this);
 connect(thread,SIGNAL(finished()),thread,SLOT(deleteLater()));
 thread->start();
}

И клиентский поток от QThread :

ClientThread::ClientThread(int socketDescriptor,
                           const QMap <int, QString> & colors,
                           const QMap < int , QPair <QString , QString> > & specification,
                           QObject *parent ) :
    socketDescriptor(socketDescriptor),
    colors(colors),
    specification(specification),
    QThread(parent)
{

    nextBlockSize = 0;
}

void ClientThread::Run()
{
    socket = new QTcpSocket();
    connect(socket,SIGNAL(readyRead()),this,SLOT(start()));
    socket->setSocketDescriptor(socketDescriptor);
    qDebug() << "HAHA";
    socket->disconnectFromHost();
    socket->waitForDisconnected();
}

Первый раз пишу клиент/сервер. Но почему-то у меня не запускается поток, т.е. получается что сокет не генирирует сигнал readyRead? А почему, ведь данные приходят от клиента..нет ?


Сообщение отредактировал Andrewshkovskii - 15.5.2010, 19:34

[Andrewshkovskii]

Ну с forever на получение полных данных я понял.но у меня другая проблема. Что бы запустить цикл обработки событий в функции run() потока я использую
exec() :

void ClientThread::run()
{
    socket = new QTcpSocket();
    socket->setSocketDescriptor(socketDescriptor);
    requestBrocker * brocker = new requestBrocker(socket);
    connect(socket,SIGNAL(readyRead()),brocker,SLOT(readClient()),Qt::QueuedConnection);
//    connect(socket,SIGNAL(readyRead()),this,SLOT(readClientSocket()),Qt::QueuedConnection);
    exec();
    socket->disconnectFromHost();
    socket->waitForDisconnected();
}

Если не запускать - брокер не поймает сигнал , и ничего не произойдет.
И вот ещё насчет брокера запросов..
:

void requestBrocker::readClient()
{
 qDebug() << "reading client " << socket->isValid() << " " << socket->bytesAvailable();
// QTcpSocket * socket = (QTcpSocket*)sender();
 QDataStream in(socket);
 in.setVersion(QDataStream::Qt_4_6);
 forever{
     if (nextBlockSize == 0)
     {
         if (socket->bytesAvailable() < sizeof(quint16))
         {
             break;
         }
         in >> nextBlockSize;
     }

     qDebug() <<  " total bytes " << nextBlockSize;
     if( socket->bytesAvailable() < nextBlockSize)
     {
         break;
     }
}
 quint8 requestType;
 in >> requestType;
 qDebug() << "before read request is : " <<(char)requestType;
 if(requestType == 'C')
 {
     QByteArray block;
     QDataStream out(&block,QIODevice::WriteOnly);
     out.setVersion(QDataStream::Qt_4_6);
     out << quint16(0);
     out.device()->seek(0);
     out << quint16(block.size() - sizeof(quint16));
     socket->write(block);
     qDebug() << "data writed";
 }
}

Я получаю на такие данные

    out << quint16(0) << quint8('C') << quint32(32);
    out.device()->seek(0);
    out << quint16 (block.size() - sizeof(quint16))

вот такой отладочный вывод :

reading client true 7
total bytes 344832
before read request is :

И поток не завершается без exit() , т.е. поток остается в незавершенном режиме и не удаляется. Из брокера я не могу вызвать ни exec() ни exit, разве что явно указать parent'a ему, и через указатель на родителя вызывать.
Но основная проблема в том, что я не могу никак написать код, который бы читал/принимал данные корректно.

[kibsoft]

exec();
    socket->disconnectFromHost();
    socket->waitForDisconnected();

после exec() уже ничего никогда не выполниться.

if (socket->bytesAvailable() < sizeof(quint16))
         {
             break;
         }

тут return надо.

exit можно связать с сигналом disconnected сокета, а при создании объекта ClientThread в сервере - указать deleteLayer, чтобы объект удалялся при выходе из цикла событий.