QTcpServer :: incomingConnection (qintptr) 호출하지 않음

Question

QTcpSocket 및 QTcpServer을 사용하여 클라이언트 및 서버를 만들려고합니다.

그래서 서버는 어떻게됩니까? 내가 서버를 실행

1. , 그것은
내가 클라이언트 실행
2. 가, port
3. 클라이언트에 대한 IP address 및 30000에 대한 127.0.0.1를 입력 (성공적으로 [자신에 의해 확인]) 연결이
4. 서버 아무튼 estabilished 있다고 듣고 시작 무엇이든하면 그냥 기다리십시오.

내 프로그램의 부분 :

//server-work.h 
#ifndef SERVERWORK_H 
#define SERVERWORK_H 

#include <QtCore> 
#include <QSqlError> 
#include <QDebug> 
#include <QSqlQuery> 
#include <unistd.h> 
#include <QtNetwork/QTcpServer> 
#include <QtNetwork/QTcpSocket> 
#include <QtSql/QSqlDatabase> 
#include "lssclient.h" 
class LSSClient; 

class LTcpServer : public QTcpServer 
{ 
    Q_OBJECT 
public: 

    class LTWorkWithClients : public QThread 
    { 
     //Q_OBJECT 
    public: 
     LTcpServer* server; 
     LTWorkWithClients(QObject* parent = 0, LTcpServer *server = 0): 
      QThread(parent) 
     { 
      this->server = server; 
     } 

    protected: 
     void run() { 
      qDebug() << "started"; 
      server->workWithIncomingConnection(); 
     } 
    }; 

    QSqlDatabase db; // clients in database 

    LTWorkWithClients* t_workWithClients; 
    QQueue<quintptr> clientsToBeAttached; 
    QList<LSSClient*> clients; 

    LResult workWithIncomingConnection (); 

    LResult serverInit   (); 
    LResult createDatabase  (); 

    static QTextStream& qStdout(); 

    void incomingConnection(qintptr socketDescriptor) Q_DECL_OVERRIDE; 

protected: 

private: 

}; 

#endif // SERVERWORK_H 

나는이 중첩 된 스레드 클래스는이 일을 할 수있는 길을 잘못 강하게 것을 알고,하지만 난 그래서, 서버가 단지 1 (아무것도 작성하지 더 계속 제대로

// server-work.cpp [PART] 
LResult LTcpServer::serverInit() 
{ 
    checkError; 
    db = QSqlDatabase::addDatabase("QSQLITE"); 
    db.setDatabaseName("serverDB"); 

    if (!db.open()) { 
     qDebug() << "Error opening database..."; 
     qDebug() << db.lastError().text(); 
     return LVError; 
    } else { 
     qDebug() << "Database successfully opened"; 
    } 
    if(!this->listen(QHostAddress::Any, 30000)){ 
     qDebug() << "Error starting listening..."; 
     return LVError; 
    } else { 
     qDebug() << "Start listening successfully"; 
    } 
    t_workWithClients = new LTWorkWithClients(this, this); 
    t_workWithClients->start(); 
    return LVSuccess; 
} 

void LTcpServer::incomingConnection(qintptr socketDescriptor) 
{ 
    qDebug() << Q_FUNC_INFO << " new connection"; 
    clientsToBeAttached.enqueue(socketDescriptor); 
    qDebug() << "here1"; 
} 

LResult LTcpServer::workWithIncomingConnection() 
{ 
    bool toExit = false; 
    while (!toExit) { 
     checkError; 
     qDebug() << "1"; 
     if (clientsToBeAttached.length() != 0) { 
      quintptr eachClientDescriptor = clientsToBeAttached.dequeue(); 
      qDebug() << "2"; 
      LSSClient* client = new LSSClient(this); 
      client->server = this; 
      client->socket->setSocketDescriptor(eachClientDescriptor); 
      qDebug() << "3"; 
      client->registered = false; 
      client->server = this; 
      qDebug() << client->socket->localAddress(); 
      connect(client->socket, SIGNAL(readyRead()), client, SLOT(onSokReadyRead())); 
      connect(client->socket, SIGNAL(connected()), client, SLOT(onSokConnected())); 
      connect(client->socket, SIGNAL(disconnected()), client, SLOT(onSokDisconnected())); 
      connect(client->socket, SIGNAL(error(QAbstractSocket::SocketError)),client, SLOT(onSokDisplayError(QAbstractSocket::SocketError))); 
      clients.append(client); 
     } 
     usleep(1000000); 
    } 
    return LVSuccess; 
} 

그것을 할 시간이별로 없어) 초마다 있지만 클라이언트가 서버에 연결되어 있다고합니다.

Answer 1

이 구조가 도움이 될 수 있습니다 ... 당신의 ltcpserver.h 파일에

:

class LTcpServer : public QTcpServer 
{ 
    Q_OBJECT 
public: 
    explicit LTcpServer(QObject * parent = 0); 
    void incomingConnection(qintptr socketDescriptor) Q_DECL_OVERRIDE; 
private: 
    QThread *myThread; 
}; 

하고 ltcpserver.cpp의 :

LTcpServer::LTcpServer(QObject * parent) : QTcpServer(parent) 
{ 
    if(this->listen(QHostAddress::Any,30000)) 
    { 
     qDebug() << "server started..."; 
    } 
    else 
    { 
     qDebug() << "server could not be started..."; 
    } 
    myThread = new QThread(); 
    myThread->start(); 
} 

void LTcpServer::incomingConnection(qintptr socketDescriptor) 
{ 
    LSSClient * yourClient = new LSSClient(socketDescriptor); 
    yourClient->moveToThread(myThread); 
    clients->append(yourClient); 
} 

하고 lssclient.h

에서

class LSSClient: public QObject 
{ 
    Q_OBJECT 
public: 
    explicit LSSClient(qintptr socketDescriptor,QObject * parent = 0); 
private: 
    void setupSocket(qintptr socketDescriptor); 
    QTcpSocket * socket; 
public slots: 
    void readyRead(); 
    void disconnected(); 
}; 

그리고 lss client.cpp

LSSClient::LSSClient(qintptr socketDescriptor,QObject * parent) : QObject(parent) 
{ 
    setupSocket(qintptr socketDescriptor); 
} 

void LSSClient::setupSocket(qintptr socketDescriptor) 
{ 
    socket = new QTcpSocket(this); 
    socket->setSocketDescriptor(sDescriptor); 
    connect(socket,SIGNAL(readyRead()),this,SLOT(readyRead())); 
    connect(socket,SIGNAL(disconnected()),this,SLOT(disconnected())); 
} 

void LSSClient::readyRead() 
{ 
    // do whatever you want here with incoming data 
} 

void LSSClient::disconnected() 
{ 
    // do what happens to client when disconnected 
}