zoukankan html css js c++ java

QT学习笔记（12） QT下的TCP通信

一、TCP通信过程

（1）服务器端：

　　服务器端有QTcpServer的监听套接字，运用listen()方法监听网卡的ip和端口。

　　如果有新的连接传过来，并且连接成功，服务器会触发newConnection(),通过槽函数取出连接过来的通信套接字QTcpSocket

　　如果有数据成功传送过来，对方的通信套接字QTcpSocket会触发readyRead(),通过槽函数可以对接收的数据进行处理

（2）客户端

　　首先根据ip和端口，通过通信套接字QTcpSocket的connectToHost()方法主动和服务器建立连接

　　如果连接成功，通信套接字QTcpSocket会自动触发connected()，通过槽函数可以进行操作

　　如果有数据成功传送过来，对方的通信套接字QTcpSocket会触发readyRead(),通过槽函数可以对接收的数据进行处理

二、实例代码如下：

QT_HelloWorld11.pro

 1 #-------------------------------------------------
 2 #
 3 # Project created by QtCreator 2017-08-30T21:18:55
 4 #
 5 #-------------------------------------------------
 6 
 7 QT       += core gui network #添加network模块
 8 
 9 greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
10 
11 TARGET = QT_HelloWorld11
12 TEMPLATE = app
13 
14 
15 SOURCES += main.cpp
16         serverwidget.cpp 
17     clientwidget.cpp
18 
19 HEADERS  += serverwidget.h 
20     clientwidget.h
21 
22 FORMS    += serverwidget.ui 
23     clientwidget.ui
24 
25 CINFIG += C++11

main.cpp

 1 #include "serverwidget.h"
 2 #include <QApplication>
 3 //包含头文件
 4 #include "clientwidget.h"
 5 
 6 
 7 int main(int argc, char *argv[])
 8 {
 9     QApplication a(argc, argv);
10     //显示服务器窗口
11     ServerWidget w;
12     w.show();
13 
14     //显示客户端窗口
15     ClientWidget w2;
16     w2.show();
17 
18     return a.exec();
19 }

serverwidget.h

 1 #ifndef SERVERWIDGET_H
 2 #define SERVERWIDGET_H
 3 
 4 #include <QWidget>
 5 #include <QTcpServer>//监听套接字
 6 #include <QTcpSocket>//通信套接字（建立好连接的套接字）
 7 
 8 namespace Ui {
 9 class ServerWidget;
10 }
11 
12 class ServerWidget : public QWidget
13 {
14     Q_OBJECT
15 
16 public:
17     explicit ServerWidget(QWidget *parent = 0);
18     ~ServerWidget();
19 
20 private slots:
21     void on_button_send_clicked();
22 
23     void on_button_close_clicked();
24 
25 private:
26     Ui::ServerWidget *ui;
27 
28     QTcpServer * tcpServer;//监听套接字
29     QTcpSocket * tcpSocket;//通信套接字
30 
31 };
32 
33 #endif // SERVERWIDGET_H

clientwidget.h

 1 #ifndef CLIENTWIDGET_H
 2 #define CLIENTWIDGET_H
 3 
 4 #include <QWidget>
 5 #include <QTcpSocket>//通信套接字
 6 
 7 namespace Ui {
 8 class ClientWidget;
 9 }
10 
11 class ClientWidget : public QWidget
12 {
13     Q_OBJECT
14 
15 public:
16     explicit ClientWidget(QWidget *parent = 0);
17     ~ClientWidget();
18 
19 private slots:
20     void on_pushButton_connect_clicked();
21 
22     void on_pushButton_send_clicked();
23 
24     void on_pushButton_close_clicked();
25 
26 private:
27     Ui::ClientWidget *ui;
28 
29     QTcpSocket *tcpSocket;
30 };
31 
32 #endif // CLIENTWIDGET_H

serverwidget.cpp

 1 #include "serverwidget.h"
 2 #include "ui_serverwidget.h"
 3 #include <QTcpServer>//监听套接字
 4 #include <QTcpSocket>//通信套接字（建立好连接的套接字）
 5 
 6 ServerWidget::ServerWidget(QWidget *parent) :
 7     QWidget(parent),
 8     ui(new Ui::ServerWidget)
 9 {
10     ui->setupUi(this);
11 
12     setWindowTitle(QString::fromLocal8Bit("服务器：8888"));
13 
14     tcpServer = NULL;//先赋值为空，在后面做空值判断，防止空指针的错误
15     tcpSocket = NULL;
16 
17     //实例化 监听套接字
18     tcpServer = new QTcpServer(this);//指定父对象，让其自动回收空间
19     //监听
20     tcpServer->listen(QHostAddress::Any,8888);//默认绑定当前网卡上的所有ip
21 
22     //如果有新的连接传过来，并连接成功，服务器触发newConnection()方法
23     connect(tcpServer,&QTcpServer::newConnection,
24             [=]()
25             {
26                 //取出建立好连接的套接字
27                 tcpSocket = tcpServer->nextPendingConnection();//取出当前最近的一次连接的套接字
28                 //获取对方（客户端）的IP和端口
29                 QString ip = tcpSocket->peerAddress().toString();
30                 qint16 port = tcpSocket->peerPort();
31                 QString temp = QString("[%1:%2]:成功连接").arg(ip).arg(port);//组包
32                 //在服务器端显示
33                 ui->textEdit_read->setText(temp);
34 
35                 //此处不能直接放在构造函数中，因为如果直接放在那，还没分配tcpSocket空间，会程序异常
36                 //如果有数据传送成功，对方的通信套接字会触发readyRead(),需要在对应的槽函数做接收处理
37                 connect(tcpSocket,&QTcpSocket::readyRead,
38                         [=]()
39                         {
40                             //从通信套接字中取出内容
41                             QByteArray array = tcpSocket->readAll();
42                             //然后将内容追加到显示文本中
43                             ui->textEdit_read->append(array);
44                         }
45                         );
46 
47                 //如果对方主动断开连接，通信套接字会自动触发disconnected()
48                 connect(tcpSocket,&QTcpSocket::disconnected,
49                         [=]()
50                         {
51                             ui->textEdit_read->append(QString::fromLocal8Bit("对方主动断开连接"));
52                         }
53                         );
54             }
55             );
56 
57 }
58 
59 ServerWidget::~ServerWidget()
60 {
61     delete ui;
62 }
63 
64 void ServerWidget::on_button_send_clicked()
65 {
66     if(tcpSocket == NULL)
67     {
68         return;
69     }
70 
71     //获取编辑区内容
72     QString str = ui->textEdit_write->toPlainText();
73     //给对方发送数据,使用套接字是tcpSocket
74     tcpSocket->write(str.toUtf8().data());
75 }
76 
77 void ServerWidget::on_button_close_clicked()
78 {
79     if(tcpSocket == NULL)
80     {
81         return;
82     }
83     //主动和客户端断开连接
84     tcpSocket->disconnectFromHost();
85     tcpSocket->close();
86 
87     tcpSocket = NULL;
88 }

clientwidget.cpp

 1 #include "clientwidget.h"
 2 #include "ui_clientwidget.h"
 3 //需要包含头文件
 4 #include <QHostAddress>
 5 
 6 ClientWidget::ClientWidget(QWidget *parent) :
 7     QWidget(parent),
 8     ui(new Ui::ClientWidget)
 9 {
10     ui->setupUi(this);
11     setWindowTitle(QString::fromLocal8Bit("客户端"));
12 
13     tcpSocket = NULL;
14 
15     //分配空间，指定父对象
16     tcpSocket = new QTcpSocket(this);
17 
18     //当tcpSocket套接字建立连接成功
19     //如果成功和对方建立连接，通信套接字会自动触发connected()
20     connect(tcpSocket,&QTcpSocket::connected,
21             [=]()
22             {
23                 ui->textEdit_read->setText(QString::fromLocal8Bit("成功和服务器建立连接"));
24             }
25             );
26 
27     //如果有数据传送成功，对方的通信套接字会触发readyRead(),需要在对应的槽函数做接收处理
28     connect(tcpSocket,&QTcpSocket::readyRead,
29             [=]()
30             {
31                 //从通信套接字中取出内容
32                 QByteArray array = tcpSocket->readAll();
33                 //然后将内容追加到显示文本中
34                 ui->textEdit_read->append(array);
35             }
36             );
37 
38     //如果对方主动断开连接，通信套接字会自动触发disconnected()
39     connect(tcpSocket,&QTcpSocket::disconnected,
40             [=]()
41             {
42                 ui->textEdit_read->append(QString::fromLocal8Bit("对方主动断开连接"));
43             }
44             );
45 
46 }
47 
48 ClientWidget::~ClientWidget()
49 {
50     delete ui;
51 }
52 
53 void ClientWidget::on_pushButton_connect_clicked()
54 {
55     //获取服务器ip和端口
56     QString ip = ui->lineEdit_IP->text();
57     qint16 port = ui->lineEdit_port->text().toInt();
58 
59     //主动和服务器建立连接
60     tcpSocket->connectToHost(QHostAddress(ip),port);
61 }
62 
63 void ClientWidget::on_pushButton_send_clicked()
64 {
65     //获取编辑框内容
66     QString str = ui->textEdit_Write->toPlainText();
67     //发送数据
68     tcpSocket->write( str.toUtf8().data() );
69 }
70 
71 void ClientWidget::on_pushButton_close_clicked()
72 {
73     //主动和服务器断开连接
74     tcpSocket->disconnectFromHost();
75     tcpSocket->close();
76 }

serverwidget.ui

clientwidget.ui

三、TCP传递文件

　　实现以下功能：

　　　　客户端连接到服务器

　　　　服务器端选择文件，然后发送

　　　　客户端接收文件，并提示接收成功

　　大概流程图如下：

代码如下：

QT_HelloWorld14.pro

 1 #-------------------------------------------------
 2 #
 3 # Project created by QtCreator 2017-08-31T19:08:18
 4 #
 5 #-------------------------------------------------
 6 
 7 QT       += core gui network
 8 
 9 greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
10 
11 TARGET = QT_HelloWorld14
12 TEMPLATE = app
13 
14 
15 SOURCES += main.cpp
16         serverwidget.cpp 
17     clientwidget.cpp
18 
19 HEADERS  += serverwidget.h 
20     clientwidget.h
21 
22 FORMS    += serverwidget.ui 
23     clientwidget.ui
24 
25 CONFIG += C++11