1.服务器端

widget.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpServer>//服务器端类
#include <QMessageBox>//消息对话框
#include <QTcpSocket>//客户端类
#include <QList>//链表容器类
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_startBtn_clicked();public slots:void newConnection_slot();//newConnection信号对应的槽函数声明void readRead_slot();//readyRead信号对应的槽函数声明
private:Ui::Widget *ui;//实例化一个服务器指针QTcpServer *server;//定义一个存放客户端的容器QList<QTcpSocket *>socketList;
};
#endif // WIDGET_H

main.cpp

#include "widget.h"#include <QApplication>int main(int argc, char *argv[])
{QApplication a(argc, argv);Widget w;w.show();return a.exec();
}

widget.cpp

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget),server(new QTcpServer(this))//给服务器指针 实例化空间
{ui->setupUi(this);this->setWindowTitle("服务器");
}Widget::~Widget()
{delete ui;
}//启动服务器按钮对应的槽函数
void Widget::on_startBtn_clicked()
{//获取ui界面上的端口号quint16 port = ui->portEdit->text().toUInt();//将字符串转换成整形//让服务器设置监听//函数原型：//bool listen（const QHostAddress &address=QHostAddress::Any,quint16 port=0)//参数1：监听的主机地址 可以任意主机//参数2：监听的端口号//返回值：bool 监听成功 true 否则falseif(server->listen(QHostAddress::Any,port)){QMessageBox::information(this,"成功对话框","启动服务器成功!");//监听成功}else{//监听失败QMessageBox::information(this,"失败对话框","启动服务器失败");return;}//程序运行至此，意味着服务器监听成功，如果有客户端发来连接请求，服务器就会自动发射一个newConnection（）信号//那么我们就可以将该信号链接到自定义的槽函数中connect(server,&QTcpServer::newConnection,this,&Widget::newConnection_slot);
}//newConnection信号对应的槽函数
void Widget::newConnection_slot()
{//获取最新连接客户端的套接字//函数原型QTcpSocket *s=server->nextPendingConnection();//将套接字放入链表容器中socketList.push_back(s);//此时说明服务器与客户端成功建立了连接，如果客户端向服务器发来数据，那么客户端就会自动发射一个readyRead信号//将该信号链接到自定义的槽函数中，在槽函数中读取数据connect(s,&QTcpSocket::readyRead,this,&Widget::readRead_slot);
}//readyRead()信号对应的槽函数
void Widget::readRead_slot()
{//移出无效客户端for(int i=0;i<socketList.count();i++){//功能：判断客户端与服务器//未连接的枚举对应的值为0if(socketList.at(i)->state()==0){//删除下标socketList.removeAt(i);}}for(int i=0;i<socketList.count();i++){//bytesAvailable():返回数据的大小if(socketList.at(i)->bytesAvailable()>0){//读取数据QByteArray msg = socketList.at(i)->readAll();//将读到的数据放入到ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));//将数据广播给所有客户端for(int j=0;j<socketList.count();j++){socketList.at(j)->write(msg);}}}}

2.客户端

widget.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QTcpSocket>//客户端类
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_conneBtn_clicked();void on_sendBtn_clicked();void on_disconnectBtn_clicked();public slots:void connect_slot();void readyRead_slot();void disconnected_slot();private:Ui::Widget *ui;//实例化一个客户端指针QTcpSocket *socket;//定义一个存储用户的变量QString username;
};
#endif // WIDGET_H

main.cpp

#include "widget.h"#include <QApplication>int main(int argc, char *argv[])
{QApplication a(argc, argv);Widget w;w.show();return a.exec();
}

widget.cpp

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget),socket(new QTcpSocket(this))
{ui->setupUi(this);//初始化界面ui->msgEdit->setEnabled(false);//不可用ui->sendBtn->setEnabled(false);ui->disconnectBtn->setEnabled(false);//如果成功链接到服务器，客户端就会自动发射一个connect信号//将信号链接到自定义的槽函数，由于只需要连接一次，所以连接函数写在构造函数中connect(socket,&QTcpSocket::connected,this,&Widget::connect_slot);//如果连接到服务器向客户端发来数据，客户端就会自动发射一个readyread信号//将该信号链接到自定义的槽函数中，读取数据，由于只需要连接一次，那么连接函数写在构造函数中connect(socket,&QTcpSocket::readyRead,this,&Widget::readyRead_slot);
}Widget::~Widget()
{delete ui;
}//连接按钮对应的槽函数处理
void Widget::on_conneBtn_clicked()
{//获取到ui界面上的ip和端口号QString ip=ui->ipEdit->text();quint16 port=ui->portEdit->text().toUInt();//将字符串转换成整形//客户端连接服务器socket->connectToHost(ip,port);}//connected对应槽函数
void Widget::connect_slot()
{//告诉服务器 我上线username=ui->usernameEdit->text();QString msg=username+"进入聊天室";//将数据发送给服务器socket->write(msg.toLocal8Bit());//至此服务器和客户端已经建立连接ui->msgEdit->setEnabled(true);//可用ui->sendBtn->setEnabled(true);ui->disconnectBtn->setEnabled(true);ui->conneBtn->setEnabled(false);ui->label_2->setEnabled(false);ui->label_3->setEnabled(false);}
//readyRead()信号对应的槽函数
void Widget::readyRead_slot(){//读数据QByteArray msg=socket->readAll();//将读取到的数据放入到ui界面上ui->listWidget->addItem(QString::fromLocal8Bit(msg));
}void Widget::disconnected_slot()
{//如果输入框内有内容则清空ui->msgEdit->clear();//按钮的重新启用与不可用ui->msgEdit->setEnabled(false);ui->sendBtn->setEnabled(false);ui->disconnectBtn->setEnabled(false);ui->conneBtn->setEnabled(true);
}
//发送按钮的槽函数
void Widget::on_sendBtn_clicked()
{//获取ui界面上的内容QString msg=ui->msgEdit->text();msg=username+":"+msg;socket->write(msg.toLocal8Bit());//将信息发送给服务器//清空输入框的内容ui->msgEdit->clear();}//断开与服务器连接所对应的自定义槽函数
void Widget::on_disconnectBtn_clicked()
{QString msg = username + "退出聊天室";socket->write(msg.toLocal8Bit());socket->disconnectFromHost();connect(socket,&QTcpSocket::disconnected,this,&Widget::disconnected_slot);}