【免费】QT中TCP通信流程完整代码资源-CSDN文库

共10个文件

cpp：4个

ui：2个

pro：2个

需积分: 0 200 浏览量 2023-12-01 21:13:32 上传评论收藏 9KB ZIP 举报

QT库是Qt公司开发的一款强大的跨平台应用程序开发框架，尤其在图形用户界面和网络通信方面表现出色。在QT中实现TCP通信，可以帮助开发者构建稳定、高效的数据传输应用。本篇文章将详细讲解QT中TCP通信的流程，并提供一个完整的代码示例。我们需要了解TCP（Transmission Control Protocol）是一种面向连接的、可靠的、基于字节流的传输层通信协议。在QT中，我们可以使用QTcpServer和QTcpSocket这两个类来实现TCP服务器和客户端的通信。 1. **创建TCP服务器** - 我们需要创建一个QTcpServer对象，并在其上绑定监听端口。这通常在主线程或单独的线程中完成。 - 通过调用`QTcpServer::listen()`方法启动监听，传入适当的QHostAddress和端口号。 - 当有新的连接请求时，QTcpServer会发出`newConnection()`信号，我们可以通过连接这个信号并处理新连接。 2. **处理连接请求** - 在服务器端，当接收到新的连接请求时，我们需要接受这个连接。通过调用`QTcpServer::nextPendingConnection()`方法获取到一个新的QTcpSocket对象，代表了与客户端的连接。 - 接收数据可以使用QTcpSocket的`read()`或`readLine()`方法，发送数据则使用`write()`方法。 3. **创建TCP客户端** - 客户端需要创建一个QTcpSocket对象，然后使用`connectToHost()`方法尝试连接到服务器，传入服务器的IP地址和端口号。 - 连接成功后，同样可以通过`write()`方法发送数据，`read()`或`readLine()`方法接收数据。 4. **错误处理和信号槽** - 在TCP通信中，错误处理至关重要。QTcpServer和QTcpSocket都提供了各种错误信号，如`error(QAbstractSocket::SocketError)`，可以捕获并处理这些信号。 - 为了响应事件，如连接建立、数据接收和发送，我们可以使用QT的信号槽机制，将相应的函数连接到这些信号。 5. **完整代码示例** 以下是一个简单的TCP服务器和客户端的QT代码示例： ```cpp // TCP服务器 class Server : public QObject { Q_OBJECT public: explicit Server(QObject *parent = nullptr) : server(parent) {} void startServer(int port) { server.listen(QHostAddress::Any, port); } private slots: void newConnection() { auto socket = server.nextPendingConnection(); connect(socket, &QTcpSocket::readyRead, this, [socket] { QByteArray data = socket->readAll(); // 处理接收到的数据 ... socket->write("数据已接收"); }); } signals: void started(); private: QTcpServer server; }; // TCP客户端 class Client : public QObject { Q_OBJECT public: explicit Client(QObject *parent = nullptr) : socket(parent) {} void connectToServer(const QString &host, int port) { socket.connectToHost(host, port); if (socket.waitForConnected()) { // 连接成功，发送数据 socket.write("你好，服务器！"); connect(socket, &QTcpSocket::readyRead, this, [this] { QByteArray data = socket.readAll(); // 处理接收到的数据 ... }); } else { // 处理连接失败 ... } } signals: void connected(); private: QTcpSocket socket; }; ``` 这个例子展示了如何在QT中使用TCP进行通信的基本流程。服务器监听特定端口，当有新连接时，读取客户端发送的数据并回应。客户端连接到服务器，发送消息并等待服务器的响应。实际应用中，你需要根据具体需求对数据处理和错误处理部分进行扩展和完善。 QT为TCP通信提供了一套简洁、高效的API，使得开发者能够轻松地在不同平台上实现可靠的数据传输功能。通过理解并掌握上述知识，你可以创建自己的TCP服务和客户端应用，实现数据的高效交互。

资源推荐

资源详情

资源评论

收起资源包目录

TCP-QT.zip （10个子文件）

TCP-QT

client

mainwindow.h 874B

mainwindow.cpp 4KB

main.cpp 183B

mainwindow.ui 4KB

client.pro 1KB

server

mainwindow.h 1KB

mainwindow.cpp 5KB

main.cpp 183B

server.pro 1KB

mainwindow.ui 4KB

#include "mainwindow.h" #include "ui_mainwindow.h" MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent) , ui(new Ui::MainWindow) { ui->setupUi(this); labListen = new QLabel("监听状态："); labListen->setMaximumWidth(150); ui->statusbar->addWidget(labListen); labSocketState = new QLabel("socket状态："); labSocketState->setMaximumWidth(200); ui->statusbar->addWidget(labSocketState); QString loaclIP = getLocalIP(); //获取本机IP地址 this->setWindowTitle(this->windowTitle() + "---本机IP地址：" + loaclIP); ui->lineEditIP->setText(loaclIP); tcpServer = new QTcpServer(this); connect(tcpServer, SIGNAL(newConnection()), this, SLOT(slotNewConnection())); } MainWindow::~MainWindow() { if(tcpSocket != nullptr) { if(tcpSocket->state() == QAbstractSocket::ConnectingState) { tcpSocket->disconnectFromHost(); //断开与客户端连接 } } if(tcpServer->isListening()) { tcpServer->close(); //停止网络监听 } delete ui; } QString MainWindow::getLocalIP() { QString hostName = QHostInfo::localHostName(); //获取本机主机名 QHostInfo hostInfo = QHostInfo::fromName(hostName); QString localIP = ""; QList<QHostAddress>addrList = hostInfo.addresses(); //获取本机IP地址列表 if(addrList.isEmpty()) { return localIP; } foreach(QHostAddress aHost, addrList) { if(QAbstractSocket::IPv4Protocol == aHost.protocol()) { localIP = aHost.toString(); break; } } return localIP; } void MainWindow::on_actStart_clicked() { QString IP = ui->lineEditIP->text(); quint16 port = ui->lineEditPort->text().toShort(nullptr, 10); QHostAddress address(IP); //通过IP地址字符串创建QHostAddress对象 tcpServer->listen(address, port); //开始监听 ui->TextEdit->appendPlainText("开始监听....."); ui->TextEdit->appendPlainText("服务器地址：" + tcpServer->serverAddress().toString()); ui->TextEdit->appendPlainText("服务器端口：" + QString::number(tcpServer->serverPort())); ui->actStart->setEnabled(false); ui->actStop->setEnabled(true); labListen->setText("监听状态：正在监听..."); } void MainWindow::slotNewConnection() { tcpSocket = tcpServer->nextPendingConnection(); //创建socket connect(tcpSocket, SIGNAL(connected()), this, SLOT(slotClientConnect())); slotClientConnect(); connect(tcpSocket, SIGNAL(disconnected()), this, SLOT(slotClientDisconnect())); connect(tcpSocket, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(slotStateChange(QAbstractSocket::SocketState))); //connect(tcpSocket, &QTcpSocket::stateChanged, this, &MainWindow::slotStateChange); slotStateChange(tcpSocket->state()); connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(slotSocketReadyRead())); } void MainWindow::slotClientConnect() { ui->TextEdit->appendPlainText("客户端已连接"); ui->TextEdit->appendPlainText("peer address:" + tcpSocket->peerAddress().toString()); ui->TextEdit->appendPlainText("peer port:" + QString::number(tcpSocket->peerPort())); } void MainWindow::slotClientDisconnect() { ui->TextEdit->appendPlainText("客户端断开连接"); tcpSocket->deleteLater(); } void MainWindow::slotStateChange(QAbstractSocket::SocketState socketState) { switch (socketState) { case QAbstractSocket::UnconnectedState: labSocketState->setText("未连接"); break; case QAbstractSocket::HostLookupState: labSocketState->setText("HostLookupState"); break; case QAbstractSocket::ConnectingState: labSocketState->setText("ConnectingState"); break; case QAbstractSocket::ConnectedState: labSocketState->setText("ConnectedState"); break; case QAbstractSocket::BoundState: labSocketState->setText("BoundState"); break; case QAbstractSocket::ClosingState: labSocketState->setText("ClosingState"); break; case QAbstractSocket::ListeningState: labSocketState->setText("ListeningState"); break; } } void MainWindow::on_actStop_clicked() { if(tcpServer->isListening()) { if(tcpSocket != nullptr) { if(tcpSocket->state() == QAbstractSocket::ConnectedState) { tcpSocket->disconnectFromHost(); } } tcpServer->close(); ui->actStart->setEnabled(true); ui->actStop->setEnabled(false); labListen->setText("监听状态：已停止监听"); } } void MainWindow::on_send_clicked() { QString msg = ui->lineEdit->text(); ui->TextEdit->appendPlainText("[out]:" + msg); ui->lineEdit->clear(); ui->lineEdit->setFocus(); QByteArray str = msg.toUtf8(); str.append('\n'); tcpSocket->write(str); } void MainWindow::slotSocketReadyRead() { while (tcpSocket->canReadLine()) { ui->TextEdit->appendPlainText("[in]:" + tcpSocket->readLine()); } } void MainWindow::on_clear_clicked() { ui->lineEdit->clear(); ui->TextEdit->clear(); } void MainWindow::on_exit_clicked() { this->close(); }

评论收藏

内容反馈