QT中的TCP网络通信-第二弹

在第一弹里，笔者大致讲述了QTcpSocket，QTcpServer这两个重要的类的一些基本特性以及API函数。那么在第二弹，我将用一个事例讲述他们在项目里的实战。

假设我们要搭建一个简单的聊天服务器，分为客户端与服务端，两个端可以相互连接并发送消息。

1.服务器端通信流程

1.首先创建一个套接字服务器QTcpServer类的对象

2.通过此对象设置监听，即QTcpServer::listen()

3.检测新客户端连接信号 即QTcpServer::newConnection()

4.检测到新客户端连接号之后调用QTcpSocket*QTcpServer::nextPendingConnection()

得到套接字通信对象

代码片段

ui界面搭建效果如下:

头文件

#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include<QTcpServer>
#include<QTcpSocket>
#include<QLabel>
QT_BEGIN_NAMESPACE
namespace Ui {
class MainWindow;
}
QT_END_NAMESPACE

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr);
    ~MainWindow();

private slots:
    void on_setListen_clicked();

    void on_sendMessage_clicked();

private:
    Ui::MainWindow *ui;
    QTcpServer*m_s;
    QTcpSocket*m_ts;
    QLabel*m_status;
    QTcpSocket*tcp;
};
#endif // MAINWINDOW_H

源文件

#include "mainwindow.h"
#include "./ui_mainwindow.h"
MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)
{
    ui->setupUi(this);
    setWindowTitle("服务器");
    //得到端口号
    ui->port->setText("8899");
    //创建监听服务器对象
    m_s=new QTcpServer(this);
    connect(m_s,&QTcpServer::newConnection,this,[=]()
    {   m_ts= m_s->nextPendingConnection();//得到socket对象 实例化
        m_status->setPixmap(QPixmap(":/images/right.png").scaled(20,20));
        ui->record->append("客户端连接成功");
    //检测是否可以接收数据
    connect(m_ts,&QTcpSocket::readyRead,this,[=](){
        //接收数据
          QByteArray data =m_ts->readAll();
        ui->record->append("客户端:"+ data);
    });
        //检测断开连接
        connect(m_ts,&QTcpSocket::disconnected,this,[=](){
        m_ts->close();
        m_ts->deleteLater();//delete
        ui->record->append("客户端断开连接");
        m_status->setPixmap(QPixmap(":/images/false.png").scaled(20,20));
    });
    });
    //状态栏
    m_status =new QLabel;
    m_status->setPixmap(QPixmap(":/images/false.png").scaled(20,20));
    ui->statusbar->addWidget(new QLabel("连接状态: "));
    ui->statusbar->addWidget(m_status);
}
MainWindow::~MainWindow()
{
    delete ui;
}
void MainWindow::on_setListen_clicked()
{
    unsigned short port = ui->port->text().toShort();
    //监听
    m_s->listen(QHostAddress::Any,port);//绑定本地任意ip地址并且指定窗口
    //启动监听后让按钮不可用
    ui->setListen->setDisabled(true);

}
void MainWindow::on_sendMessage_clicked()
{
    QString msg=ui->message->toPlainText();//纯文本方式取出数据
    m_ts->write(msg.toUtf8());
    ui->record->append("服务器: "+msg);
    ui->message->clear();
}

2.客户端通信流程

1.创建套接字通信性类QTcpSocket

2.使用绑定的ip以及端口连接服务器QAbstarctSocket::connectToHost()

3.使用套接字对象与服务器进行通信

代码片段

客户端ui界面效果如下

头文件

#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>

#include<QTcpSocket>
#include<QLabel>
QT_BEGIN_NAMESPACE
namespace Ui {
class MainWindow;
}
QT_END_NAMESPACE

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr);
    ~MainWindow();

private slots:
    void on_sendMessage_clicked();
    void on_connect_clicked();
    void on_disconnect_clicked();

private:
    Ui::MainWindow *ui;
    QTcpSocket*m_tcp;
    QLabel*m_status;
};
#endif // MAINWINDOW_H

源文件

#include "mainwindow.h"
#include "./ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)
{
    ui->setupUi(this);
    ui->port->setText("8899");
    ui->ip->setText("127.0.0.1");
    ui->disconnect->setDisabled(true);
    setWindowTitle("客户端");
    //创建套接字对象
    m_tcp = new QTcpSocket;
    //接收信息
    connect(m_tcp,&QTcpSocket::readyRead,this,[=](){
        QByteArray data =m_tcp->readAll();
        ui->record->append("服务器:"+data);
    });
    //断开检测
    connect(m_tcp,&QTcpSocket::disconnected,this,[=](){
        m_tcp->close();//双向断开
        m_tcp->deleteLater();
        m_status->setPixmap(QPixmap(":/images/false.png").scaled(20,20));
        ui->record->append("服务器断开连接");
        ui->connect->setDisabled(false);
        ui->disconnect->setEnabled(false);
    });
    //连接检测
    connect(m_tcp,&QTcpSocket::connected,this,[=](){
        m_status->setPixmap(QPixmap(":/images/right.png").scaled(20,20));
        ui->record->append("服务器连接成功");
        ui->connect->setDisabled(true);
        ui->disconnect->setEnabled(true);
    });
    //处理状态栏
    m_status = new QLabel;
    m_status->setPixmap(QPixmap(":/images/false.png").scaled(20,20));
    ui->statusbar->addWidget(new QLabel("连接状态"));
    ui->statusbar->addWidget(m_status);

}

MainWindow::~MainWindow()
{
    delete ui;
}

void MainWindow::on_sendMessage_clicked()
{
    QString msg = ui->message->toPlainText();//纯文本方式读取数据
    m_tcp->write(msg.toUtf8());
    ui->record->append("客户端:"+msg);
    ui->message->clear();
}


void MainWindow::on_connect_clicked()
{   //连接服务器
    QString ip=ui->ip->text();
    unsigned short port =ui->port->text().toUShort();
    m_tcp->connectToHost(QHostAddress(ip),port);

}

void MainWindow::on_disconnect_clicked()
{
    m_tcp->close();
    ui->connect->setDisabled(false);
    ui->disconnect->setDisabled(true);
}

以上就是这个案例的内容。后续任然会更新一个相关案例