Я настраиваю клиента, работающего с QTcpSocket
, Часть, в которой установлено соединение с сервером, должна быть реализована в виде потока.
Вот так выглядит мой класс, который реализует функции соединения (.hpp):
class Connector: public QObject {
Q_OBJECT
public:
Connector(QString hexHost);
virtual ~Connector();
// Start to establish a connection
void startConnection();
// End thread
void stopConnection();
signals:
// Emitted, if connector should get to work
void startTransforming();
// Emitted, if transformation from hex to dig is complete
void transformationFinished();
// Emitted, if connection is established
void connectionEstd();
// Emitted, if connection failed
void connectionFailed();
// Emitted, if work is done
void doneConnecting();
public slots:
// Connect to server
void connectToServer();
private:
// IP of the server
QString addressHost;
// Socket
QTcpSocket aQTcpSocket;
};
И вот как я реализовал этот класс (.cpp);
Connector::Connector(QString hexHost)
{
// Save user data
addressHost = hexHost;
// Start thread
bool result = QObject::connect(this, SIGNAL(startTransforming()), this, SLOT(transformIP()));
Q_ASSERT(result);
// Start trying to establish a connection
result = QObject::connect(this, SIGNAL(transformationFinished()), this, SLOT(connectToServer()));
Q_ASSERT(result);
// End thread
result = QObject::connect(this, SIGNAL(doneConnecting()), this, SLOT(deleteLater()));
Q_ASSERT(result);
Q_UNUSED(result);
}
Connector::~Connector()
{
QObject::disconnect(this, SIGNAL(startTransforming()), this, SLOT(transformIP()));
QObject::disconnect(this, SIGNAL(transformationFinished()), this, SLOT(connectToServer()));
QObject::disconnect(this, SIGNAL(doneConnecting()), this, SLOT(deleteLater()));
}
void Connector::transformIP()
{
[...]
// Emit ready signal
emit transformationFinished();
}
void Connector::connectToServer()
{
aQTcpSocket.connectToHost(addressHost, port);
result = aQTcpSocket.waitForConnected(5000);
if(result)
{
emit connectionFailed();
emit doneConnecting();
std::clog << "Connection failed!" << std::endl; // This debug message is printed during runtime
return;
}
// Emit signal
emit connectionEstd();
}
void Connector::startConnection()
{
emit startTransforming();
}
void Connector::stopConnection()
{
emit doneConnecting();
}
Я начинаю тему с:
[...]
// Create new thread
QThread *conThread = new QThread();
// Create connector object
aConnector = new Connector(hexHost);
aConnector->moveToThread(conThread);
conThread->start();
// Clean up thread
bool result = QObject::connect(aConnector, SIGNAL(destroyed()), conThread, SLOT(quit()));
Q_ASSERT(result);
result = QObject::connect(conThread, SIGNAL(finished()), conThread, SLOT(deleteLater()));
Q_ASSERT(result);
// Connect signals
result = QObject::connect(aConnector, SIGNAL(connectionFailed()), this, SLOT(onConnectionFailed()));
Q_ASSERT(result);
result = QObject::connect(aConnector, SIGNAL(connectionEstd()), this, SLOT(onConnectionEstd()));
Q_ASSERT(result);
Q_UNUSED(result);
// Get connector to work
aConnector->startConnection();
[...]
Когда я тестирую программу, соединитель создается правильно. Он запускает функции transformIP () и connectToServer ().
В настоящее время у меня не работает сервер, поэтому клиент не может подключиться. Это должно привести к излучению сигнала
connectionFailed ()
Клиентский класс, который запускает поток с объектом соединителя, должен получить этот сигнал и реагировать на него.
Проблема в:
Кажется, что сигнал не излучается, потому что клиентский класс не реагирует на него.
Вот часть в клиентском классе, где я подключаю сигнал к определенному слоту:
// Connect signals
result = QObject::connect(aConnector, SIGNAL(connectionFailed()), this, SLOT(onConnectionFailed()));
Q_ASSERT(result);
Было бы здорово, если бы у кого-то была идея, как это решить, спасибо 🙂
Это выглядит как QTcpSocket.connectToHost
возвращаемое значение void и вызов асинхронный. Что вам нужно сделать, это позвонить QTcpSocket.connectToHost()
и дождитесь окончания соединения QTcpSocket.waitForConnected( CONNECT_TIME_OUT )
и еще обработать плохое соединение
Пример:
QTcpSocket socket;
socket.connectToHost(QHostAddress("172.0.0.1", 8080);
if (!socket.waitForConnected(5000)) {
emit connectionFailed();
}
Других решений пока нет …