QTcoSocket прием данных в отдельном потоке.

[GPPsoft]

Какие-то неудобные сокеты в Qt... Ощущение кривоты! Сделал вот так, но теперь непонятно как timeout сделать?

Код:

void TCPSocket::onReady()
{
    while(socket->bytesAvailable()){
        QByteArray data=socket->readAll();
        qDebug()<<"Данные";
    }
}

void TCPSocket::run(){
    connect(socket,SIGNAL(disconnected()),this,SLOT(_disconnected()));
    connect(socket,SIGNAL(readyRead()),this,SLOT(onReady()));
    exec();
}

[Fregloin]

неужели так трудно последовать моему совету и порыться в ветке связанной с сетью на форуме? там таких вопросов штук 5 минимум если не больше, и везде есть разъяснения. с конкретными примерами.

[GPPsoft]

неужели так трудно последовать моему совету и порыться в ветке связанной с сетью на форуме? там таких вопросов штук 5 минимум если не больше, и везде есть разъяснения. с конкретными примерами.

Вы не поверите. Я уже 2 дня сижу над этим вопросом. И гуглил и искал. Я не нашел решения моей проблемы!

[Kurles]

Какие-то неудобные сокеты в Qt... Ощущение кривоты! Сделал вот так, но теперь непонятно как timeout сделать?

Вы просто не умеете их готовить ) А для таймаутов есть QTimer

[kuzulis]

GPPsoft,

покамест все неправильно. Читай документацию, смотри пимеры, гугли, работай. А то развелось халявщихов, которые хотят все получить с наскоку, сразу.

[GPPsoft]

GPPsoft,

покамест все неправильно. Читай документацию, смотри пимеры, гугли, работай. А то развелось халявщихов, которые хотят все получить с наскоку, сразу.

А так?

Код

C++ (Qt)
#include "tcpsocket.h"
 
 
TCPSocket::TCPSocket(QObject *parent) :QThread(parent)
{
}
 
bool TCPSocket::connectTo(QString hostName, int port){
    socket = new QTcpSocket();
    connect(socket,SIGNAL(disconnected()),this,SLOT(onDisconnect()));
    socket->connectToHost(hostName, port);
 
    if (!socket->waitForConnected(5000)) {
        emit error(socket->errorString());
        return false;
    }else{
        if(!isRunning())
            start();
        return true;
    }
}
 
void TCPSocket::killConnection(){
    socket->disconnectFromHost();
}
 
void TCPSocket::sendData(const QByteArray &packet){
    socket->write(packet,packet.length());
    socket->flush();
}
 
void TCPSocket::onDataReceive()
{
    while(socket->bytesAvailable()){
        QByteArray data=socket->readAll();
        qDebug()<<"Данные";
    }
}
 
void TCPSocket::onDisconnect(){
    emit disconnected();
    exit(0);
}
 
void TCPSocket::run(){
    QTcpSocket tcpSocket;
    connect(&tcpSocket,SIGNAL(readyRead()), this, SLOT(onDataReceive()));
    if (!tcpSocket.setSocketDescriptor(socket->socketDescriptor())) {
        emit error(tcpSocket.errorString());
        return;
    }
    exec();
}
 

Нихрена прием данных не работает теперь.. Ну и гемморой в Qt с сокетами. Ужас!

[GPPsoft]

В продолжение геммороя. Сделал по "феншую", все через сигналы и слоты. Теперь при отправке данных через сигнал славливаю все те же
QSocketNotifier: socket notifiers cannot be enabled from another thread
QSocketNotifier: socket notifiers cannot be disabled from another thread

.h GUI

Код

C++ (Qt)
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
 
#include <QMainWindow>
#include <tcpsocket.h>
//#include <hubsession.h>
 
namespace Ui {
class MainWindow;
}
 
class MainWindow : public QMainWindow
{
    Q_OBJECT
 
public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();
signals:
    void sendData(const QByteArray &packet);
private slots:
    void on_connectButton_clicked();
    void on_sendButton_clicked();
    void disconnected();
    void connected();
    void error(QString error);
    void on_pushButton_clicked();
private:
    Ui::MainWindow *ui;
    TCPSocket *socket;
};
 
#endif // MAINWINDOW_H
 

.cpp GUI

Код

C++ (Qt)
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include "QMessageBox"
 
MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow)
{
    ui->setupUi(this);
    socket = new TCPSocket();
 
    connect(socket,SIGNAL(connected()),this,SLOT(connected()));
    connect(socket,SIGNAL(disconnected()),this,SLOT(disconnected()));
    connect(socket,SIGNAL(error(QString)),this,SLOT(error(QString)));
    connect(this,SIGNAL(sendData(QByteArray)),socket,SLOT(sendData(QByteArray)));
}
 
void MainWindow::disconnected(){
    QMessageBox::information(this,"Внимание","Отключились");
}
 
void MainWindow::connected(){
    QMessageBox::information(this,"Внимание","Подключились!");
}
 
void MainWindow::error(QString error){
    QMessageBox::information(this,"Внимание",error);
}
 
MainWindow::~MainWindow()
{
    delete ui;
}
 
void MainWindow::on_connectButton_clicked()
{
   socket->connectTo("192.168.0.3",3478);
}
 
void MainWindow::on_sendButton_clicked()
{
   emit sendData(ui->textToSend->toPlainText().toUtf8().data());
}
 
void MainWindow::on_pushButton_clicked()
{
    socket->killConnection();
}
 

.h TCPSocket

Код

C++ (Qt)
#ifndef TCPSOCKET_H
#define TCPSOCKET_H
 
#include <QThread>
#include <QtNetwork>
 
typedef unsigned char BYTE;
 
class TCPSocket : public QThread
{
    Q_OBJECT
public:
    TCPSocket(QObject *parent = 0);
    void run();
    void connectTo(QString hostName, int port);
    void killConnection();
private:
    QTcpSocket *socket;
    QString hostName;
    int port;
private slots:
    void onDataReceive();
    void onDisconnect();
public slots:
    void sendData(const QByteArray &packet);
signals:
  void disconnected();
  void connected();
  void error(QString error);
};
 
#endif // TCPSOCKET_H
 

.cpp TCPSocket

Код

C++ (Qt)
#include "tcpsocket.h"
 
TCPSocket::TCPSocket(QObject *parent) :QThread(parent)
{
}
 
void TCPSocket::connectTo(QString hostName, int port){
    this->hostName=hostName;
    this->port=port;
 
    if(!isRunning())
        start();
}
 
void TCPSocket::killConnection(){
    socket->disconnectFromHost();
}
 
void TCPSocket::sendData(const QByteArray &packet){
    socket->write(packet,packet.length());
    socket->flush();
}
 
void TCPSocket::onDataReceive()
{
    while(socket->bytesAvailable()){
        QByteArray data=socket->readAll();
        qDebug()<<"Данные";
    }
}
 
void TCPSocket::onDisconnect(){
    emit disconnected();
    exit(0);
}
 
void TCPSocket::run(){
 
    socket = new QTcpSocket();
    connect(socket,SIGNAL(readyRead()),this,SLOT(onDataReceive()));
    connect(socket,SIGNAL(disconnected()),this,SLOT(onDisconnect()));
    socket->connectToHost(hostName, port);
 
    if (!socket->waitForConnected(5000)) {
        emit error(socket->errorString());
        return;
    }
 
    emit connected();
 
    exec();
}
 

Что я делаю не так?! Уже перерыл кучу информации и в google и тут на форуме. Сижу 3 день! Подскажите кто-нибудь, я готов уже заплатить за подсказку. Как мне сделать так, чтобы прием и обработка данных были в отдельном потоке а отправку отключение и подключение к хосту я мог делать в потоке GUI? Спасибо!

[Old]

Про невозможность отключения нотифиера сообщение, как я вижу, выдается при попытке отключиться?
А в какой момент получаете сообщение о невозможности включения нотификатора?

[GPPsoft]

Про невозможность отключения нотифиера сообщение, как я вижу, выдается при попытке отключиться?
А в какой момент получаете сообщение о невозможности включения нотификатора?

При вызове TCPSocket::sendData. Не важно напрямую вызывать или через сигнал. Одна и та же ошибка в логи сваливается.

[Old]

При вызове TCPSocket::sendData. Не важно напрямую вызывать или через сигнал. Одна и та же ошибка в логи сваливается.

Ага точно - увидал.
Все работает так, как вы написали. Не сердитесь, но вам нужно получше разобраться именно в поддержке ниток в Qt.
На форуме очень много раз поднималась эта тема, совсем недавно я пытался на пальцах это рассказать в очередной раз - поищите.
Смысл в неправильных типах connect, которые Qt не может корректно определить, в виду того что все соединяемые объекты находятся в контексте одной нитки.

[GPPsoft]

При вызове TCPSocket::sendData. Не важно напрямую вызывать или через сигнал. Одна и та же ошибка в логи сваливается.

Ага точно - увидал.
Все работает так, как вы написали. Не сердитесь, но вам нужно получше разобраться именно в поддержке ниток в Qt.
На форуме очень много раз поднималась эта тема, совсем недавно я пытался на пальцах это рассказать в очередной раз - поищите.
Смысл в неправильных типах connect, которые Qt не может корректно определить, в виду того что все соединяемые объекты находятся в контексте одной нитки.

Что делать и как быть? Нужно решение здесь и сейчас. К сожалению пока нет времени вникать особо глубоко. Портирую один свой довольно большой проект. Уже к сожалению подумываю о связке java + JNI. Очень странно что на мой субъективный взгляд работа с сокетами так криво реализована в данном фреймворке. Считаю что получение данных обязательно должно быть в отдельном потоке... Как я понимаю в Qt классы для работы с сокетами по умолчанию асинхронные. Вообщем уже в 10 наверное раз пытаюсь попробовать Qt "на вкус" и все как-то чаще на "горечь" наталкиваюсь. Очень жаль. Но альтернатив почти нет.

[GPPsoft]

Самое интересное что программа не падает и даже отправляет пакет, но не правильно все это как-то. В логах должно быть чисто

[Old]

Что делать и как быть? Нужно решение здесь и сейчас.

Код

C++ (Qt)
TCPSocket::TCPSocket(QObject *parent) :QThread(parent)
{
    moveToThread( this );
}
 

[Old]

Очень странно что на мой субъективный взгляд работа с сокетами так криво реализована в данном фреймворке.

Просто вы с ним не очень разобрались.

Но для серьезных применений тоже QtNetwork не использую, предпочитаю boost asio.

[GPPsoft]

Что делать и как быть? Нужно решение здесь и сейчас.

Код

C++ (Qt)
TCPSocket::TCPSocket(QObject *parent) :QThread(parent)
{
    moveToThread( this );
}
 

Это что за кривота? Зачем поток в себя же запихивать?!