要源碼的朋友太多了，滿(mǎn)眼的郵箱地址，我很頭疼。鑒于現(xiàn)在CSDN首頁(yè)的Qt應(yīng)用大賽正在火熱進(jìn)行中，我干脆把源碼奉獻(xiàn)出來(lái)，給大家參考一下好了。不過(guò)，這不是我一個(gè)人的勞動(dòng)成果，我一直認(rèn)為技術(shù)領(lǐng)域的最高境界是分享，所以希望得到你的尊重。

有什么好的意見(jiàn)和建議歡迎你提，但是請(qǐng)注意語(yǔ)氣。我寫(xiě)博客的目的有兩個(gè)，一是記錄，二是分享。我記錄我的學(xué)習(xí)歷程，分享給大家。我不是神，我想神也不能精通各個(gè)技術(shù)領(lǐng)域，不是最好的方案你就冷嘲熱諷，于情于理都不太合適吧。我這又不是出書(shū)，你掏腰包買(mǎi)了看了覺(jué)得不好，罵幾句才痛快。我自己寫(xiě)我的自己博客，你發(fā)現(xiàn)瑕疵，是好事，歡迎你提出來(lái)，哪來(lái)那么大火氣我就不懂了。你能寫(xiě)出更好的，我向你學(xué)習(xí)。如若不然，在寫(xiě)出作品之前，請(qǐng)別帶著一副大爺?shù)淖炷標(biāo)Ｇ嗥ぁ?

請(qǐng)?jiān)徫艺f(shuō)了那么多前言范er的廢話(huà)，我最后再說(shuō)說(shuō)關(guān)于QThread 的用法，tcpSocket起一個(gè)線(xiàn)程去讀取用戶(hù)注冊(cè)信息這么一檔子事。

線(xiàn)程，就是這么個(gè)模子：

TcpConThread::TcpConThread(int socketDescriptor, QObject *parent) : QThread(parent), socketDescriptor(socketDescriptor) { ... } void TcpConThread::run() { ... }

備個(gè)注吧：QThread類(lèi)提供了與系統(tǒng)無(wú)關(guān)的線(xiàn)程。

QThread代表在程序中一個(gè)單獨(dú)的線(xiàn)程控制，在多任務(wù)操作系統(tǒng)中，它和同一進(jìn)程中的其它線(xiàn)程共享數(shù)據(jù)，但運(yùn)行起來(lái)就像一個(gè)單獨(dú)的程序一樣。它不是在main()中開(kāi)始，QThread是在run()中開(kāi)始運(yùn)行的。你繼承run()并且在其中包含你的代碼。例如：

class MyThread : public QThread { public: virtual void run(); }; void MyThread::run() { for( int count = 0; count < 20; count++ ) { sleep( 1 ); qDebug( "Ping!" ); } } int main() { MyThread a; MyThread b; a.start(); b.start(); a.wait(); b.wait(); }

void QThread::run () [純虛 保護(hù)]
這個(gè)方法是純虛的，并且為了能夠做有用的工作必須在繼承類(lèi)中被重新實(shí)現(xiàn)。這個(gè)方法的返回將會(huì)結(jié)束線(xiàn)程的執(zhí)行。

void QThread::start ()
通過(guò)調(diào)用run()（必須在QThread子類(lèi)中重新實(shí)現(xiàn)來(lái)包含你的代碼）開(kāi)始這個(gè)線(xiàn)程的執(zhí)行。如果你試圖開(kāi)始一個(gè)已經(jīng)運(yùn)行的線(xiàn)程，這個(gè)調(diào)用將一直等待，直到這個(gè)線(xiàn)程完成，然后再重新開(kāi)始這個(gè)線(xiàn)程。

void QThread::exit () [靜態(tài)]

結(jié)束調(diào)用線(xiàn)程的執(zhí)行并且喚醒任何等待它終止的線(xiàn)程。

bool QThread::wait ( unsigned long time = ULONG_MAX )

這將提供和POSIX pthread_join相似的功能。一個(gè)線(xiàn)程調(diào)用了它將會(huì)一直阻塞，知道下述條件之一滿(mǎn)足時(shí)繼續(xù)：

1.這個(gè)QThread對(duì)象所關(guān)聯(lián)的線(xiàn)程已經(jīng)結(jié)束執(zhí)行（比如，當(dāng)它從run()中返回）。如果線(xiàn)程完成，這個(gè)函數(shù)將返回真。如果線(xiàn)程還沒(méi)有開(kāi)始呢，這個(gè)函數(shù)也返回真。

2.time毫秒過(guò)去了。如果time是ULONG_MAX（默認(rèn)值），然后等待將永遠(yuǎn)不會(huì)超時(shí)（線(xiàn)程必須從run()中返回）。如果等待時(shí)間到了，這個(gè)函數(shù)將返回假。

想在線(xiàn)程里干什么，就在run()里寫(xiě)什么，在這里的實(shí)現(xiàn)很簡(jiǎn)單，內(nèi)容都在on_Ready_Read()的實(shí)現(xiàn)里

void TcpConThread::run() { tcpSocket = new QTcpSocket; connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(on_Ready_Read())); if (!tcpSocket->setSocketDescriptor(socketDescriptor)) { emit error(tcpSocket->error()); return; } exec(); }

這個(gè)exec() 就是把整個(gè)進(jìn)程空間換成要執(zhí)行的那個(gè)程序的進(jìn)程空間，說(shuō)白了就把自己換成別人。

void TcpConThread::on_Ready_Read() { /*QString strLogin = tcpSocket->readAll(); QStringList strListUser = strLogin.split("|"); QString id = strListUser.at(0); QString password = strListUser.at(1);*/ db = new SqliteDB; QString ip = tcpSocket->peerAddress().toString(); qint16 port = tcpSocket->peerPort(); QByteArray block = tcpSocket->readAll(); QDataStream in(&block, QIODevice::ReadOnly); //QDataStream in(tcpSocket); quint16 dataGramSize; QString msgType; in >> dataGramSize >> msgType; if ( "MSG_CLIENT_USER_REGISTER" == msgType ) { QString id; QString password; QString name; in >> id >> password >> name; if ( 0 == db->insertNewUser( id, password, name, ip, QString::number(port)) ) { QMessageBox::warning(NULL, tr("提示"), tr("該號(hào)碼已被注冊(cè).")); QString msgType = "MSG_ID_ALREADY_EXIST"; QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); } else { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); QString msgType = "MSG_REGISTER_SUCCESS"; out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); } } else if ( "MSG_USER_LOGIN" == msgType ) { QString id; QString password; in >> id >> password; db->getUserInfo(id); if (db->strListUser.isEmpty()) //MSG_ID_NOTEXIST { QMessageBox::critical(NULL, tr("提示"), tr("沒(méi)有名字") ); QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); QString msgType = "MSG_ID_NOTEXIST"; out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); } else if(db->strListUser.at(1) != password) //MSG_PWD_ERROR { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); QString msgType = "MSG_PWD_ERROR"; out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); } else if (db->strListUser.at(1) == password ) { if ((db->strListUser.at(3)) == "1") //MSG_LOGIN_ALREADY { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); QString msgType = "MSG_LOGIN_ALREADY"; out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); } else //MSG_LOGIN_SUCCESS { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_6); QString msgType = "MSG_LOGIN_SUCCESS"; out << (quint16)0 << msgType; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); tcpSocket->write(block); //login success, update database db->updateUserLogStat(id, "1"); db->updateUserIp(id,tcpSocket->peerAddress().toString()); } } }

還有請(qǐng)注意， QCoreApplication::exec() 必須從主線(xiàn)程(執(zhí)行 main() 方法的線(xiàn)程)調(diào)用， 不從 QThread 調(diào)用。 在GUI應(yīng)用程序，主線(xiàn)程也被稱(chēng)為GUI線(xiàn)程，因?yàn)樗俏ㄒ辉试S執(zhí)行GUI相關(guān)操作的線(xiàn)程。

困死了還有一大堆工作沒(méi)有做，整個(gè)工程的源碼debug版 , release版都打包好上傳至CSDN資源，本地沒(méi)有Qt庫(kù)也可以運(yùn)行體驗(yàn)一下，很?chē)宓氖牵抑荒苌蟼?0M以下的資源，只好縮減了一些UI的特效顯示，唉……只是些UI資源圖片的刪減無(wú)大礙，免費(fèi)0積分下載： 自定義QQ

12點(diǎn)多了晚安~

我的專(zhuān)屬Q(mào)Q （三） 附源碼