Помогите с сервером....

[lolbla2]

Вообщем сервер рассылает данные в отдельный поток...

myserver.cpp

Код

C++ (Qt)
#include "myserver.h"
 
MyServer::MyServer(QObject *parent) :
    QTcpServer(parent)
{
}
 
 
void MyServer::StartServer()
{
    if(!this->listen(QHostAddress::Any,1234))
    {
        qDebug() << "Could not start server";
        thread = new MyThread(this);
        connect(thread, SIGNAL(finished()),thread, SLOT(deleteLater()));
        thread->start();
    }
    else
    {
        qDebug() << "Listening...";
    }
}
 
void MyServer::incomingConnection(int socketDescriptor)
{
    qDebug() << socketDescriptor << " Connecting...";
    thread->newConnection(socketDescriptor);
 
}
 

Mythread.cpp

Код

C++ (Qt)
#include "mythread.h"
 
MyThread::MyThread( QObject *parent) :
    QThread(parent)
{
    blockSize = 0;
//    socket = new QTcpSocket(this);
}
 
void MyThread::run()
{
    //thread starts here
    qDebug() <<  " Starting thread";
//    socket = new QTcpSocket();
//    if(!socket->setSocketDescriptor(this->socketDescriptor))
//    {
//        emit error(socket->error());
//        return;
//    }
 
//    connect(socket,SIGNAL(readyRead()),this,SLOT(readyRead()),Qt::DirectConnection);
//    connect(socket,SIGNAL(disconnected()),this,SLOT(disconnected()),Qt::DirectConnection);
//    sockets.append(socket);
//    qDebug() << socketDescriptor << " Client Connected";
 
    exec();
}
void MyThread::newConnection(int sockDesc)
{
    qDebug() << sockDesc << " Client Connected";
    QTcpSocket *socket = new QTcpSocket();
    if(!socket->setSocketDescriptor(sockDesc))
       {
           emit error(socket->error());
           return;
       }
  connect(socket,SIGNAL(readyRead()),this,SLOT(readyRead()),Qt::DirectConnection);// падает тут 
    connect(socket,SIGNAL(disconnected()),this,SLOT(disconnected()),Qt::DirectConnection);
    sockets.append(socket);
 
 
 
}
 
void MyThread::readyRead()
{
 
     QString message;
     for(int i=0; i<sockets.size(); i++)
      {
          while(sockets[i]->bytesAvailable())
        {
            QDataStream in(sockets[i]);
          in.setVersion(QDataStream::Qt_4_7);
 
          if (blockSize == 0) {
            if (sockets[i]->bytesAvailable() < (int)sizeof(quint32))
                return;
          in >> blockSize;
        }
 
        if (sockets[i]->bytesAvailable() < blockSize)
          return;
 
          in>>message;
         }
     blockSize=0;
     }
     text = message;
     qDebug() << socketDescriptor << " Data in: " << message;
     SendData();
}
 
void MyThread::disconnected()
{
    for (int i=0; i<sockets.size(); i++)
                if (sockets[i]->state()!=QAbstractSocket::ConnectedState)
                {
                    qDebug() << sockets[i]->socketDescriptor() << "Disconnected";
                    sockets[i]->deleteLater();
                    sockets.removeAt(i);
                }
    if(sockets.empty())
      exit(0);
}
void MyThread::SendData()
{
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_7);
    out << (quint32)0;
    out << text;
    out.device()->seek(0);
    out << (quint32)(block.size() - sizeof(quint32));
    for(int i=0; i<sockets.size(); i++)
        sockets[i]->write(block);
}
 

Не могу понять, в закомменченной строке "падает тут" происходит ошибка сегментации SEGSIG fault, вроде для сокета память выделена и для потока, в чём же дело?

[Alex Custov]

У тебя после ошибки "Could not start server" создаётся поток чтения, а если ошибки нет, то он не создаётся. По-мойму тут что-то должно быть наоборот

[mutineer]

Непонятно зачем тебе поток - все у тебя происходит в главном потоке, а дополнительный просто eventLoop гоняет

Да и сокет в случае ошибки ты тож не удаляешь - так и висит он в утекшей памяти))

[lolbla2]

Непонятно зачем тебе поток - все у тебя происходит в главном потоке, а дополнительный просто eventLoop гоняет

Да и сокет в случае ошибки ты тож не удаляешь - так и висит он в утекшей памяти))

Отдельный поток только в run ? а то что просто поток гоняется и если кто-то подключился обрабатывается...

[mutineer]

Отдельный поток только в run ? а то что просто поток гоняется и если кто-то подключился обрабатывается...

Сейчас вся обработка сигналов от сокета происходит в том же потоке, в котором крутится сервер

[lolbla2]

Отдельный поток только в run ? а то что просто поток гоняется и если кто-то подключился обрабатывается...

Сейчас вся обработка сигналов от сокета происходит в том же потоке, в котором крутится сервер

почему? типо отдельный поток только в методе run? а класс QThread на самом деле не весь в отдельном потоке?

[mutineer]

Ага, QThread - это просто класс, управляющий потоком. В новом треде выполняется только метод run() и все, что вызвано из него непосредственно

[lolbla2]

Ага, QThread - это просто класс, управляющий потоком. В новом треде выполняется только метод run() и все, что вызвано из него непосредственно

Ладно, хорошо тогда принимать буду в основном потоке, а рассылать хочу всем клиентам в отдельном потоке пытаюсь это сделать следующим образом:

Myserver.cpp

Код

C++ (Qt)
#include "myserver.h"
 
MyServer::MyServer(QObject *parent) :
    QTcpServer(parent)
{
    client = new QTcpSocket();
    blockSize = 0;
}
 
 
void MyServer::StartServer()
{
    if(!this->listen(QHostAddress::Any,1234))
    {
        qDebug() << "Could not start server";
 
    }
    else
    {
        qDebug() << "Listening...";
    }
}
 
void MyServer::incomingConnection(int socketDescriptor)
{
    qDebug() << socketDescriptor << " Connecting...";
        if(!client->setSocketDescriptor(socketDescriptor))
        {
//            emit error(client->error());
            return;
        }
 
        connect(client,SIGNAL(readyRead()),this,SLOT(ReceiveData()),Qt::DirectConnection);
        connect(client,SIGNAL(disconnected()),this,SLOT(disconnected()),Qt::DirectConnection);
        sockets.append(client);
        qDebug() << socketDescriptor << " Client Connected";
}
void MyServer::ReceiveData()
{
    QString message;
    for(int i=0; i<sockets.size(); i++)
     {
         while(sockets[i]->bytesAvailable())
       {
           QDataStream in(sockets[i]);
         in.setVersion(QDataStream::Qt_4_7);
 
         if (blockSize == 0) {
           if (sockets[i]->bytesAvailable() < (int)sizeof(quint32))
               return;
         in >> blockSize;
       }
 
       if (sockets[i]->bytesAvailable() < blockSize)
         return;
 
         in>>message;
        }
    blockSize=0;
    }
    text = message;
    qDebug() <<  " Data in: " << message;
    thread = new MyThread(sockets, text);
    connect(thread, SIGNAL(finished()),thread, SLOT(deleteLater()));
    thread->start();
}
void MyServer::disconnected()
{
    for (int i=0; i<sockets.size(); i++)
                if (sockets[i]->state()!=QAbstractSocket::ConnectedState)
                {
                    qDebug() << sockets[i]->socketDescriptor() << "Disconnected";
                    sockets[i]->deleteLater();
                    sockets.removeAt(i);
                }
}
 

MyThread.cpp

Код

C++ (Qt)
#include "mythread.h"
 
MyThread::MyThread(QList <QTcpSocket *> clients, QString mes, QObject *parent) :
    QThread(parent)
{
    sockets = clients;
    text = mes;
}
 
void MyThread::run()
{
    //thread starts here
    qDebug() <<  " Starting thread";
    if(sockets.isEmpty())
        exit(0);
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_7);
    out << (quint32)0;
    out << text;
    out.device()->seek(0);
    out << (quint32)(block.size() - sizeof(quint32));
    for(int i=0; i<sockets.size(); i++)
        sockets[i]->write(block);
    exec();
}
 

в итоге получаю:

Listening...
264  Connecting...
264  Client Connected
 Data in:  "fgd"
 Starting thread
QObject: Cannot create children for a parent that is in a different thread.
(Parent is QNativeSocketEngine(0x5d4d48), parent's thread is QThread(0x5d2e28), current thread is MyThread(0x5d6458)

[mutineer]

ты создал сокет в одном потоке, а используешь в другом. Внутренние объекты сокета противятся такому.

да и идея создать один сокет, а потом засовывать его в массив несколько раз, как будто их много, тоже не особо хороша

[lolbla2]

ты создал сокет в одном потоке, а используешь в другом. Внутренние объекты сокета противятся такому.

да и идея создать один сокет, а потом засовывать его в массив несколько раз, как будто их много, тоже не особо хороша

а как же мне тогда в отдельном потоке разослать всем клиентам данные?

[mutineer]

Ну например можно мувнуть сокет в нужный тред. Или создать его прям в нужном треде

ну и еще - тред у тебя не умрет никогда, а на каждую новую порцию данных будет создан новый

[fuCtor]

А может посмотреть на существующие решения в плане организации межпроцессного общения и соответствующим протоколам?
Либо сервер должен в само приложения встраиваться наряду с клиентом?

[lolbla2]

А может посмотреть на существующие решения в плане организации межпроцессного общения и соответствующим протоколам?
Либо сервер должен в само приложения встраиваться наряду с клиентом?

Можно ссылки по этому поводу пожалуйста...?

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

[lolbla2]

Ну например можно мувнуть сокет в нужный тред. Или создать его прям в нужном треде

ну и еще - тред у тебя не умрет никогда, а на каждую новую порцию данных будет создан новый

Имеешь в виду для каждого сокета отдельный поток что ли? Типо сокет подключился, создали для него поток... Я то хотел один поток для передачи всем сокетам (клиентам), поэтому в поток передаю список клиентов.  Кстати почему-то лист клиентов нельзя мувнуть в поток... почему? Чот я до конца не пойму, это получается поток может использовать только объекты созданные внутри него или как ?

[mutineer]

Ну например можно мувнуть сокет в нужный тред. Или создать его прям в нужном треде

ну и еще - тред у тебя не умрет никогда, а на каждую новую порцию данных будет создан новый

Имеешь в виду для каждого сокета отдельный поток что ли? Типо сокет подключился, создали для него поток... Я то хотел один поток для передачи всем сокетам (клиентам), поэтому в поток передаю список клиентов.  Кстати почему-то лист клиентов нельзя мувнуть в поток... почему? Чот я до конца не пойму, это получается поток может использовать только объекты созданные внутри него или как ?

что значит "мувнуть лист клиентов"?
нет, поток может и другие объекты использовать, но родитель объекта и сам объект должны находиться в одном и том же потоке

можно и один поток на весь список клиентов, просто лучше сокеты для этих клиентов прям в потоке создавать. Кстати, сокет у тебя сейчас только один, независимо от количества клиентов, что неправильно