发帖 回复
返回列表
  • 11268阅读
  • 5回复

[提问]Qt TcpSocket多线程诡异问题求解... [复制链接]

 上一主题 下一主题
离线a289672082
新手上路
 
只看楼主 倒序阅读 楼主  发表于: 2016-05-16
复制代码
  1. #include <QtWidgets/QMainWindow>
  2. #include "QGridLayout"
  3. #include "QVBOXlAYOUT"
  4. #include "QPushButton"
  5. #include "QLineEdit"
  6. #include "Qlabel"
  7. #include <QTcpSocket>
  8. #include <QHostAddress>
  9. #include <QMessageBox>
  10. #include <functional>
  11. #include <QTcpServer>
  12. #include "mythread.h"
  13. class MyWindow : public QWidget
  14. {
  15.     Q_OBJECT
  17. public:
  18.     QTcpServer* server;
  19.     MyWindow(QWidget *parent = 0);
  20.     ~MyWindow();
  21.     QPushButton *  btn;
  22.     QLabel* label;
  23.     QLineEdit* edit;
  24.     QVBoxLayout* Vbox;
  25.     QGridLayout* grid;
  26.      signals:
  27.     void mainwrite(QString);
  28.     public slots:
  29.     void On_TestBtn_Cliked();
  30.     void  acceptConnection();
  32. };

复制代码
  1. MyWindow::MyWindow(QWidget *parent)
  2.     : QWidget(parent)
  3. {
  5.     
  6.     
  7.     label = new QLabel(QStringLiteral(""));
  8.     btn  = new QPushButton("send");
  9.     edit = new QLineEdit();
  11.     grid = new QGridLayout();
  12.     grid->addWidget(edit,0,0);
  13.     grid->addWidget(btn,0,1);
  15.     Vbox = new QVBoxLayout();
  16.     Vbox->addLayout(grid);
  18.     Vbox->addWidget(label);
  19.      setLayout(Vbox);
  21.     
  22.     fuc1 fu = std::bind(&MyWindow::On_TestBtn_Cliked, this);
  23.     connect(btn, &QPushButton::clicked, this, fu);
  25.     server = new QTcpServer(this);
  26.     server->listen(QHostAddress::Any, 6665);
  27.     connect(server, SIGNAL(newConnection()), this, SLOT(acceptConnection()));
  29.     
  30. }
  31. void MyWindow::acceptConnection()
  32. {
  33.     qDebug() << "main id:" << QThread::currentThreadId();
  35.     QTcpSocket*  clientConnection = server->nextPendingConnection();
  36.     qDebug() << __LINE__;
  37.     MyWork*  thread_Tmp = new MyWork(clientConnection->socketDescriptor(),NULL);
  38.     connect(this, &MyWindow::mainwrite, thread_Tmp, std::bind(&MyWork::writeslot, thread_Tmp, std::placeholders::_1));
  39.     qDebug() << __LINE__;
  40.   
  42.   all.append(thread_Tmp);
  43.     
  46. }  
  47. MyWindow::~MyWindow()
  48. {
  50. }
  53. #include <QEvent>
  54. #include <QApplication>
  55. void MyWindow::On_TestBtn_Cliked()
  56. {
  57.     qDebug() << "write fuc";
  58.     emit mainwrite(edit->text());
  59.   
  60. }
线程中接收数据没问题,发送数据第二次出现问题,尝试了各种方法。。。
复制代码
  1. class   MyWork :public QObject
  2. {
  3.     Q_OBJECT
  4. public:
  5.     QThread * m_thread;
  6.     QTcpSocket* socket;
  7.     int m_socketid;
  9.     MyWork(int socketid, QObject* parent = NULL);
  10.     ~MyWork();
  11.     public slots:
  12.     void readClient();
  13. signals:
  14.     void wirte(QString);
  15.     public slots :
  16.     void writeslot(QString);
  18. private:
  19. };
复制代码
  1. MyWork::MyWork(int socketid, QObject* parent) :QObject(parent)
  2. {
  4.     socket = NULL;
  5.     m_socketid = socketid;
  6.     m_thread = new QThread();
  7.     socket = new QTcpSocket();
  8.     socket->setSocketDescriptor(this->m_socketid);
  9.     connect(socket, SIGNAL(readyRead()), this, SLOT(readClient()), Qt::DirectConnection);
  10.     this->moveToThread(m_thread);
  11.     m_thread->start();
  16. }
  17. void MyWork::readClient()
  18. {
  19.     qDebug() << "thread get msg id:" << QThread::currentThreadId() << "read:" << socket->readAll();
  20. }
  21. void MyWork::writeslot(QString s)
  22. {
  23.     qDebug() << "writeslot  id:" << QThread::currentThreadId();
  24.     socket->write(s.toStdString().c_str());
  25.   [backcolor=#ffffff][color=#008ef1]   socket->waitForBytesWritten(); //这行代码会导致 套接字[9904]QSocketNotifier:从另一个线程通知不能启用或禁用  但是注释会导致发送过一次数据 下次就无法发送[/color][/backcolor]
  27.     qDebug() << "wait write end";
  28. }
  29. MyWork::~MyWork()
  30. {
  31. }

帮我看看
   socket->waitForBytesWritten(); //这行代码会导致 套接字[9904]QSocketNotifier:从另一个线程通知不能启用或禁用  但是注释会导致发送过一次数据 下次就无法发送
的诡异问题,谢谢各位了
通过按钮触发socket发送数据,Qobject不能跨线程调用,因此用MovetoThread了,但是问题依旧，然后尝试了QEvent,问题依旧。Qt socket只能在线程内部写入吗,必须得用底层的API实现socket吗
接收和发送的函数打印出来都是在线程中,为啥还有这个问题呐！
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线lemonzll
侠客
只看该作者 1楼 发表于: 2016-05-16
代码我没试过，有点问题，MyWork里面socket的parent没有设置，调用moveToThread的时候socket没有切换到其他线程，你在writeSlot里面调用write的时候socket就跨线程调用了，这样会有警告。还有就是MyWork里面你不要这样根据线程描述符重建socket，直接还用原来的socket就可以
回复
举报
离线jxgyzhang
新手上路
只看该作者 2楼 发表于: 2016-05-16
楼上说的对你也可以把socket也移动到新的线程中去
    socket = NULL;
    m_socketid = socketid;
    m_thread = new QThread();
    socket = new QTcpSocket();
    socket->setSocketDescriptor(this->m_socketid);
    connect(socket, SIGNAL(readyRead()), this, SLOT(readClient()), Qt::DirectConnection);
    socket ->moveToThread(m_thread);
    this->moveToThread(m_thread);
    m_thread->start();
回复
举报
离线a289672082
新手上路
只看该作者 3楼 发表于: 2016-05-16
回 lemonzll 的帖子
lemonzll:代码我没试过，有点问题，MyWork里面socket的parent没有设置，调用moveToThread的时候socket没有切换到其他线程，你在writeSlot里面调用write的时候socket就跨线程调用了，这样会有警告。还有就是MyWork里面你不要这样根据线程描述符重建socket，直接还用原来的socket就可以 (2016-05-16 08:37) 

谢谢  我现在试试
回复
举报
离线a289672082
新手上路
只看该作者 4楼 发表于: 2016-05-16
回 jxgyzhang 的帖子
jxgyzhang:楼上说的对你也可以把socket也移动到新的线程中去
    socket = NULL;
    m_socketid = socketid;
    m_thread = new QThread();
    socket = new QTcpSocket();
....... (2016-05-16 09:49) 

谢谢  我现在去试试
回复
举报
离线a289672082
新手上路
只看该作者 5楼 发表于: 2016-05-16
@jxgyzhang    @lemonzll    两位  问题解决了  是socket没有指定parent.

代码改成:
m_thread = new QThread();
socket = new QTcpSocket(this);
socket->setSocketDescriptor(this->m_socketid);
就没问题了

总结:moveToThread,要小心,不能跨线程的对象不指定parent也属于跨线程操作
本帖提到的人: @jxgyzhang @lemonzll
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个