发帖 回复
返回列表
  • 10871阅读
  • 9回复

QTcpSocket问题-服务器断开-崩溃！ [复制链接]

 上一主题 下一主题
离线xairwolfcn
新手上路
 
只看楼主 倒序阅读 楼主  发表于: 2012-03-29
关键词： 求助QT4初学者的问题网络通信网络
RT 请高手指教-谢谢帮忙！
我自己参照网上的一些资料写了个QTcpSocket的线程！当我连接到服务器后，然后让服务器断开连接，程序有时候就正常，但是大多数情况下程序就崩溃！
错误信息如下图：


就是d这个参数有问题！  
  if (d->socketEngine)
        d->socketEngine->setReadNotificationEnabled(false); 执行完这句就挂了！！


我尝试过用Designer进行编译，MinGw进行编译，并且今天我还更新了新的QT4.8.1（以前是4.8.0），都是崩溃，一会儿就好了！
我把链接socket状态信号和自定义槽，注释掉后,就留下发射数据的信号，就没有任何问题！如下：
  1. //connect(socketClient, SIGNAL(connected()),this, SLOT(sendRequest()));
  2. //connect(socketClient, SIGNAL(disconnected()), this,SLOT(connectionCloseByServer()));
  3. connect(socketClient, SIGNAL(readyRead()), this, SLOT(recvdatagram()),Qt::DirectConnection);
  4. //connect(socketClient, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(error()));


所以我怀疑我的代码写的有问题，请各位高手指点！！
贴源码：
SocketThread.h
复制代码
  1. #ifndef SOCKETTHREAD
  2. #define SOCKETTHREAD
  4. #include <QtNetwork/QtNetwork>
  5. #include <QThread>
  8. class SocketThread : public QThread
  9. {
  10. Q_OBJECT
  12. //function
  13. public:
  14. SocketThread(QHostAddress addr, int port);
  15. ~SocketThread();
  16. //通过该函数删除socket
  17. void Stop();
  19. // variable
  20. public:
  22. //variable
  23. private:
  25. int sum;
  26. bool needStopThread;
  27. QTcpSocket *socketClient;
  28. quint16 readBufferSize;
  29. quint16 nextBlockSize;
  30. QByteArray datagram;
  32. QHostAddress _hostAddress;
  33. int _portNumber;
  35. //function
  36. private:
  37. void closeConnection();
  39. private slots:
  40. void sendRequest();
  41. void connectionCloseByServer();
  42. void error();
  43. void recvdatagram();
  44. signals:
  45. //将接收到的数据和状态发射出去！
  46. void RecvDateDisplay(QByteArray str);
  47. void SumDisplay(int s);
  48. void disButtonDisplay(bool b);
  49. void conButtonDisplay(bool a);
  50. void proBarDisplay(bool a);
  51. void staLabeDisplay(QString str);
  53. protected:
  54. virtual void run();
  55. };
  56. #endif //SOCKETTHREAD

SocketThread.cpp
复制代码
  1. #include "SocketThread.h"
  2. #include <QtGui>
  4. SocketThread::SocketThread(QHostAddress addr, int port)
  5. {
  6. _hostAddress =addr;
  7. _portNumber = port;
  8. sum = 0;
  9. needStopThread = false;
  10. socketClient=NULL;
  11. readBufferSize = 256;
  13. qRegisterMetaType<QAbstractSocket::SocketError>("QAbstractSocket::SocketError");
  14. }
  15. SocketThread::~SocketThread()
  16. {
  17. needStopThread = false;
  18. closeConnection();
  19. quit();
  20. wait();
  21. }
  23. void SocketThread::sendRequest()
  24. {
  25. emit staLabeDisplay(tr("Connected!"));
  26. emit proBarDisplay(false);
  27. }
  28. void SocketThread::connectionCloseByServer()
  29. {
  30. if (nextBlockSize != 0xFFFF)
  31. {
  32. emit staLabeDisplay(tr("Error:connection closed by server"));
  33. emit proBarDisplay(false);
  34. }
  36. if (socketClient)
  37. {
  38. socketClient->close();
  39. exit();
  40. wait();
  41. }
  43. }
  44. void SocketThread::error()
  45. {
  46. emit staLabeDisplay(socketClient->errorString());
  47. emit proBarDisplay(false);
  48. emit conButtonDisplay(true);
  49. emit disButtonDisplay(false);
  51. if (socketClient)
  52. {
  53. socketClient->close();
  54. exit();
  55. wait();
  56. }
  57. }
  58. void SocketThread::run()
  59. {
  61. nextBlockSize = 0;
  63. socketClient = new QTcpSocket;
  65. if (!_hostAddress.isNull() && _portNumber >0)
  66. {
  67. socketClient->abort();
  68. socketClient->connectToHost(_hostAddress, _portNumber, QIODevice::ReadOnly);
  69. socketClient->setReadBufferSize(readBufferSize);
  70. emit staLabeDisplay(tr("Connect to Server........"));
  71. emit proBarDisplay(true);
  72. emit conButtonDisplay(false);
  73. emit disButtonDisplay(true);
  74. }
  75. //slot
  77. connect(socketClient, SIGNAL(connected()),this, SLOT(sendRequest()));
  78. connect(socketClient, SIGNAL(disconnected()), this,SLOT(connectionCloseByServer()));
  79. connect(socketClient, SIGNAL(readyRead()), this, SLOT(recvdatagram()),Qt::DirectConnection);
  80. connect(socketClient, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(error()));
  83. exec();
  84. while(needStopThread)
  85. {
  86. if (socketClient)
  87. {
  88. closeConnection();
  89. }
  90. break;
  91. }
  93. }
  94. void SocketThread::closeConnection()
  95. {
  96. socketClient->abort();
  97. socketClient->close();
  98. delete socketClient;
  99. socketClient = NULL;
  101. sum =0;
  102. emit proBarDisplay(false);
  103. emit conButtonDisplay(true);
  104. emit disButtonDisplay(false);
  105. }
  106. void SocketThread::Stop()
  107. {
  108. needStopThread = true;
  109. }
  110. void SocketThread::recvdatagram()
  111. {
  112. if (socketClient->bytesAvailable() >0)
  113. {
  114. datagram.resize(socketClient->bytesAvailable());
  115. socketClient->read(datagram.data(), datagram.size());
  116. sum = sum +datagram.size();
  118. emit SumDisplay(sum);
  119. emit RecvDateDisplay(datagram);
  120. }
  121. }
OASIS
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线xairwolfcn
新手上路
只看该作者 1楼 发表于: 2012-03-29
对了我的开发环境是 vs2008 + qt-win-opensource-4.8.1-vs2008.exe +Qt Visual Studio Add-in 1.1.10
OASIS
回复
举报
离线淳于半邪
骑士
只看该作者 2楼 发表于: 2012-03-30
明显是内存问题，自己检查下
回复
举报
离线xairwolfcn
新手上路
只看该作者 3楼 发表于: 2012-03-30
回 2楼(淳于半邪) 的帖子
关键是我主动关闭线程，socket就没有问题！ 只有在连接好的服务器短掉的时候才出问题！
OASIS
回复
举报
离线xairwolfcn
新手上路
只看该作者 4楼 发表于: 2012-03-30
回 2楼(淳于半邪) 的帖子
关键是我想调试都进不去 我的程序！直接进QAbstractSocket，没法搞！！
OASIS
回复
举报
离线淳于半邪
骑士
只看该作者 5楼 发表于: 2012-03-31
回 3楼(xairwolfcn) 的帖子
那你应该在服务器断开做相应的处理
回复
举报
离线xairwolfcn
新手上路
只看该作者 6楼 发表于: 2012-03-31
回 5楼(淳于半邪) 的帖子
服务器断开，后我的程序是 连接了个槽
78.connect(socketClient, SIGNAL(disconnected()), this,SLOT(connectionCloseByServer()));
可是问题是，我做单步调试，根本就进不到connectionCloseByServer（）里面去！！
所以比较纠结！
OASIS
回复
举报
离线淳于半邪
骑士
只看该作者 7楼 发表于: 2012-04-01
回 6楼(xairwolfcn) 的帖子
单从这个上面看是没错的，你在仔细检查下自己的程序
回复
举报
离线xairwolfcn
新手上路
只看该作者 8楼 发表于: 2012-04-01
回 7楼(淳于半邪) 的帖子
麻烦大哥，给我指个方向。。现在我都找了好几天了。。都没有结果！哎！
OASIS
回复
举报
离线xairwolfcn
新手上路
只看该作者 9楼 发表于: 2012-04-12
问题的原因找到了！应该采用阻塞式通信方式，参照Qt自带的例子，Blocking Fortune Client Example
就没有问题！！
OASIS
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个