一、TCP和UDP的區別

這裡我會用一個表格來顯示這兩者的區別

二、incomingConnection函式

這個函式和之前講過的newConnection訊號功能差不多，只要有新的連接出現，就會自動呼叫這個函式。

然後我們只需在這個函式中新建一個QTcpSocket物件，並且將這個套接字指定為這個函式的引數socketDescriptor，然後將這個套接字存放到套接字列表中就可以實現多個客戶端同時登陸了。

這裡我們簡單看一下這個函式裡的內容

void Server::incomingConnection(int socketDescriptor)
{
    TcpClientSocket *tcpclientsocket = new TcpClientSocket(this);//只要有新的連線就生成一個新的通訊套接字
    //將新建立的通訊套接字描述符指定為引數socketdescriptor
    tcpclientsocket->setSocketDescriptor(socketDescriptor);

    //將這個套接字加入客戶端套接字列表中
    tcpclientsocketlist.append(tcpclientsocket);

}
 

Server這個類是繼承於QTcpServer類的，所以我們需要在Server類中重寫incomingConnection函式。

三、多個客戶端同時登陸的小聊天室示例。

首先說明一下這個小示例的功能，當有一個客戶端進入聊天室的時候，會向伺服器傳送一個資訊，告訴伺服器這個賬號進入了聊天室， 然後伺服器會在介面中顯示哪個賬號進入了聊天室，並且伺服器會向所有的客戶端傳送訊息，告訴所有客戶端有哪個賬號進入了聊天室。某個賬號傳送資訊的時候也是如此，伺服器會將收到的資訊傳送給所有的客戶端。

如果需要實現網路通訊，就必須在pro檔案中加入 QT += network

伺服器端

在伺服器端需要新增三個類，一個類用來建立介面，一個類用來監聽，這個類的基類是QTcpServer，最後一個類用來通訊，通訊的類的基類是QTcpSocket類。

1、用來建立介面的Tcpserver類

#ifndef TCPSERVER_H
#define TCPSERVER_H

#include <QWidget>
#include "server.h"

namespace Ui {
class TcpServer;
}

class TcpServer : public QWidget
{
    Q_OBJECT

public:
    explicit TcpServer(QWidget *parent = 0);
    ~TcpServer();

private:
    Ui::TcpServer *ui;
    int port;
    Server *server;

protected slots:
    void slotupdateserver(QString, int);//接收到server發過來的訊號就更新介面的資訊


private slots:
    void on_pushButtonCreateChattingRoom_clicked();
};

#endif // TCPSERVER_H
 

#include "tcpserver.h"
#include "ui_tcpserver.h"


TcpServer::TcpServer(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::TcpServer)
{
    ui->setupUi(this);
    port = 8888;

}

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

void TcpServer::on_pushButtonCreateChattingRoom_clicked()
{
    server  = new Server(this, port);
    connect(server, &Server::updateserver, this, &TcpServer::slotupdateserver);
    ui->pushButtonCreateChattingRoom->setEnabled(false);
}

void TcpServer::slotupdateserver(QString msg, int length)
{
    ui->textEdit->append(msg);
}

2、用來監聽的類Server

#ifndef SERVER_H
#define SERVER_H

#include <QTcpServer>
#include <QObject>
#include <QList>
#include "tcpclientsocket.h"

class Server : public QTcpServer
{
    Q_OBJECT //為了實現訊號和槽的通訊
public:
    Server(QObject *parent = 0, int port = 0);
    QList<TcpClientSocket*> tcpclientsocketlist;
protected:
    void incomingConnection(int socketDescriptor);//只要出現一個新的連線，就會自動呼叫這個函式
protected slots:
    void sliotupdateserver(QString, int);//用來處理tcpclient發過來的訊號
    void slotclientdisconnect(int);

signals:
    void updateserver(QString, int);//傳送訊號給介面，讓介面更新資訊

};

#endif // SERVER_H

#include "server.h"
#include <QHostAddress>

Server::Server(QObject *parent, int port):QTcpServer(parent)
{
    listen(QHostAddress::Any, port); //監聽
}

void Server::incomingConnection(int socketDescriptor)
{
    TcpClientSocket *tcpclientsocket = new TcpClientSocket(this);//只要有新的連線就生成一個新的通訊套接字
    //將新建立的通訊套接字描述符指定為引數socketdescriptor
    tcpclientsocket->setSocketDescriptor(socketDescriptor);

    //將這個套接字加入客戶端套接字列表中
    tcpclientsocketlist.append(tcpclientsocket);


    //接收到tcpclientsocket傳送過來的更新介面的訊號
    connect(tcpclientsocket, &TcpClientSocket::updateserver, this, &Server::sliotupdateserver);
    connect(tcpclientsocket, &TcpClientSocket::clientdisconnected, this, &Server::slotclientdisconnect);

}

void Server::sliotupdateserver(QString msg, int length)
{
    //將這個訊號傳送給介面
    emit updateserver(msg, length);

    //將收到的資訊傳送給每個客戶端,從套接字列表中找到需要接收的套接字
    for(int i = 0; i < tcpclientsocketlist.count(); i++)
    {
        QTcpSocket *item = tcpclientsocketlist.at(i);
//        if(item->write((char*)msg.toUtf8().data(), length) != length)
//        {
//            continue;
//        }
        item->write(msg.toUtf8().data());
    }

}

void Server::slotclientdisconnect(int descriptor)
{
    for(int i = 0; i < tcpclientsocketlist.count(); i++)
    {
        QTcpSocket *item = tcpclientsocketlist.at(i);
        if(item->socketDescriptor() == descriptor)
        {
            tcpclientsocketlist.removeAt(i);//如果有客戶端斷開連線， 就將列表中的套接字刪除
            return;
        }
    }
    return;
}

#ifndef TCPCLIENTSOCKET_H
#define TCPCLIENTSOCKET_H

#include <QTcpSocket>

class TcpClientSocket : public QTcpSocket
{
    Q_OBJECT //新增這個巨集是為了實現訊號和槽的通訊
public:
    TcpClientSocket(QObject *parent = 0);
protected slots:
    void receivedata();//處理readyRead訊號讀取資料
    void slotclientdisconnected();//客戶端斷開連線觸發disconnected訊號，這個槽函式用來處理這個訊號

signals:
    void updateserver(QString, int);//用來告訴tcpserver需要跟新介面的顯示
    void clientdisconnected(int); //告訴server有客戶端斷開連線
};

#endif // TCPCLIENTSOCKET_H

#include "tcpclientsocket.h"

TcpClientSocket::TcpClientSocket(QObject *parent)
{
    //客戶端傳送資料過來就會觸發readyRead訊號
    connect(this, &TcpClientSocket::readyRead, this, &TcpClientSocket::receivedata);
    connect(this, &TcpClientSocket::disconnected, this, &TcpClientSocket::slotclientdisconnected);
}

void TcpClientSocket::receivedata()
{
//    while(bytesAvailable() > 0)
//    {
//        int length = bytesAvailable();
//        char buf[1024]; //用來存放獲取的資料
//        read(buf, length);
//        QString msg = buf;
//        //發訊號給介面，讓介面顯示登入者的資訊
//        emit updateserver(msg, length);
//    }
    int length = 10;
    QByteArray array = readAll();
    QString msg = array;
    emit updateserver(msg, length);
}

void TcpClientSocket::slotclientdisconnected()
{
    emit clientdisconnected(this->socketDescriptor());
}

客戶端

客戶端只需要一個類就行了，這個類我們只需要建立一個通訊套接字來和伺服器進行通訊就可以了。

#ifndef TCPCLIENT_H
#define TCPCLIENT_H

#include <QWidget>
#include <QTcpSocket>

namespace Ui {
class TcpClient;
}

class TcpClient : public QWidget
{
    Q_OBJECT

public:
    explicit TcpClient(QWidget *parent = 0);
    ~TcpClient();

private slots:
    void on_pushButtonEnter_clicked();
    void slotconnectedsuccess();//用來處理連線成功的訊號
    void slotreceive();//接收伺服器傳過來的資訊
    void on_pushButtonSend_clicked();
    void slotdisconnected();//用來處理離開聊天室的訊號


private:
    Ui::TcpClient *ui;
    bool status;//用來判斷是否進入了聊天室
    int port;
    QHostAddress *serverIP;
    QString userName;
    QTcpSocket *tcpsocket;
};

#endif // TCPCLIENT_H

#include "tcpclient.h"
#include "ui_tcpclient.h"
#include <QHostAddress>
#include <QMessageBox>

TcpClient::TcpClient(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::TcpClient)
{
    ui->setupUi(this);
    //將進入聊天室的標誌位置為false
    status = false;
    //埠為8888
    port = 8888;
    ui->lineEditServerPort->setText(QString::number(port));//介面中埠預設顯示8888

    serverIP = new QHostAddress();

    //未進入聊天室內不能傳送資訊
    ui->pushButtonSend->setEnabled(false);
}

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

//進入聊天室
void TcpClient::on_pushButtonEnter_clicked()
{
    //首先判斷這個使用者是不是在聊天室中
    if(status == false)
    {
        //不在聊天室中就和伺服器進行連線
        QString ip = ui->lineEditServerIp->text();//從介面獲取ip地址
        if(!serverIP->setAddress(ip))//用這個函式判斷IP地址是否可以被正確解析
        {
            //不能被正確解析就彈出一個警告視窗
            QMessageBox::warning(this, "錯誤", "IP地址不正確");
            return;
        }
        if(ui->lineEditUserName->text() == "")
        {
            //使用者名稱不能為空
            QMessageBox::warning(this, "錯誤", "使用者名稱不能為空");
            return;
        }

        //從介面獲取使用者名稱
        userName = ui->lineEditUserName->text();
        //建立一個通訊套接字，用來和伺服器進行通訊
        tcpsocket = new QTcpSocket(this);

        //和伺服器進行連線
        tcpsocket->connectToHost(*serverIP, port);

        //和伺服器連線成功能會觸發connected訊號
        connect(tcpsocket, &QTcpSocket::connected, this, &TcpClient::slotconnectedsuccess);
        //接收到伺服器的資訊就會觸發readyRead訊號
        connect(tcpsocket, &QTcpSocket::readyRead, this, &TcpClient::slotreceive);



        //將進入聊天室的標誌位置為true；
        status = true;
    }
    else//已經進入了聊天室
    {
        int length = 0;
        QString msg = userName + ":Leave Chat Room";
//        if((length = tcpsocket->write((char*)msg.toUtf8().data(), msg.length())) != msg.length())
//        {
//            return;
//        }
        tcpsocket->write(msg.toUtf8().data());
        tcpsocket->disconnectFromHost();
        status = false;
        //離開聊天室就會觸發disconnected訊號
        connect(tcpsocket, &QTcpSocket::disconnected, this, &TcpClient::slotdisconnected);
    }
}

//用來處理連線成功的訊號
void TcpClient::slotconnectedsuccess()
{
    //進入聊天室可以傳送資訊了
    ui->pushButtonSend->setEnabled(true);
    //將進入聊天的按鈕改為離開聊天室
    ui->pushButtonEnter->setText("離開聊天室");

    int length = 0;
    //將使用者名稱傳送給伺服器
    QString msg= userName + " :Enter Chat Room";

//    if((length = tcpsocket->write((char*)msg.toUtf8().data(), msg.length())) != msg.length())
//    {
//        return;
//    }
    tcpsocket->write(msg.toUtf8().data());
}


void TcpClient::slotreceive()
{
//    while(tcpsocket->bytesAvailable() > 0 )
//    {
//        QByteArray datagram;
//        datagram.resize(tcpsocket->bytesAvailable());
//        tcpsocket->read(datagram.data(), datagram.size());
//        QString msg = datagram.data();
//        ui->textEdit->append(msg.left(datagram.size()));
//    }
    QByteArray array = tcpsocket->readAll();
    ui->textEdit->append(array);
}

void TcpClient::on_pushButtonSend_clicked()
{
    if(ui->lineEditSend->text() == "")
    {
        return;
    }
    QString msg = userName + ":" + ui->lineEditSend->text();
   // tcpsocket->write((char*)msg.toUtf8().data(), msg.length());
    tcpsocket->write(msg.toUtf8().data());
    ui->lineEditSend->clear();
}

void TcpClient::slotdisconnected()
{
    ui->pushButtonSend->setEnabled(false);
    ui->pushButtonEnter->setText("進入聊天室");
}

編譯完之後執行的介面就是這樣的

整個通訊的步驟

【注】這裡伺服器的說明用藍色的字標識出來，客戶端用紫色標識。

首先我們點選伺服器的建立聊天室，TcpServer類的中的相應的槽函式會建立一個Server類的物件，然後呼叫建構函式會進行監聽。一旦有客戶端點選進入聊天室的按鈕，客戶端的tcpsocket就會和伺服器進行連線，只要伺服器監聽到新的連線，Server類物件就會自動呼叫incomingConnection(int socketDescripter)這個函式。接著我們只需要在這個函式中建立一個通訊套接字也就是TcpClientSocket物件，並且將這個套接字描述符設定為引數socketDescripter，然後將這個套接字加入套接字列表中。這個時候客戶端和伺服器連線成功了，客戶端就會觸發一個connected訊號，需要我們寫一個槽函式來處理這個訊號，這裡的處理就是將這個使用者名稱和“Enter Chat Room”傳送給伺服器。伺服器一旦收到資訊，就會觸發readyRead訊號，這個時候我們需要在寫一個相應的槽函式來讀取套接字中的資訊。我們這裡是用readall來讀取套接字中的所有資訊。當收到資料的時候，我們需要發一個訊號給Server，將讀取的資訊再發送給所有在聊天室裡的使用者，所以在Server類中要新增一個相應的槽函式來將資料傳送給所有的使用者。因為同時需要在伺服器介面中顯示所有使用者發過來的訊息，所以需要在剛剛那個槽函式中將自己定義的一個訊號傳送給TcpServer類，讓其將收到的訊息顯示在介面中。客戶端收到訊息之後也會觸發readyRead訊號，客戶端只需要將從套接字中讀取的訊息顯示在見面中就行了。客戶端傳送訊息的時候需要從QLineEdit物件中讀取內容，然後通過tcpsocket->write()函式將訊息傳送給伺服器就行了。伺服器同樣會將收到的資訊傳送給所有的使用者，同時顯示在自己的介面中。最後客戶端退出聊天室，客戶端點選離開聊天室按鈕，進入相應的槽函式中呼叫disconnectFromHost()函式，就會和伺服器斷開連線，一旦有呼叫了這個函式，就會觸發disconnected訊號，然後我們需要寫一個相應的槽函式來處理這個訊號，我們所做的處理就是將這個使用者名稱和“Leave Chat Roo”傳送給伺服器。伺服器那一端檢測到有客戶端斷開連線也會觸發disconnected訊號，這個時候我們需要將套接字列表中將對應的套接字刪除就可以了。