Qt實現簡單的TCP通訊

2022-08-19 18:00:50

這段時間用到了QT的TCP通訊，做了初步的學習與嘗試，編寫了一個使用者端和伺服器基於視窗通訊的小例程。

使用QT的網路通訊端需要.pro檔案中加入一句：

QT += network

一、使用者端

1、使用者端的程式碼比伺服器稍簡單，總的來說，使用QT中的QTcpSocket類與伺服器進行通訊只需要以下5步：

（1）建立QTcpSocket通訊端物件

socket = new QTcpSocket();

（2）使用這個物件連線伺服器

socket->connectToHost(IP, port);

（3）使用write函數向伺服器傳送資料

socket->write(data);

（4）當socket接收緩衝區有新資料到來時，會發出readRead()訊號，因此為該訊號新增槽函數以讀取資料

QObject::connect(socket, &QTcpSocket::readyRead, this, &MainWindow::socket_Read_Data);
  
 void MainWindow::socket_Read_Data()
 {
     QByteArray buffer;
     //讀取緩衝區資料
     buffer = socket->readAll();
 }

（5）斷開與伺服器的連線（關於close()和disconnectFromHost()的區別，可以按F1看幫助）

socket->disconnectFromHost();

2、以下是使用者端的例程

首先是mainwindow.h檔案：

 //mainwindow.h
 #ifndef MAINWINDOW_H
 #define MAINWINDOW_H
  
 #include <QMainWindow>
 #include <QTcpSocket>
  
 namespace Ui {
 class MainWindow;
 }
  
 class MainWindow : public QMainWindow
 {
     Q_OBJECT
  
 public:
     explicit MainWindow(QWidget *parent = 0);
     ~MainWindow();
  
 private slots:
  
     void on_pushButton_Connect_clicked();
  
     void on_pushButton_Send_clicked();
  
     void socket_Read_Data();
  
     void socket_Disconnected();
  
 private:
     Ui::MainWindow *ui;
     QTcpSocket *socket;
 };
  
#endif // MAINWINDOW_H

然後是mainwindow.cpp檔案：

//mainwindow.cpp
 #include "mainwindow.h"
 #include "ui_mainwindow.h"
  
 MainWindow::MainWindow(QWidget *parent) :
     QMainWindow(parent),
     ui(new Ui::MainWindow)
 {
     ui->setupUi(this);
  
     socket = new QTcpSocket();
  
     //連線訊號槽
     QObject::connect(socket, &QTcpSocket::readyRead, this, &MainWindow::socket_Read_Data);
     QObject::connect(socket, &QTcpSocket::disconnected, this, &MainWindow::socket_Disconnected);
  
     ui->pushButton_Send->setEnabled(false);
     ui->lineEdit_IP->setText("127.0.0.1");
     ui->lineEdit_Port->setText("8765");
  
 }
  
 MainWindow::~MainWindow()
 {
     delete this->socket;
     delete ui;
 }
  
 void MainWindow::on_pushButton_Connect_clicked()
 {
     if(ui->pushButton_Connect->text() == tr("連線"))
     {
         QString IP;
         int port;
  
         //獲取IP地址
         IP = ui->lineEdit_IP->text();
         //獲取埠號
         port = ui->lineEdit_Port->text().toInt();
  
         //取消已有的連線
         socket->abort();
         //連線伺服器
         socket->connectToHost(IP, port);
  
         //等待連線成功
         if(!socket->waitForConnected(30000))
         {
             qDebug() << "Connection failed!";
             return;
         }
         qDebug() << "Connect successfully!";
  
         //傳送按鍵使能
         ui->pushButton_Send->setEnabled(true);
         //修改按鍵文字
         ui->pushButton_Connect->setText("斷開連線");
     }
     else
     {
         //斷開連線
         socket->disconnectFromHost();
         //修改按鍵文字
         ui->pushButton_Connect->setText("連線");
         ui->pushButton_Send->setEnabled(false);
     }
 }
  
 void MainWindow::on_pushButton_Send_clicked()
 {
     qDebug() << "Send: " << ui->textEdit_Send->toPlainText();
      //獲取文字方塊內容並以ASCII碼形式傳送
     socket->write(ui->textEdit_Send->toPlainText().toLatin1());
     socket->flush();
 }
  
 void MainWindow::socket_Read_Data()
 {
     QByteArray buffer;
     //讀取緩衝區資料
     buffer = socket->readAll();
     if(!buffer.isEmpty())
     {
         QString str = ui->textEdit_Recv->toPlainText();
         str+=tr(buffer);
         //重新整理顯示
         ui->textEdit_Recv->setText(str);
     }
 }
  
 void MainWindow::socket_Disconnected()
 {
     //傳送按鍵失能
     ui->pushButton_Send->setEnabled(false);
     //修改按鍵文字
     ui->pushButton_Connect->setText("連線");
     qDebug() << "Disconnected!";
 }

最後是ui的設計：

二、伺服器

1、伺服器除了使用到了QTcpSocket類，還需要用到QTcpSever類。即便如此，也只是比使用者端複雜一點點，用到了6個步驟：

（1）建立QTcpSever物件

server = new QTcpServer();

（2）偵聽一個埠，使得使用者端可以使用這個埠存取伺服器

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

（3）當伺服器被使用者端存取時，會發出newConnection()訊號，因此為該訊號新增槽函數，並用一個QTcpSocket物件接受使用者端存取

 connect(server,&QTcpServer::newConnection,this,&MainWindow::server_New_Connect);
  
 void MainWindow::server_New_Connect()
 {
     //獲取使用者端連線
     socket = server->nextPendingConnection();
 }

（4）使用socket的write函數向用戶端傳送資料

socket->write(data);

（5）當socket接收緩衝區有新資料到來時，會發出readRead()訊號，因此為該訊號新增槽函數以讀取資料

 QObject::connect(socket, &QTcpSocket::readyRead, this, &MainWindow::socket_Read_Data);
  
 void MainWindow::socket_Read_Data()
 {
     QByteArray buffer;
     //讀取緩衝區資料
     buffer = socket->readAll();
 }

（6）取消偵聽

server->close();

2、以下是伺服器的例程