个人主页网站模板,wordpress幻灯,哪些网站适合瀑布流,驾校做网站一、设计要求
用QT做一个聊天室#xff0c;
制作一个服务器和客户端。可以进行注册、登录#xff0c;
登陆成功后可以使用昵称进行发送、接收消息。
能根据昵称、聊天内容查询历史记录#xff0c;也可以查询全部聊天记录。
。
二、客户端三级ui界面 三、项目代码
//在…一、设计要求
用QT做一个聊天室
制作一个服务器和客户端。可以进行注册、登录
登陆成功后可以使用昵称进行发送、接收消息。
能根据昵称、聊天内容查询历史记录也可以查询全部聊天记录。
。
二、客户端三级ui界面 三、项目代码
//在pro文件里加入
QT core gui network
RC_FILE icon_config.rc
//客户端dialog.h
#ifndef DIALOG_H
#define DIALOG_H#include QtWidgets
#include QDebug
// 网络连接类
#include QTcpSocket
// 文本流
#include QTextStream
#include QDateTime
#include QByteArraynamespace Ui {
class Dialog;
}class Dialog : public QDialog
{Q_OBJECTpublic:explicit Dialog(QWidget *parent 0);~Dialog();private:Ui::Dialog *ui;QTcpSocket *client;void printMsg(QString); // 输出内容到公屏void succRight();private slots:void btnConnClickedSlot(); // 连接按钮void btnSendClickedSlot(); // 发送按钮void connectedSlot(); // 连接成功的槽函数void disconnectedSlot(); // 断开连接的槽函数void readReadSlot(); // 接收数据的槽函数void btnHisClickedSlot();//历史记录void btnHisNameClickedSlot();//按照昵称void btnHisNeiClickedSlot();//按照内容void btnLoginClickedSlot();//登录/切换窗口void btnRegClickedSlot();//注册};#endif // DIALOG_H//客户端dialog.c
#include dialog.h
#include ui_dialog.hDialog::Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::Dialog)
{ui-setupUi(this);// 抢前台setWindowFlags(Qt::WindowStaysOnTopHint);connect(ui-pushButtonConn,SIGNAL(clicked()),this,SLOT(btnConnClickedSlot()));connect(ui-pushButtonSend,SIGNAL(clicked()),this,SLOT(btnSendClickedSlot()));client new QTcpSocket(this);// 建立网络连接检测的信号槽connect(client,SIGNAL(connected()),this,SLOT(connectedSlot()));connect(client,SIGNAL(disconnected()),this,SLOT(disconnectedSlot()));// 接收消息的信号槽connect(client,SIGNAL(readyRead()),this,SLOT(readReadSlot()));
//历史connect(ui-pushButtonHis,SIGNAL(clicked()),this,SLOT(btnHisClickedSlot()));connect(ui-pushButtonName,SIGNAL(clicked()),this,SLOT(btnHisNameClickedSlot()));connect(ui-pushButtonNei,SIGNAL(clicked()),this,SLOT(btnHisNeiClickedSlot()));//切换窗口登录connect(ui-pushButtonLo,SIGNAL(clicked()),this,SLOT(btnLoginClickedSlot()));//注册connect(ui-pushButtonReg,SIGNAL(clicked()),this,SLOT(btnRegClickedSlot()));}Dialog::~Dialog()
{disconnect(client,SIGNAL(disconnected()),this,SLOT(disconnectedSlot()));// 如果还在连接if(client-isOpen())client-close();delete ui;
}void Dialog::btnConnClickedSlot()
{// 发起连接请求// 默认用户输入的参数都对client-connectToHost(ui-lineEditIp-text(),ui-spinBox-value());
}void Dialog::printMsg(QString msg)
{// 获得当前时间QString time QDateTime::currentDateTime().toString(yyyy-MM-dd-hh:mm:ss);ui-textBrowser-append(time);ui-textBrowser-append(msg);ui-textBrowser-append();
}void Dialog::succRight()
{ui-stackedWidget-setCurrentIndex(1);
}void Dialog::btnSendClickedSlot()
{// 获得昵称和消息内容QString user ui-lineEditUser-text();if(user){QMessageBox::warning(this,提示,请输入昵称);return;}QString msg ui-lineEditMsg-text();if(msg ){QMessageBox::warning(this,提示,请输入要发送的消息);return;}QString time QDateTime::currentDateTime().toString(yyyy-MM-dd-hh-mm-ss);// 创建文本流对象QTextStream output(client);// 连续输出发送output time:user : msg;// 清空消息输入框ui-lineEditMsg-clear();// 公屏显示msg userQString((本机):)msg;printMsg(msg);
}void Dialog::connectedSlot()
{// 屏蔽连接按钮开启发送按钮ui-pushButtonConn-setEnabled(false);ui-pushButtonConn-setText(已连接);ui-pushButtonSend-setEnabled(true);ui-stackedWidget-setCurrentIndex(1);
}void Dialog::readReadSlot()
{QTextStream input(client);QString text input.readAll();QString text1input.readLine(100);qDebug() text1;QStringList list text.split(:);QStringList list2 text1.split(:);qDebug()分割后数量list.size();qDebug() list2.size();if(list.size()4){if(textdlchengg){qDebug() text;ui-stackedWidget-setCurrentIndex(2);ui-textBrowser-clear();}
// else if(list.size()3)
// {// ui-textBrowser_2-append(text);
// return;
// }else{printMsg(text);}}else if(list.size()4){ui-textBrowser_2-append(text);return;}
}void Dialog::btnHisClickedSlot()
{ui-textBrowser_2-clear();QString user ui-lineEditUser-text();if(user){QMessageBox::warning(this,提示,请输入昵称);return;}QString time QDateTime::currentDateTime().toString(yyyy-MM-dd-hh-mm-ss);// 创建文本流对象QTextStream output(client);QString mm历史记录;output time:user : mm ;
}void Dialog::btnHisNameClickedSlot()
{ui-textBrowser_2-clear();QString user ui-lineEditUser-text();QString time hh;// 创建文本流对象QTextStream output(client);QString mm按照昵称;output time:user : mm ;
}void Dialog::btnHisNeiClickedSlot()
{ui-textBrowser_2-clear();QString user sjdhs;QString time 按照内容;// 创建文本流对象QString msg ui-lineEditMsg-text();if(msg ){QMessageBox::warning(this,提示,请输入要发送的消息);return;}QTextStream output(client);output time:user : msg ;
}void Dialog::btnLoginClickedSlot()
{QString user ui-lineEditUs-text();if(user){QMessageBox::warning(this,提示,请输入昵称);return;}QString pwd ui-lineEdit_2Pwd-text();if(pwd ){QMessageBox::warning(this,提示,请输入密码);return;}// 创建文本流对象QTextStream output(client);// 连续输出发送QString maghha;QString haflele;output user : pwd:mag:haf;}void Dialog::btnRegClickedSlot()
{QString user ui-lineEditUs-text();if(user){QMessageBox::warning(this,提示,请输入昵称);return;}QString pwd ui-lineEdit_2Pwd-text();if(pwd ){QMessageBox::warning(this,提示,请输入密码);return;}// 创建文本流对象QTextStream output(client);// 连续输出发送output user : pwd;
}void Dialog::disconnectedSlot()
{// 开启连接按钮屏蔽发送按钮ui-pushButtonConn-setEnabled(true);ui-pushButtonConn-setText(连接);ui-pushButtonSend-setEnabled(false);// 弹窗printMsg(连接已断开);QMessageBox::warning(this,提示,连接已断开);ui-stackedWidget-setCurrentIndex(0);
}//服务器dialog.h
#ifndef DIALOG_H
#define DIALOG_H#include QtWidgets
#include QDebug
// 连接管理类
#include QTcpServer
#include QDateTime
// 连接类
#include QTcpSocket
// 文本流
#include QTextStream#include QButtonGroup
#include QSqlDatabase
#include QDebug
#include QSqlError
#include QMessageBox
#include QSqlQuery
#include QByteArraynamespace Ui {
class Dialog;
}class Dialog : public QDialog
{Q_OBJECTpublic:explicit Dialog(QWidget *parent 0);~Dialog();private:Ui::Dialog *ui;QTcpServer* server; // 管理对象母鸡void printMsg(QString); // 输出内容到公屏QTcpSocket* socket NULL; // 连接对象绿蛋QListQTcpSocket* sockets;QListQString ips;QSqlDatabase db;void connect2DB(); // 连接到数据库1void createTable();// 建表void createTable2();void insertData(); // 插入数据void selectAll(int); // 数据全查void selectLOgin(QString,QString,int);void selectName(QString,int);void selectNei(QString,int);private slots:// 新连接来了的槽函数void newConnSlot();// 连接掉线的信号槽void disconnetedSlot();// 有数据可读时的槽函数void readyReadSlot();};#endif // DIALOG_H//服务器dialog.c
#include dialog.h
#include ui_dialog.hDialog::Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::Dialog)
{ui-setupUi(this);// 抢前台setWindowFlags(Qt::WindowStaysOnTopHint);server new QTcpServer(this);// 连接新连接来了的信号槽connect(server,SIGNAL(newConnection()),this,SLOT(newConnSlot()));// 开启监听服务server-listen(QHostAddress::Any,8887);connect2DB();
}Dialog::~Dialog()
{if(server-isListening()) // 如果还在监听server-close();delete ui;
}void Dialog::printMsg(QString msg)
{// 获得当前时间QString time QDateTime::currentDateTime().toString(yyyy-MM-dd hh:mm:ss);ui-textBrowser-append(time);ui-textBrowser-append(msg);ui-textBrowser-append();
}void Dialog::connect2DB()
{// 创建连接对象db QSqlDatabase::addDatabase(QSQLITE);// 设置数据库的文件名称db.setDatabaseName(book_management.db);// 打开数据库if(db.open()){qDebug() 连接成功;// createTable();// createTable2();}else{// 获得错误信息封装类QSqlError info db.lastError();// 提取错误文本QString text info.text();// 展示错误QMessageBox::critical(this,错误,text);}}void Dialog::createTable()
{QString sql CREATE TABLE book(time TEXT PRIMARY KEY,name TEXT,msg TEXT);;// 创建数据库操作类对象QSqlQuery sq;if(sq.exec(sql)){qDebug() 建表成功;}else// 失败{// 获得错误信息封装类QSqlError info sq.lastError();// 提取错误文本QString text info.text();// 展示错误qDebug() text;}}void Dialog::createTable2()
{QString sql2 CREATE TABLE class(name TEXT PRIMARY KEY,pwd TEXT);;// 创建数据库操作类对象QSqlQuery sq;if(sq.exec(sql2)){qDebug() 建表2成功;}else// 失败{// 获得错误信息封装类QSqlError info sq.lastError();// 提取错误文本QString text info.text();// 展示错误qDebug() text;}
}void Dialog::selectAll(int i)
{QString sql SELECT * FROM book;QSqlQuery sq;sq.prepare(sql);if(sq.exec(sql)){// 清空上次显示// ui-textBrowser-clear();while(sq.next())// 循环取出{// 取出一条数据库中的字段QString time sq.value(0).toString();QString name sq.value(1).toString();QString msg sq.value(2).toString();QString msa历史;// 拼接并显示QString text msa.append(:) time.append(:) name.append(:) msg;QTextStream output(sockets.at(i));output textendl;}}}void Dialog::selectLOgin(QString user, QString pwd2,int i)
{QString nameuser;QString pwdpwd2;QString sql SELECT * FROM class WHERE name LIKE ? AND pwd LIKE ?;;QSqlQuery sq;sq.prepare(sql);if(sq.exec(sql)){while(sq.next()){qDebug() yes;QString user sq.value(0).toString();QString pwd sq.value(1).toString();QString text dlchengg;QTextStream output(sockets.at(i));outputtext;}}else{QSqlError info sq.lastError();// 提取错误文本QString text info.text();text.prepend(登录失败);QMessageBox::warning(this,警告,text);}
}void Dialog::selectName(QString name1,int i)
{QString namename1;QString sql SELECT * FROM book WHERE name LIKE ?;QSqlQuery sq;sq.prepare(sql);sq.addBindValue(name);if(sq.exec()){while(sq.next())// 循环取出{// 取出一条数据库中的字段QString time sq.value(0).toString();QString name sq.value(1).toString();QString msg sq.value(2).toString();QString msa历史;// 拼接并显示QString text msa.append(:)time.append(:) name.append(:) msg;QTextStream output(sockets.at(i));output textendl;}}
}void Dialog::selectNei(QString msg, int i)
{QString sql SELECT * FROM book WHERE msg LIKE ?;QSqlQuery sq;sq.prepare(sql);sq.addBindValue(msg.prepend(%).append(%));if(sq.exec()){while(sq.next())// 循环取出{// 取出一条数据库中的字段QString time sq.value(0).toString();QString name sq.value(1).toString();QString msg sq.value(2).toString();QString msa历史;// 拼接并显示QString text msa.append(:)time.append(:) name.append(:) msg;QTextStream output(sockets.at(i));output textendl;}}
}void Dialog::newConnSlot()
{// 获得服务器端的连接类对象socket server-nextPendingConnection();QTextStream output(socket);// 如果满员则踢出if(sockets.size() 20){qDebug() 聊天室满员;output QString(聊天室已达人数上限连接失败);socket-close();return;}sockets.append(socket);// 绿蛋收到消息的信号槽connect(socket,SIGNAL(readyRead()),this,SLOT(readyReadSlot()));// 绿蛋掉线的信号槽connect(socket,SIGNAL(disconnected()),this,SLOT(disconnetedSlot()));// 给客户端打个招呼output QString(服务器你好啊);// 获得对面的IP地址和端口号QString ip socket-peerAddress().toString();quint16 port socket-peerPort();QString portText QString::number(port);QString text 新连接来了;text.append(ip).append(:).append(portText);printMsg(text);
}void Dialog::disconnetedSlot()
{// 拿到发射者socket (QTcpSocket*)sender();for(int i 0;isockets.size();i){if(socket sockets.at(i)){qDebug() 第 i 个客户端掉线了;// 获得对面的IP地址和端口号QString ip sockets.at(i)-peerAddress().toString();quint16 port sockets.at(i)-peerPort();QString portText QString::number(port);QString text 连接已断开;text.append(ip).append(:).append(portText);printMsg(text);sockets.removeAt(i);}}
}//接收数据
void Dialog::readyReadSlot()
{for(int i0;isockets.size();i){if(sockets.at(i)-isReadable() sockets.at(i)-bytesAvailable()0){qDebug() 第 i 个客户端发的消息;QTextStream input(sockets.at(i));// 一口气都读了QString text input.readAll();//写入数据库QStringList list text.split(:);qDebug()分割后数量list.size();if(list.size()3){QString time list[0];QString name list[1];QString msg list[2];if(list[2]历史记录){selectAll( i);}else if(list[2]按照昵称){selectName(name,i);}else if(list[0]按照内容){selectNei(msg,i);}else{createTable();QString sql INSERT INTO book VALUES(?,?,?);;QSqlQuery sq;sq.prepare(sql);sq.addBindValue(time);sq.addBindValue(name);sq.addBindValue(msg);if(sq.exec()){qDebug()数据插入成功;// QMessageBox::information(this,通知,数据插入成功);}else{// 获得错误信息封装类QSqlError info sq.lastError();// 提取错误文本QString text info.text();// 展示错误text.prepend(数据插入失败);QMessageBox::warning(this,警告,text);}printMsg(text);for(int m0;msockets.size();m){if(mi)continue;QTextStream output(sockets.at(m));output text;}}}else if(list.size()2){createTable2();QString name list[0];QString pwd list[1];QString sql INSERT INTO class VALUES(?,?);;QSqlQuery sq;sq.prepare(sql);sq.addBindValue(name);sq.addBindValue(pwd);if(sq.exec()){qDebug()注册成功;// QMessageBox::information(this,通知,数据插入成功);}else{// 获得错误信息封装类QSqlError info sq.lastError();// 提取错误文本QString text info.text();// 展示错误text.prepend(注册失败);QMessageBox::warning(this,警告,text);}printMsg(text);for(int m0;msockets.size();m){if(mi)continue;QTextStream output(sockets.at(m));output text;}}else if(list.size()4){QString name list[0];QString pwd list[1];qDebug() namepwd;QString sql SELECT * FROM class WHERE name? AND pwd?;QSqlQuery sq;sq.prepare(sql);sq.addBindValue(name);sq.addBindValue(pwd);qDebug() yes;if(sq.exec()){// 取出一条数据库中的字段while(sq.next()){QString name sq.value(0).toString();QString pwd sq.value(1).toString();qDebug() namepwd;qDebug() yes;QString text dlchengg;QTextStream output(sockets.at(i));outputtext;}}else{QSqlError info sq.lastError();// 提取错误文本QString text info.text();text.prepend(登录失败);QMessageBox::warning(this,警告,text);}}}}}
四、项目结果
