QTcpServer :: incomingConnection（qintptr）not calling

Question

我試圖使用QTcpSocket和QTcpServer使客戶端和服務器。

因此，服務器會發生什麼情況。

1. 我運行服務器，它開始偵聽（成功[由我自己檢查]）
2. 我運行客戶端，輸入127.0.0.1爲IP address和30000爲port
3. 客戶說，連接estabilished
4. 服務器沒有按不要做任何事，只要不斷的等待

我的程序的部分：

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

我知道，這個嵌套Thread類是強烈的錯誤的方式做這件事情，但我沒有太多的時間來正確地做到這一點

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

and in your 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 
}