Qt中实现QThread线程同步QFtp
创始人
2024-07-31 15:40:34
0

Qt中实现QThread线程同步QFtp ,对于QFtp,它是一个用来实现FTP协议的类,详情查阅资料。接触Qt没有多长时间,但简单几个小例子已经让我感受到Qt在C++运用方面的强大。写了一个小程序,需要在一个单独的线程中使用QFtp来获取FTP服务器上面的文件。FTP是FileZilla。

有两个问题我比较关心:

(1)QThread到底如何使用

(2)QFtp是Async(异步)操作,也就是说例如connectToHost这样的函数都是立刻返回,当操作完成后QFtp会发出signal。然而既然我的Ftp操作是在一个单独的线程,我想写一个函数downloadFtpFile() 来完成从connect到login到下载文件等一系列的操作,然后再返回。相当于我需要Sync(同步)的操作,所以需要等待(block)每个Ftp命令的结果。

在该文章最后有一个推荐的使用QThread的方法。我在这里想补充一点:obj.moveToThread(&thread); 这句话将obj从主线程移动到了thread对象所在的线程。但如果obj的对象里面有其他的变量,那么这些变量是在主线程中生成的。所以如果这些变量中有类变量,不能将obj的this指针作为parent传给他们。

对于第二个问题,我使用了QSemaphore类来完成我的block和同步操作:在slot函数里面接收QFtp命令执行结果的signal,释放信号,同时downloadFtpFile()函数里在调用完每一个QFtp异步命令后等待信号。在有点令人失望的是QSemaphore在通过tryAcquire()等待信号的时候是不处理事件event的。但是我需要在等待的时候程序也能触发slot,告诉我当前命令的执行情况。所以我使用了一个小循环,里面调用qApp->processEvents();来让我的slot函数被触发。下面是代码例子(只是样例,并不完全符合C++语法):

首先是我的下载Ftp文件的函数:

 

  1. downloadFtpFile () //该函数在单独线程里执行     
  2. {     
  3.      int m_idFtpOp; // 该变量用来存放每一个QFtp命令ID     
  4.      int nVal;     
  5.      QFtp*pFtp=newQFtp (this); // 生成QFtp工具对象     
  6.      connect (pFtp,SIGNAL(listInfo(QUrlInfo)),this,SLOT(slotFtpListInfo(QUrlInfo))); // 我们需要listinfo,因为我们需要下载ftp所有当前目录文件     
  7.      connect (pFtp,SIGNAL(commandFinished(int,bool)),this,SLOT(slotFtpCmdFinished(int,bool)));   
  8. // 每个QFtp命令完成之后,会发出commandFinished信号,我们在槽函数中处理该信号  
  9.      m_idFtpOp = pFtp->connectToHost (, 21); // 连接到远程FTP Server     
  10.      bRet=false;     
  11.      nVal=100;     
  12.      while (bRet == false) // 使用nVal变量来做一个10000ms(10s)的超时     
  13.      {     
  14.            nVal--;     
  15.            if (nVal == 0)     
  16.                 break;     
  17.            qApp->processEvents();   // 这里每100ms处理一次event,使slot函数能够被调用     
  18.            bRet=m_SemOp.tryAcquire (1,100); // 等待信号100ms     
  19.      }     
  20.     if (!bRet || m_bFtpOpError)   // 如果超时,或者slot函数中将m_bFtpOpError置成true,则关闭Ftp,返回错误     
  21.       {     
  22.            pFtp->abort();     
  23.            pFtp->deleteLater();     
  24.            return ERRCODE_FCC_FTP_CONN_TIMEOUT;     
  25.      }     
  26. }   

下面是槽函数

  1. slotFtpCmdFinished (int id, bool error)     
  2. {     
  3.          if (m_idFtpOp == id)  // 如果返回的id是当前正在操作的命令     
  4.          {     
  5.                   if (error)     
  6.                            m_bFtpOpError=true;     
  7.                   else    
  8.                            m_bFtpOpError=false;     
  9.                   m_SemOp.release();  // 释放信号(使downloadFtpFile函数中m_SemOp.tryAcquire()返回true)     
  10.          }     
  11. }   

以上的代码只演示了对QFtp第一个命令connectToHost的等待过程。下面的login,list,get等操作都使用这个方法。

注意:在此例中,QFtp是在当前线程生成的,所以信号listInfo(QUrlInfo)的connect方式是direct连接。如果QFtp是在另一个线程生成(比如说是在函数downloadFtpFile所在类的构造函数中),那么第一:不能将this指针作为parent传给QFtp对象,第二:需要使用qRegisterMetaType("QUrlInfo");来注册QUrlInfo类,因为信号发射与接收在不通的线程中,信号使用queued的方式。如果不注册QURlInfo类,会在运行时动态报告错误。

总结:本文介绍的是在Qt中如何实现QThread线程同步QFtp ,看过本文之后,如果对于QThread不了解的话,那么请参考Qt中QThread使用方法这篇文章。使用本文介绍的方法,可以在独立的线程中用同步的方式使用QFtp。在某些场合,尤其是采用应答机制的系统中,这样的实现可以很大程度上简化程序流程。

【编辑推荐】

浅谈Qt中多线程编程

Qt环境变量配置与安装

在Linux中设置Qt环境变量

用C#实现HTTP协议下的多线程文件传输

C#常用线程同步方法应用场景和实现原理

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
Windows恶意软件20年“... 在Windows的早期年代,病毒游走于系统之间,偶尔删除文件(但被删除的文件几乎都是可恢复的),并弹...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...
着眼MAC地址,解救无法享受D... 在安装了DHCP服务器的局域网环境中,每一台工作站在上网之前,都要先从DHCP服务器那里享受到地址动...
为啥国人偏爱 Mybatis,... 关于 SQL 和 ORM 的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行...