1. 服务端
词典数据,数据库路径:E:\peixunQianrushi\Qt\course\course10\cidain_shuju
cidian_server
widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QDebug>
#include <QTcpServer>
#include <QTcpSocket>
#include <thread_tcp.h>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots://当有新的客户端连接时的槽void new_conn_arrive();private:Ui::Widget *ui;//实例化tcp对象QTcpServer* server;//存储的socket就是与客户端的通信套接字QTcpSocket* socket1;//存储所有的通信套接字QList<QTcpSocket*> list;
};
#endif // WIDGET_H
widget.cpp
主线程页面主要涉及tcp搭建接收客户点的请求连接,并且来一个客户端就开辟一个新的线程
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//1.创建tcp服务端套接字server = new QTcpServer;//2.绑定和监听server->listen(QHostAddress("192.168.199.211"),8082);qDebug()<<"服务器启动成功~~~~";//当有新的客户端连接时,就会触发该信号connect(server,SIGNAL(newConnection()),this,SLOT(new_conn_arrive()));}Widget::~Widget()
{delete ui;
}//有新的客户端请求连接时
void Widget::new_conn_arrive(){//3. 建立连接socket1 = server->nextPendingConnection();qDebug()<<"通信套接字连接成功~~~~";list.append(socket1);//至此开启线程分别处理不同的业务//创建线程thread_tcp* tcp = new thread_tcp;//把通信套接字给线程tcp->socket = socket1;//当客户端发来消息,就会触发 在线程中的 写的槽函数connect(tcp->socket,SIGNAL(readyRead()),tcp,SLOT(readdata()));//客户端断开连接,触发信号调用 线程中的槽,使线程关闭connect(tcp->socket,SIGNAL(disconnected()),tcp,SLOT(dis_conn()));//启动线程tcp->start();
}
thread_tcp.h
线程类
#ifndef THREAD_TCP_H
#define THREAD_TCP_H#include <QThread>
#include <QDebug>
#include <QTcpSocket>
#include <QSqlDatabase>
#include <QFileDialog>
#include <QSqlQuery>
#include <QInputDialog>
#include <QFile>class thread_tcp : public QThread
{Q_OBJECT
public:explicit thread_tcp(QObject *parent = nullptr);//socket就是与客户端的通信套接字QTcpSocket* socket;//执行线程的runvoid run();//登录操作void login(QStringList arr);//注册操作void my_register(QStringList arr);//查询单词void select_word(QStringList arr);//历史记录void sel_histroy(QStringList arr);//收藏单词void store(QStringList arr);//查看收藏记录void look_collect(QStringList arr);//删除收藏void del_store(QStringList arr);public slots://当客户端发来消息的槽,登录void readdata();//只要客户端断开,就关闭线程void dis_conn();private://创建数据库对象QSqlDatabase db;//存储登陆人的名字QString user_name;};#endif // THREAD_TCP_H
thread_tcp.cpp
线程类的实现,接收客户端发来的数据,具体的功能为客户端提供数据,连接数据库
主要是根据客户端发来的不同的业务需求去调用相应的功能,然后给客户端返回相应的数据
#include "thread_tcp.h"thread_tcp::thread_tcp(QObject *parent): QThread{parent}
{//添加一个数据库,获取数据库对象去连接sqlite数据库,返回一个数据库连接对象db = QSqlDatabase::addDatabase("QSQLITE");//打开一个数据库db.setDatabaseName("E:/peixunQianrushi/Qt/course/course10/cidain_shuju/word.db");if(db.open()){qDebug()<<"数据库打开成功";}}//登录操作
void thread_tcp::login(QStringList arr){//登录qDebug()<<"账号"<<arr[1]<<"密码"<<arr[2];//指定操作的数据库QSqlQuery query(db);//编写sqlQString sql = "select * from user";//执行query.exec(sql);while(query.next()){//取出名字QString name = query.value("name").toString();QString psw = query.value("password").toString();//对账号进行校验if(name == arr[1]){//账号正确//校验密码if(psw == arr[2]){qDebug()<<"账号密码正确";//返回标志位和成功码QString success = "0";QString retu = QString::number(1)+" "+success;socket->write(retu.toStdString().c_str());//只有登录成功才存储登陆人的名字user_name = name;qDebug()<<"登陆人的姓名:"<<user_name;return;}}}//至此账号密码绝对是错误的qDebug()<<"密码错误";//返回标志位和错误码QString err = "-1";QString retu = QString::number(1)+" "+err;socket->write(retu.toStdString().c_str());
}//注册操作
void thread_tcp::my_register(QStringList arr){//注册qDebug()<<"账号"<<arr[1]<<"密码"<<arr[2];//指定操作的数据库QSqlQuery query(db);//编写sqlQString sql = "select * from user";//执行query.exec(sql);while(query.next()){//取出名字QString name = query.value("name").toString();QString psw = query.value("password").toString();//对账号进行校验if(name == arr[1]){//账号相同//返回标志位和错误码QString err = "-1";QString retu = QString::number(2)+" "+err;socket->write(retu.toStdString().c_str());return;}}//至此到这账号不相同//插入数据库sql = "insert into user values('%0','%1')";//给通配符赋值sql = sql.arg(arr[1]).arg(arr[2]);qDebug()<<sql;query.exec(sql);//返回标志位和成功码QString success = "0";QString retu = QString::number(2)+" "+success;socket->write(retu.toStdString().c_str());}//查询单词
void thread_tcp::select_word(QStringList arr){//要查询的单词qDebug()<<arr[1];//直接操作文件//实例化QFile对象,可以通过这个对象执行文件的读写操作。QFile file("E:/peixunQianrushi/Qt/course/course10/cidain_shuju/dict.txt");if(file.open(QIODevice::ReadOnly|QIODevice::Text)){//QIODevice::Text 以文本的形式打开while (!file.atEnd()) {//atEnd()如果到达文件的末尾,返回true;否则返回falseQByteArray line = file.readLine();//一次读取一行//把line拷贝到msgchar msg[1024];memset(msg,0,sizeof(msg));strcpy(msg,line.toStdString().c_str());//据观察前17个字符是单词 后面是解释 取出前17个字符char dest[25];//存储读出来的单词memset(dest,0,sizeof(dest));//清0//sscanf 会从输入字符串 input 中找到第一个非空白字符,然后开始提取字符,直到再次遇到空白字符为止。sscanf(line,"%s",dest);//找到了要查询单词if(arr[1] == dest){//截取单词意思char buf[1024];memset(buf,0,sizeof(buf));strcpy(buf,&msg[17]);//从第18个字节开始一直到最后,就是单词的解释//返回标志位和成功码QString success = "0";QString retu = QString::number(3)+" "+success+" "+buf;qDebug()<<retu;socket->write(retu.toStdString().c_str());//只有找到了查询的单词,才往数据库中插入记录//指定操作的数据库QSqlQuery query(db);//插入数据库QString sql = "insert into histroy values('%0','%1')";//给通配符赋值sql = sql.arg(user_name).arg(arr[1]);qDebug()<<sql;query.exec(sql);return;}}//到这就是没找到//返回标志位和错误码QString err = "-1";QString retu = QString::number(3)+" "+err;socket->write(retu.toStdString().c_str());file.close();}}//历史记录
void thread_tcp::sel_histroy(QStringList arr){//指定操作的数据库QSqlQuery query(db);//插入数据库QString sql = "select distinct word from histroy where name = '%0'";sql = sql.arg(user_name);qDebug()<<sql;query.exec(sql);QString send_word;while(query.next()){//取出单词QString word = query.value("word").toString();//拼接字符串send_word.append(" ");send_word.append(word);}if(query.size()==0){//没有查询到数据qDebug()<<"2222222222222222222222222222";//返回标志位和错误码QString err = "-1";QString retu = QString::number(4)+" "+err;socket->write(retu.toStdString().c_str());}else{//返回标志位和成功码qDebug()<<"5555555555555555555555555";QString success = "0";QString retu = QString::number(4)+" "+success+send_word;qDebug()<<retu;socket->write(retu.toStdString().c_str());}}//收藏单词
void thread_tcp::store(QStringList arr){//指定操作的数据库QSqlQuery query(db);//插入数据库QString sql = "insert into collect values('%0','%1')";//给通配符赋值sql = sql.arg(user_name).arg(arr[1]);qDebug()<<sql;bool ok = query.exec(sql);//如果sql执行成功if(ok){//返回标志位和成功码QString success = "0";QString retu = QString::number(5)+" "+success;qDebug()<<retu;socket->write(retu.toStdString().c_str());qDebug()<<"收藏成功~~~~~~~~~~~~~~~~~~~~~~";}else{//返回标志位和错误码QString err = "-1";QString retu = QString::number(5)+" "+err;socket->write(retu.toStdString().c_str());}}//查看收藏
void thread_tcp::look_collect(QStringList arr){//指定操作的数据库QSqlQuery query(db);//插入数据库QString sql = "select distinct word from collect where name = '%0'";//给通配符赋值sql = sql.arg(user_name);qDebug()<<sql;query.exec(sql);QString send_word;while(query.next()){//取出单词QString word = query.value("word").toString();//拼接字符串send_word.append(" ");send_word.append(word);}if(query.size()==0){//没有查询到数据qDebug()<<"111111111111111111111";//返回标志位和错误码QString err = "-1";QString retu = QString::number(6)+" "+err;socket->write(retu.toStdString().c_str());}else{qDebug()<<"333333333333333333333333333333";//返回标志位和成功码QString success = "0";QString retu = QString::number(6)+" "+success+send_word;qDebug()<<retu;socket->write(retu.toStdString().c_str());}
}//删除收藏
void thread_tcp::del_store(QStringList arr){QSqlQuery query(db);QString sql = "delete from collect where word = '%0' and name = '%1'";sql = sql.arg(arr[1]).arg(user_name);qDebug()<<sql;bool ok = query.exec(sql);//如果sql执行成功if(ok){//返回标志位和成功码QString success = "0";QString retu = QString::number(7)+" "+success;qDebug()<<retu;socket->write(retu.toStdString().c_str());qDebug()<<"删除成功~~~~~~~~~~~~~~~~~~~~~~";}else{//返回标志位和错误码QString err = "-1";QString retu = QString::number(7)+" "+err;socket->write(retu.toStdString().c_str());}}//当客户端发来消息的就会进入这个槽
void thread_tcp::readdata(){//首先接收标志位QByteArray data = socket->readAll();qDebug()<<data;QString str = QString::fromUtf8(data);//先转位QString类型QStringList arr = str.split(" ");//以空格分割字符串int flag = arr[0].toInt();//在转为intqDebug()<<flag;switch(flag){case 1://登录login(arr);break;case 2://注册my_register(arr);break;case 3://查询单词select_word(arr);break;case 4://历史记录sel_histroy(arr);break;case 5://收藏单词store(arr);break;case 6://查看收藏记录look_collect(arr);break;case 7://删除收藏del_store(arr);break;}}//一直执行线程
void thread_tcp::run(){qDebug()<<"线程执行";//阻塞执行exec();
}//客户端断开连接时,关闭线程
void thread_tcp::dis_conn(){qDebug()<<"线程关闭";exit(0);
}
2. 客户端
登录界面
电子词典界面
cidian_client
widget.h
客户端主界面
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpSocket>
#include <QHostAddress>
#include <cidian_dialog.h>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();//登录后续处理void login(QStringList arr);//注册后续处理void my_register(QStringList arr);private slots:void on_pushButton_login_clicked();void on_pushButton_register_clicked();//当连接服务器,且连接成功的槽void socket_conn();//当有数据发来时void readdata();private:Ui::Widget *ui;//创建tcp对象QTcpSocket* socket;CiDian_Dialog* cidian = new CiDian_Dialog();//开启词典界面};
#endif // WIDGET_H
widget.cpp
实现类,主要是向服务端发起tcp请求连接,并且接收服务端返回的数据,涉及登录注册服务,调用电子词典主界面
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//1.创建套接字对象socket = new QTcpSocket;//2.连接服务器,参数1服务端ip,参数2服务端端口QString port = "8082";socket->connectToHost(QHostAddress("192.168.199.211"),port.toUShort());//toUShort() 字符串转为数字//当连接服务器,且连接成功,就会触发该信号connect(socket,SIGNAL(connected()),this,SLOT(socket_conn()));//当有数据发来时,触发该信号connect(socket,SIGNAL(readyRead()),this,SLOT(readdata()));
}Widget::~Widget()
{delete ui;}//当连接服务器,且连接成功,触发的信号对应的槽
void Widget::socket_conn(){qDebug()<<"连接成功";}//登录
void Widget::on_pushButton_login_clicked()
{//获取账号和密码QString name = ui->lineEdit_name->text();QString password = ui->lineEdit_password->text();//把数据发送给服务端//发送标志位 账号 密码QString send_message = QString::number(1)+" "+name+" "+password;socket->write(send_message.toStdString().c_str());}
//登录后续处理
void Widget::login(QStringList arr){if(arr[1]=="0"){//登录成功qDebug()<<"登录成功*********";//开启新的界面cidian->socket1 = socket;//把套接字给词典界面this->close();//关闭当前界面//查询历史记录cidian->history();cidian->show();}else if(arr[1]=="-1"){qDebug()<<"登录失败*********";}
}//注册
void Widget::on_pushButton_register_clicked()
{//获取账号和密码QString name = ui->lineEdit_name->text();QString password = ui->lineEdit_password->text();//把数据发送给服务端//发送标志位 账号 密码QString send_message = QString::number(2)+" "+name+" "+password;socket->write(send_message.toStdString().c_str());
}
//注册后续处理
void Widget::my_register(QStringList arr){if(arr[1]=="0"){//注册成功qDebug()<<"注册成功*********";ui->label_zhuce->setText("注册成功");}else if(arr[1]=="-1"){qDebug()<<"用户名相同*********";ui->label_zhuce->setText("用户名相同");}
}//当有数据发来时,接收数据
void Widget::readdata(){//5.读取处理数据QByteArray rece_data = socket->readAll();QString str = QString::fromUtf8(rece_data);//先转位QString类型QStringList arr = str.split(" ");//以空格分割字符串int flag = arr[0].toInt();//在转为int//这里的匹配是在接收完成以后,对各个功能接收到返回值后的处理switch(flag){case 1://登录后续处理login(arr);break;case 2://注册后续处理my_register(arr);break;case 3://查询单词后续处理cidian->select_word(rece_data);break;case 4://查询历史后续处理cidian->sel_histroy(arr);break;case 5://收藏后续处理cidian->shoucang(arr);break;case 6://查看收藏后续处理cidian->look_store(arr);break;case 7://删除收藏后续处理cidian->del_store_word(arr);break;}}
widget.cpp
实现类,主要是向服务端发起tcp请求连接,并且接收服务端返回的数据,涉及登录注册服务,调用电子词典主界面
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//1.创建套接字对象socket = new QTcpSocket;//2.连接服务器,参数1服务端ip,参数2服务端端口QString port = "8082";socket->connectToHost(QHostAddress("192.168.199.211"),port.toUShort());//toUShort() 字符串转为数字//当连接服务器,且连接成功,就会触发该信号connect(socket,SIGNAL(connected()),this,SLOT(socket_conn()));//当有数据发来时,触发该信号connect(socket,SIGNAL(readyRead()),this,SLOT(readdata()));
}Widget::~Widget()
{delete ui;}//当连接服务器,且连接成功,触发的信号对应的槽
void Widget::socket_conn(){qDebug()<<"连接成功";}//登录
void Widget::on_pushButton_login_clicked()
{//获取账号和密码QString name = ui->lineEdit_name->text();QString password = ui->lineEdit_password->text();//把数据发送给服务端//发送标志位 账号 密码QString send_message = QString::number(1)+" "+name+" "+password;socket->write(send_message.toStdString().c_str());}
//登录后续处理
void Widget::login(QStringList arr){if(arr[1]=="0"){//登录成功qDebug()<<"登录成功*********";//开启新的界面cidian->socket1 = socket;//把套接字给词典界面this->close();//关闭当前界面//查询历史记录cidian->history();cidian->show();}else if(arr[1]=="-1"){qDebug()<<"登录失败*********";}
}//注册
void Widget::on_pushButton_register_clicked()
{//获取账号和密码QString name = ui->lineEdit_name->text();QString password = ui->lineEdit_password->text();//把数据发送给服务端//发送标志位 账号 密码QString send_message = QString::number(2)+" "+name+" "+password;socket->write(send_message.toStdString().c_str());
}
//注册后续处理
void Widget::my_register(QStringList arr){if(arr[1]=="0"){//注册成功qDebug()<<"注册成功*********";ui->label_zhuce->setText("注册成功");}else if(arr[1]=="-1"){qDebug()<<"用户名相同*********";ui->label_zhuce->setText("用户名相同");}
}//当有数据发来时,接收数据
void Widget::readdata(){//5.读取处理数据QByteArray rece_data = socket->readAll();QString str = QString::fromUtf8(rece_data);//先转位QString类型QStringList arr = str.split(" ");//以空格分割字符串int flag = arr[0].toInt();//在转为int//这里的匹配是在接收完成以后,对各个功能接收到返回值后的处理switch(flag){case 1://登录后续处理login(arr);break;case 2://注册后续处理my_register(arr);break;case 3://查询单词后续处理cidian->select_word(rece_data);break;case 4://查询历史后续处理cidian->sel_histroy(arr);break;case 5://收藏后续处理cidian->shoucang(arr);break;case 6://查看收藏后续处理cidian->look_store(arr);break;case 7://删除收藏后续处理cidian->del_store_word(arr);break;}}
cidian_dialog.h
电子词典的类
#ifndef CIDIAN_DIALOG_H
#define CIDIAN_DIALOG_H#include <QDialog>
#include <QTcpSocket>
#include <QDebug>namespace Ui {
class CiDian_Dialog;
}class CiDian_Dialog : public QDialog
{Q_OBJECTpublic:explicit CiDian_Dialog(QWidget *parent = nullptr);~CiDian_Dialog();//创建tcp对象QTcpSocket* socket1;//查询单词后续处理void select_word(QByteArray arr);//历史记录void history();//历史记录后续处理void sel_histroy(QStringList arr);//收藏后续处理void shoucang(QStringList arr);//查看收藏记录void see_collect();//查看收藏后续处理void look_store(QStringList arr);//删除后续处理void del_store_word(QStringList arr);private slots:void on_pushButton_sel_clicked();void on_pushButton_shoucang_clicked();void on_pushButton_del_store_clicked();private:Ui::CiDian_Dialog *ui;};#endif // CIDIAN_DIALOG_H
cidian_dialog.cpp
主要涉及电子词典功能的实现,向服务端发送数据,并且根据服务端返回的数据进行校验然后进行逻辑处理
#include "cidian_dialog.h"
#include "ui_cidian_dialog.h"CiDian_Dialog::CiDian_Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::CiDian_Dialog)
{ui->setupUi(this);//收藏单词按钮,只有在查询单词并且成功后才能收藏ui->pushButton_shoucang->setEnabled(false);}CiDian_Dialog::~CiDian_Dialog()
{delete ui;
}//查询单词
void CiDian_Dialog::on_pushButton_sel_clicked()
{//获取单词QString word = ui->lineEdit_sel->text();//发送给服务器//发送标志位和单词QString sel = QString::number(3)+" "+word;socket1->write(sel.toStdString().c_str());}
//查询单词后续处理
void CiDian_Dialog::select_word(QByteArray arr){//处理字符串char msg[1024];memset(msg,0,sizeof(msg));strcpy(msg,arr.toStdString().c_str());//截取单词意思char buf[1024];memset(buf,0,sizeof(buf));strcpy(buf,&msg[4]);//从第4个字节开始一直到最后,就是单词的解释QString str = QString::fromUtf8(arr);//先转位QString类型QStringList arr2 = str.split(" ");//以空格分割字符串if(arr2[1]=="0"){//查询成功qDebug()<<"查询成功*********";ui->plainTextEdit_jieshi->clear();ui->plainTextEdit_jieshi->appendPlainText(buf);//每查询成功一次,就调用一次历史记录,更新历史记录history();//查询成功后打开收藏按钮ui->pushButton_shoucang->setEnabled(true);}else if(arr2[1]=="-1"){ui->plainTextEdit_jieshi->clear();ui->plainTextEdit_jieshi->appendPlainText("抱歉本词典没有收录该单词");}
}//历史记录
void CiDian_Dialog::history(){//查询记录QString sel = QString::number(4);socket1->write(sel.toStdString().c_str());
}//历史记录后续处理
void CiDian_Dialog::sel_histroy(QStringList arr){if(arr[1]=="0"){//用之前先清空ui->comboBox_lishi->clear();for(int i=2;i<arr.size();i++){ui->comboBox_lishi->addItem(arr[i]);}//展示完历史数据后,接着展示收藏数据see_collect();}else if(arr[1]=="-1"){}
}//收藏单词
void CiDian_Dialog::on_pushButton_shoucang_clicked()
{//得到搜索的单词QString word = ui->lineEdit_sel->text();//发送标志位和单词QString sel = QString::number(5)+" "+word;socket1->write(sel.toStdString().c_str());
}
//收藏后续处理
void CiDian_Dialog::shoucang(QStringList arr){if(arr[1]=="0"){//收藏成功qDebug()<<"收藏成功***********";//一旦收藏成功就调用,查看收藏see_collect();//收藏成功后再次关闭收藏按钮ui->pushButton_shoucang->setEnabled(false);}else if(arr[1]=="-1"){qDebug()<<"收藏失败";}
}//查看收藏记录
void CiDian_Dialog::see_collect(){//发送标志位QString sel = QString::number(6);socket1->write(sel.toStdString().c_str());
}//查看收藏后续处理
void CiDian_Dialog::look_store(QStringList arr){if(arr[1]=="0"){//查到收藏记录//用之前先清空ui->comboBox_store->clear();ui->plainTextEdit_shoucang->clear();for(int i=2;i<arr.size();i++){ui->comboBox_store->addItem(arr[i]);ui->plainTextEdit_shoucang->appendPlainText(arr[i]);}}else if(arr[1]=="-1"){}
}//删除收藏
void CiDian_Dialog::on_pushButton_del_store_clicked()
{//从组合框中读取要删除的数据QString del_word = ui->comboBox_store->currentText();//发送标志位QString sel = QString::number(7)+" "+del_word;socket1->write(sel.toStdString().c_str());
}//删除后续处理
void CiDian_Dialog::del_store_word(QStringList arr){if(arr[1]=="0"){//删除成功//删除成功就更新一下收藏列表see_collect();}else if(arr[1]=="-1"){}
}
3. 测试
运行代码前记得修改ip
测试,先运行服务端在运行客户端
首先是登录
也可以选择注册
登录
登录成功
查询单词,多查几个,方便测试
收藏单词
删除收藏,首先在组合框选中,然后点击删除
客户端点击右上角的x即可退出