QT实现TCP通信（服务器与客户端搭建）

一、TCP通信框架

二、QT中的服务器操纵

• 创建一个QTcpServer类对象，该类对象就是一个服务器
  
• 调用listen函数将该对象设置为被动监听状态，监听时，可以监听指定的ip地址，也可以监听所有主机地址，可以通过指定端口号，也可以让服务器自动选择
  
• 当有客户端发来毗连请求时，该服务器会自动发射一个newConnection信号，我们可以将该信号毗连到自定义槽函数处置惩罚相关逻辑
  
• 在槽函数中，可以调用nextPendingConnection函数可以得到最新毗连的客户端套接字地址，我们可以将该套接字地址存储到容器中
  
• 此时服务器与客户端已经建立毗连，假如有客户端向服务器发来数据，那么对应的客户端套接字就会发射一个readyRead信号
  
• 读取套接字中的数据利用read、readLine、readAll函数来完成
  
• 向套接字中写数据，可以利用write
  
• 关闭服务器，利用close来完成
  

Server界面代码：
体系管理文件：

1. QT       += core gui network
3. greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
5. CONFIG += c++11
7. # The following define makes your compiler emit warnings if you use
8. # any Qt feature that has been marked deprecated (the exact warnings
9. # depend on your compiler). Please consult the documentation of the
10. # deprecated API in order to know how to port your code away from it.
11. DEFINES += QT_DEPRECATED_WARNINGS
13. # You can also make your code fail to compile if it uses deprecated APIs.
14. # In order to do so, uncomment the following line.
15. # You can also select to disable deprecated APIs only up to a certain version of Qt.
16. #DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0
18. SOURCES += \
19.     main.cpp \
20.     widget.cpp
22. HEADERS += \
23.     widget.h
25. FORMS += \
26.     widget.ui
28. # Default rules for deployment.
29. qnx: target.path = /tmp/$${TARGET}/bin
30. else: unix:!android: target.path = /opt/$${TARGET}/bin
31. !isEmpty(target.path): INSTALLS += target

复制代码

 头文件：

1. #ifndef WIDGET_H
2. #define WIDGET_H
4. #include <QWidget>
5. #include <QTcpServer>   //服务器头文件
6. #include <QTcpSocket>   //客户端头文件
7. #include <QList>    //链表头文件用来存放客户端容器
8. #include <QDebug>
9. #include <QMessageBox>  //消息对话框
11. QT_BEGIN_NAMESPACE
12. namespace Ui { class Widget; }
13. QT_END_NAMESPACE
15. class Widget : public QWidget
16. {
17.     Q_OBJECT
19. public:
20.     Widget(QWidget *parent = nullptr);
21.     ~Widget();
23. private slots:
24.     void on_pushButton_clicked();
25.     void newConnection_slot();
26.     void readyRead_slot();  //自定义处理readyRead信号的槽函数
28. private:
29.     Ui::Widget *ui;
31.     //定义服务器指针
32.     QTcpServer *server;
34.     //定义客户端指针链表容器
35.     QList<QTcpSocket *> clientList;
37. };
38. #endif // WIDGET_H

复制代码

主函数：

1. #include "widget.h"
3. #include <QApplication>
5. int main(int argc, char *argv[])
6. {
7.     QApplication a(argc, argv);
8.     Widget w;
9.     w.show();
10.     return a.exec();
11. }

复制代码

重要功能函数：

1. #include "widget.h"
2. #include "ui_widget.h"
4. Widget::Widget(QWidget *parent)
5.     : QWidget(parent)
6.     , ui(new Ui::Widget)
7. {
8.     ui->setupUi(this);
10.     //给服务器指针实例化对象
11.     server = new QTcpServer(this);  //服务器创建完成
13. }
15. Widget::~Widget()
16. {
17.     delete ui;
18. }
20. //启动服务器按钮对应的槽函数
21. void Widget::on_pushButton_clicked()
22. {
23.     //获取UI界面的端口号
24.     quint16 port = ui->lineEdit->text().toUInt();
25.     //将服务器设置为被动监听状态
26.     //bool QTcpServer::listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)
27.     //参数1：要监听的主机地址，如果是any，表示监听所有主机地址，也可以给特定的主机地址进行监听
28.     //参数2：通过指定的端口号进行访问服务器，如果是0，表示由服务器自动分配。如果非0，则表示指定端口号
29.     //返回值：成功返回真，失败返回假
30.     if(!server->listen(QHostAddress::Any,port))
31.     {
32.         QMessageBox::critical(this, "失败", "服务器启动失败");
33.     }else{
34.         QMessageBox::information(this, "成功", "服务器启动成功");
35.     }
37.     //执行到这表明服务器启动成功，并对客户端连接进行监听，如果有客户端向服务器发来连接请求，那么该服务器就会自动发射一个newConnection信号
38.     //我们可以将信号连接到对应的槽函数中处理相关逻辑
39.     connect(server, &QTcpServer::newConnection, this, &Widget::newConnection_slot);
40. }
42. void Widget::newConnection_slot()
43. {
44.     qDebug() <<"有客户端申请连接";
46.     //获取最新连接的客户端套接字
47.     //[virtual] QTcpSocket *QTcpServer::nextPendingConnection()
48.     QTcpSocket *s = server->nextPendingConnection();
50.     //将获取的套接字存放到客户端容器中
51.     clientList.push_back(s);
53.     //此时，客户端就和服务器建立起来联系了
54.     //如果客户端有数据向服务器发送过来，那么该套接字就会自动发送一个readyread信号
55.     //我们可以将该信号连接到自定义的槽函数中处理相关逻辑
56.     connect(s, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);
57. }
59. //关于readyRead信号对应槽函数的实现
60. void Widget::readyRead_slot()
61. {
62.     //删除客户端链表中的无效客户端套接字
63.     for(int i=0; i<clientList.count(); i++)
64.     {
65.         //判断套接字的状态
66.         //函数原型     SocketState state() const;
67.         //功能：返回客户端状态
68.         //返回值：客户端状态，如果是0，表示无连接
69.         if(clientList[i]->state() == 0)
70.         {
71.             clientList.removeAt(i);     //将下标为i的客户端移除
72.         }
73.     }
75.     //遍历所有客户端，查看是哪个客户端发来数据
76.     for(int i=0; i<clientList.count(); i++)
77.     {
78.         //函数原型：qint64 bytesAvailable() const override;
79.         //功能：返回当前客户端套接字中的可读数据字节个数
80.         //返回值：当前客户端待读的字节数，如果该数据0，表示无待读数据
81.         if(clientList[i]->bytesAvailable() != 0)
82.         {
83.             //读取当前客户端的相关数据
84.             //函数原型：QByteArray readAll();
85.             //功能：读取当前套接字中的所有数据，并返回一个字节数组
86.             //返回值：数据的字节数组
87.             QByteArray msg = clientList[i]->readAll();
89.             //将数据战术到ui界面上
90.             ui->listWidget->addItem(QString::fromLocal8Bit(msg));
92.             //将接收到的该消息，发送给所有客户端
93.             for(int j=0; j<clientList.count(); j++)
94.             {
95.                 clientList[j]->write(msg);
96.             }
97.         }
98.     }
100. }

复制代码

所用组件：

 三、QT中的客户端操纵

• 实例化一个QTcpSocket类对象
  
• 调用该对象的成员函数connectToHost毗连到服务器，毗连服务器时，需要给定服务器的ip地址和端口号
  
• 假如毗连服务器成功，那么该客户端就会自动发送一个connected信号，我们可以将该信号毗连到自定义槽函数中处置惩罚相关逻辑
  
• 假如服务器向客户端发来数据，那么该客户端就会自动发射一个readyRead信号，我们可以将该信号毗连到自定义的槽函数中处置惩罚相关逻辑
  
• 可以利用read、readLine、readAll读取客户端中的数据
  
• 可以利用write向服务器发送数据
  
• 利用成员函数disConnectFromHost断开与服务器的毗连
  
• 假如成功断开与服务器的毗连，那么该套接字就会自动发射一个disconn信号
  

Client界面代码：
 体系管理文件：

1. QT       += core gui network
3. greaterThan(QT_MAJOR_VERSION, 4): QT += widgets
5. CONFIG += c++11
7. # The following define makes your compiler emit warnings if you use
8. # any Qt feature that has been marked deprecated (the exact warnings
9. # depend on your compiler). Please consult the documentation of the
10. # deprecated API in order to know how to port your code away from it.
11. DEFINES += QT_DEPRECATED_WARNINGS
13. # You can also make your code fail to compile if it uses deprecated APIs.
14. # In order to do so, uncomment the following line.
15. # You can also select to disable deprecated APIs only up to a certain version of Qt.
16. #DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0
18. SOURCES += \
19.     main.cpp \
20.     widget.cpp
22. HEADERS += \
23.     widget.h
25. FORMS += \
26.     widget.ui
28. # Default rules for deployment.
29. qnx: target.path = /tmp/$${TARGET}/bin
30. else: unix:!android: target.path = /opt/$${TARGET}/bin
31. !isEmpty(target.path): INSTALLS += target

复制代码

 头文件：

1. #ifndef WIDGET_H
2. #define WIDGET_H
4. #include <QWidget>
5. #include <QTcpSocket>
6. #include <QMessageBox>
8. QT_BEGIN_NAMESPACE
9. namespace Ui { class Widget; }
10. QT_END_NAMESPACE
12. class Widget : public QWidget
13. {
14.     Q_OBJECT
16. public:
17.     Widget(QWidget *parent = nullptr);
18.     ~Widget();
20. private slots:
21.     void on_pushButton_2_clicked();
22.     void connected_slot();  //自定义处理信号的槽函数
23.     void readyRead_slot();  //自定义处理readyRead信号的槽函数
24.     void disconnected_slot();   //自定义处理disconnected信号的槽函数
26.     void on_pushButton_clicked();
28.     void on_pushButton_3_clicked();
30. private:
31.     Ui::Widget *ui;
33.     //定义一个客户端指针
34.     QTcpSocket *socket;
36.     //用户名
37.     QString userName;
38. };
39. #endif // WIDGET_H

复制代码

主函数：

1. #include "widget.h"
3. #include <QApplication>
5. int main(int argc, char *argv[])
6. {
7.     QApplication a(argc, argv);
8.     Widget w;
9.     w.show();
10.     return a.exec();
11. }

复制代码

重要功能函数：

1. #include "widget.h"
2. #include "ui_widget.h"
4. Widget::Widget(QWidget *parent)
5.     : QWidget(parent)
6.     , ui(new Ui::Widget)
7. {
8.     ui->setupUi(this);
10.     //给客户端指针实例化空间
11.     socket = new QTcpSocket(this);
13.     //如果连接服务器成功，该客户端就会发射一个connected信号
14.     //我们可以将该信号连接到自定义的槽函数中处理相关逻辑
15.     //由于该连接只需要连接一次。所有在构造函数中即可
16.     connect(socket, &QTcpSocket::connected, this, &Widget::connected_slot);
18.     //客户端与服务器连接成功后，如果服务器向客户端发来数据，那么该客户端就会自动发射一个readyRead信号
19.     //我们可以将该信号连接到自定义槽函数中处理相关逻辑
20.     connect(socket, &QTcpSocket::readyRead, this, &Widget::readyRead_slot);
22.     //当客户端与服务器断开连接后，该客户端就会自动发射1一个disconnected信号
23.     //我们可以将该信号与自定义的槽函数连接
24.     //由于只需要连接一下，所有该连接写到构造函数即可
25.     connect(socket, &QTcpSocket::disconnected, this, &Widget::disconnected_slot);
26. }
28. Widget::~Widget()
29. {
30.     delete ui;
31. }
33. //连接服务器按钮对应的槽函数
34. void Widget::on_pushButton_2_clicked()
35. {
36.     //获取UI界面的信息
37.     userName = ui->lineEdit_2->text();  //获取用户名
38.     QString hostName = ui->lineEdit_3->text();  //获取主机地址
39.     quint16 port = ui->lineEdit_4->text().toUInt();     //获取端口号
42.     //调用函数连接到主机
43.     //函数原型：[virtual] void QAbstractSocket::connectToHost(const QString &hostName, quint16 port)
44.     //参数1：服务器的主机地址
45.     //参数2：端口号
46.     //返回值：无
47.     socket->connectToHost(hostName,port);
49.    
50. }
52. //关于处理connected信号的槽函数
53. void Widget::connected_slot()
54. {
55.     QMessageBox::information(this,"成功","连接服务器成功");
57.     //顺便向服务器发送一条消息，说：xxx进入聊天室
58.     QString msg = userName + "进入聊天室";
60.     socket->write(msg.toLocal8Bit());
61. }
63. //关于readyRead信号对应槽函数的实现
64. void Widget::readyRead_slot()
65. {
66.     //读取该客户端中的数据
67.     //返回值：QBytearray
68.     QByteArray msg = socket->readAll();
70.     //将数据展示在UI界面
71.     ui->listWidget->addItem(QString::fromLocal8Bit(msg));
73. }
76. void Widget::on_pushButton_clicked()
77. {
78.     //获取UI界面中的编辑的文本内容
79.     QString m = ui->lineEdit->text();
81.     //整合要发送的信息
82.     QString msg = userName + ": " + m;
84.     //将消息发送给服务器
85.     socket->write(msg.toLocal8Bit());
87.     //将消息编辑框中的内容清空
88.     ui->lineEdit->clear();
89. }
92. //断开服务器按钮对应的槽函数
93. void Widget::on_pushButton_3_clicked()
94. {
95.     //准备要发送的信息
96.     QString msg = userName + ": 离开聊天室";
97.     socket->write(msg.toLocal8Bit());
99.     //调用成员函数disconnectFromHost
100.     //函数原型：virtual void disconnectFromHost();
101.     //功能：断开服务器与客户端的连接
102.     //参数：无
103.     //返回值：无
104.     socket->disconnectFromHost();
105. }
107. //disconn信号对应槽函数的实现
108. void Widget::disconnected_slot()
109. {
110.     QMessageBox::information(this, "退出", "断开成功");
111. }

复制代码

 所用组件：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。