基于Qt开发的IM即时通讯软件

#include "client.h" #include "ui_client.h" Client::Client(QString qq, QString nickName, QString ipv4) : ui(new Ui::Client) { QTextCodec::setCodecForTr(QTextCodec::codecForName("GBK")); ui->setupUi(this); this->setWindowTitle(tr("来聊")); ui->nameLabel->setText(nickName+"("+qq+")"); ui->comboBox->setCurrentIndex(0); ui->toolButton_tx->setIcon(QIcon(":/icons/icon/icq_online.jpg")); firm_list.clear(); id_list.clear(); chat_list.clear(); this->nickName = nickName; this->ipv4 = ipv4; this->qq = qq; f_qq=""; f_name=""; search = new Search(ipv4, qq, nickName); //网络服务器设定 tcpPort = 60001; udpPort = 44444; //address = QHostAddress::LocalHost; address=DOMAIN; clientSocket = new QTcpSocket(this); serverSocket = new QTcpSocket(this); udpSocket = new QUdpSocket(this); udpSocket->bind(udpPort, QUdpSocket::ShareAddress | QUdpSocket::ReuseAddressHint); server = new QTcpServer(this); server->listen(QHostAddress::Any, 54545); nextBlockSize = 0; clientSocket->abort(); clientSocket->connectToHost(address, tcpPort); //把自己添加为好友，防止自己添加自己 addNewFriendToList(ipv4, qq, nickName); ////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////// //定时器 connect(this, SIGNAL(toQuit()), this, SLOT(sendOffLineSlot())); connect(ui->searchBtn, SIGNAL(clicked()), this, SLOT(searchFormSlot())); //信号和槽 connect(server, SIGNAL(newConnection()), this, SLOT(newConnectionSlot())); connect(ui->treeWidget, SIGNAL(itemDoubleClicked(QTreeWidgetItem*, int)), this, SLOT(showChatForm(QTreeWidgetItem*, int))); //connect(ui->treeWidget,SIGNAL(customContextMenuRequested(QPoint)),this,SLOT(showMenu())); connect(udpSocket, SIGNAL(readyRead()), this, SLOT(readMessageSlot())); connect(clientSocket, SIGNAL(connected()), this, SLOT(timerToCheckConnection())); } Client::~Client() { delete ui; } void Client::closeEvent(QCloseEvent *event) { qDebug()<<"I have closed"; emit toQuit(); sendOffLineSlot(); event->accept(); qApp->quit(); } //心跳去测试是否还连接 void Client::timerToCheckConnection() { timer = new QTimer(); timer->start(3 * 1000); timerID = timer->timerId(); connect(timer, SIGNAL(timeout()), this, SLOT(checkConnectionStateSLot())); } void Client::newConnectionSlot() { serverSocket = server->nextPendingConnection(); connect(serverSocket, SIGNAL(readyRead()), this, SLOT(readTCPMessageSlot())); } void Client::readTCPMessageSlot() { nextBlockSize=0; QTextCodec::setCodecForTr(QTextCodec::codecForName("GBK")); QDataStream in(serverSocket); in.setVersion(QDataStream::Qt_4_8); if (nextBlockSize == 0) { if (serverSocket->bytesAvailable() < sizeof(quint16)) return; in >> nextBlockSize; } if (serverSocket->bytesAvailable() < nextBlockSize) return; quint8 type; in >> type; qDebug() << "tcp type = " << type; ////////////////////////////ZHELI /////////////////////////// // QByteArray block; // QDataStream out(&block, QIODevice::WriteOnly); // out.setVersion(QDataStream::Qt_4_8); // out << quint16(0) << quint8(ADD_FRIEND) << nickName << qq << ipv4; // out.device()->seek(0); // out << quint16(block.size() - sizeof(quint16)); // clientSocket->write(block); ///////////////////////////////////////////////////////////////////// QSound sys("../sound/system.wav"); switch (type) { case ADD_REQUEST: sys.play(); in >> ip_s >> qq_s >> nickname_s; if (QMessageBox::Yes == QMessageBox::question(this, tr("添加好友提醒"), tr("%1 想和你成为好友，您是否接受?").arg(ip_s), QMessageBox::Yes | QMessageBox::No, QMessageBox::Yes)) { sendAddResult(quint8(AGREED)); //添加好友 addNewFriendToList(ip_s, qq_s, nickname_s); } else { sendAddResult(quint8(DENIED)); } break; default: break; } } void Client::readMessageSlot() { QByteArray datagram; do { datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); } while (udpSocket->hasPendingDatagrams()); QDataStream in(&datagram, QIODevice::ReadOnly); in.setVersion(QDataStream::Qt_4_8); int type; QString qq_in, name_in, message; QString qq_to, name_to; in >> type; QSound msg("../sound/msg.wav"); QSound nudge("../sound/shake.wav"); switch (type) { case Message: msg.play(); in >> qq_in >> name_in >> qq_to >> name_to >> message; openRelevantChatForm(name_in, qq_in, message); break; case Nudge: nudge.play(); in >> qq_in >> name_in; nudgeRelevantChatForm(name_in, qq_in); break; default: break; } } //打开聊天窗口 void Client::openRelevantChatForm(QString name_sender, QString qq_sender, QString mes) { bool nflag = false; int n = ui->treeWidget->topLevelItemCount(); for (int i = 0; i < id_list.size(); i++) { if (id_list.at(i) == qq_sender){ nflag = true; break; } } if (nflag == true){ for (int i = 0; i < n; i++) { if (firm_list.at(i) == qq_sender) { chat_list.at(i)->messagefirmSlot(qq_sender, mes, name_sender); } } } else { id_list << qq_sender; for (int i = 0; i < n; i++) { if (firm_list.at(i) == qq_sender) { chat_list.at(i)->show(); chat_list.at(i)->messagefirmSlot(qq_sender, mes, name_sender); connect(chat_list.at(i), SIGNAL(closebutton(QString)), this, SLOT(outputlist(QString))); } } } } //震动窗口 void Client::nudgeRelevantChatForm(QString name_sender, QString qq_sender) { bool nflag = false; int n = ui->treeWidget->topLevelItemCount(); for (int i = 0; i < id_list.size(); i++) { if (id_list.at(i) == qq_sender){ nflag = true; break; } } if (nflag == true){ for (int i = 0; i < n; i++) { if (firm_list.at(i) == qq_sender) { chat_list.at(i)->getWindowAnimation(name_sender); } } } else { id_list << qq_sender; for (int i = 0; i < n; i++) { if (firm_list.at(i) == qq_sender) { chat_list.at(i)->show(); chat_list.at(i)->getWindowAnimation(name_sender); connect(chat_list.at(i), SIGNAL(closebutton(QString)), this, SLOT(outputlist(QString))); } } } } //发送添加信息 void Client::sendAddResult(quint8 res) { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_8); out << quint16(0) << res << ipv4 << qq << nickName; out.device()->seek(0); out << quint16(block.size() - sizeof(quint16)); serverSocket->write(block); } //发送用户上线后的状态信息 void Client::sendOnlineSlot() { QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out.setVersion(QDataStream::Qt_4_8); out << quint16(0) << quint8(LOG_IN) << nickName << qq << ipv4; out.device()->seek(0); out << quint16(block.size() - sizeof(quint16)); clientSocket->write(block); ui->toolButton_tx->setIcon(QIcon(":/icons/icon/icq_online.jpg")); } //发送用户下线后的状态信息 void Client::sen