QTcpServer :: incomingConnection（qintptr）が呼び出されない

Question

QTcpSocketとQTcpServerを使用してクライアントとサーバーを作成しようとしています。

したがって、サーバーはどうなりますか。

1. 私は、サーバーを実行し、それは（成功した[自分でチェックする]）待機を開始
2. 私は、クライアントを実行し、port
3. ためIP addressと30000ため127.0.0.1を入力します。クライアントは接続が
4. サーバーのdoesnのに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 

私は、このネストされたスレッドクラスは、このことを行うために強く間違った方法であることを知っているが、私は正しく

// 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; 
} 

をそれを行うには多くの時間を持っていない、サーバはちょうどより1（何も書いていない保ちます）毎秒、クライアントはそれがサーバーに接続されていると言います。

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 
}