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

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

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

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

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

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

QThread代表在程序中一個(gè)單獨(dú)的線程控制，在多任務(wù)操作系統(tǒng)中，它和同一進(jìn)程中的其它線程共享數(shù)據(jù)，但運(yùn)行起來就像一個(gè)單獨(dú)的程序一樣。它不是在main()中開始，QThread是在run()中開始運(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è)方法是純虛的，并且為了能夠做有用的工作必須在繼承類中被重新實(shí)現(xiàn)。這個(gè)方法的返回將會(huì)結(jié)束線程的執(zhí)行。

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

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

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

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

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

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

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

想在線程里干什么，就在run()里寫什么，在這里的實(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)程空間，說白了就把自己換成別人。

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("沒有名字") ); 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() 必須從主線程(執(zhí)行 main() 方法的線程)調(diào)用， 不從 QThread 調(diào)用。 在GUI應(yīng)用程序，主線程也被稱為GUI線程，因?yàn)樗俏ㄒ辉试S執(zhí)行GUI相關(guān)操作的線程。

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

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

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