QT学习第五天

#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->mag_edit->setEnabled(false);

    ui->send_btn->setEnabled(false);

    ui->dis_btn->setEnabled(false);

    //

    connect(socket,&QTcpSocket::connected,this,&Widget::connected_slot);

    //如果服务器向客户端发送数据，那么客户端就会自动发射一个readyread()信号

    connect(socket,&QTcpSocket::readyRead,this,&Widget::readyRead_slot);

    connect(socket,&QTcpSocket::disconnected,this,&Widget::disconnected_slot);

}

Widget::~Widget()

{

    delete ui;

}

void Widget::on_connect_btn_clicked()

{

    QString ip = ui->ip_edit->text();

    quint16 port = ui->port_edit->text().toUInt();

    socket->connectToHost(ip,port);

}

void Widget::connected_slot()

{

    QString userName = ui->user_edit->text();

    //告诉服务器我来了

    QString msg = userName + "：进入聊天室";

    //将信息发送给服务器

    socket->write(msg.toLocal8Bit());

    ui->mag_edit->setEnabled(true);

    ui->send_btn->setEnabled(true);

    ui->dis_btn->setEnabled(true);

    ui->user_edit->setEnabled(false);

    ui->ip_edit->setEnabled(false);

    ui->port_edit->setEnabled(false);

    ui->connect_btn->setEnabled(false);

}

void Widget::on_send_btn_clicked()

{

    //获取ui界面的文本

    QString msg =ui->mag_edit->text();

    msg = userName + "：" + msg;

    //将信息发生给服务器

    socket->write(msg.toLocal8Bit());

    //清空

    ui->mag_edit->clear();

}

void Widget:: readyRead_slot()

{

    QByteArray msg = socket->readAll();

    ui->listWidget->addItem(QString::fromLocal8Bit(msg));

}

void Widget::disconnected_slot()

{

    ui->mag_edit->setEnabled(false);

    ui->send_btn->setEnabled(false);

    ui->dis_btn->setEnabled(false);

    ui->user_edit->setEnabled(true);

    ui->ip_edit->setEnabled(true);

    ui->port_edit->setEnabled(true);

    ui->connect_btn->setEnabled(true);

}

void Widget::on_dis_btn_clicked()

{

    //告诉服务器我要走了

    QString msg = userName + "：离开聊天室";

    socket->write(msg.toLocal8Bit());

    socket->disconnectFromHost();

}

服务器

#include "widget.h"

#include "ui_widget.h"

Widget::Widget(QWidget *parent)

    : QWidget(parent)

    , ui(new Ui::Widget)

    , server(new QTcpServer(this))//给服务器指针实例化空间

{

    ui->setupUi(this);

}

Widget::~Widget()

{

    delete ui;

}

void Widget::on_start_btn_clicked()

{

    quint16 port = ui->port_edit->text().toUInt();

    if(server->listen(QHostAddress::Any,port))

    {

        QMessageBox::information(this,"","启动服务器成功！");

    }

    else

    {

        QMessageBox::information(this,"","启动服务器失败！");

        return;

    }

    connect(server,&QTcpServer::newConnection,this,&Widget::newConnection_slot);

}

void Widget::newConnection_slot()

{

    qDebug()<<"有新的客户端连接";

    QTcpSocket *s = server->nextPendingConnection();

    socketList.push_back(s);

    connect(s,&QTcpSocket::readyRead,this,&Widget::readyRead_slot);

}

void Widget::readyRead_slot()

{

    for(int i=0;i<socketList.count();i++)

    {

        if(socketList.at(i)->state()==0)

        {

            //移除无效客户端

            socketList.removeAt(i);

        }

    }

    //遍历客户端容器判断哪个客户端有数据待读

    for(int i=0;i<socketList.count();i++)

    {

        //判断哪个客户端有数据待读

        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);

            }

        }

    }

}