Qt Tcp服務器程序（可群發消息，定向IP發送消息）

1、用到的頭文件

#include<QTcpServer>
#include<QTcpSocket>
#include<QHostAddress>

　　

2、pro文件添加 QT += network

 

3、創建QTcpSocket的子類，tcpClient，用於接收客戶端行為

#ifndef CLIENT_H
#define CLIENT_H

#include<QTcpSocket>

class Client : public QTcpSocket
{
    Q_OBJECT
public:
    Client(QObject * parent = 0);

protected slots:
    void receiveData();     // signal readyRead() 觸發該槽
    void slotClientDisconnected();      // signal disconnected() 觸發該槽

signals:
    void updateServer(QString);     // 該信號發送給tcpServer類
    void clientDisconnected(qintptr);   // 該信號發送給tcpServer類
};

#endif // CLIENT_H

#include "tcpClient.h"

Client::Client(QObject * parent):QTcpSocket(parent)
{
    connect(this,&QTcpSocket::readyRead,this,&Client::receiveData);
    connect(this,&QTcpSocket::disconnected,this,&Client::slotClientDisconnected);

}

void Client::receiveData()
{
    QByteArray array = readAll();
    QString msg = array;
    emit updateServer(msg);
}

void Client::slotClientDisconnected()
{
    emit clientDisconnected(this->socketDescriptor());
}

 

 4、創建QTcpServer的子類，tcpServer，用於更新客戶端連接、與tcpClient交互等等

#ifndef SERVER_H
#define SERVER_H

#include<QTcpServer>
#include<QTcpSocket>
#include<QHostAddress>
#include<QList>
#include"tcpClient.h"

class Server : public QTcpServer
{
    Q_OBJECT
public:
    Server(QObject *parent = 0 ,QString IP = "" ,quint16 port = 0);
    QTcpSocket * deleteSocket;
    quint16 qlistCount();
    void sendMessage(QByteArray msg, int i);

protected:
    void incomingConnection(qintptr socketDescriptor) override;     // 只要出現一個新的連接，就會自動調用這個函數
    QList<QTcpSocket*>clientList;
    Client * client;
    QTcpSocket * temp;

protected slots:
    void slotUpdateServer(QString);     // signal來自tcpClient
    void slotClientDisconnected(qintptr);   // signal來自tcpClient
signals:
    void updateServer(QString);     // 該信號發送給文本框
    void newClientInfo(QHostAddress clientAddress,quint16 port);    // 該信號發送給文本框
    void deleteClient(QHostAddress clientAddress,quint16 port);     // 該信號發送給文本框

private:


};

#endif // SERVER_H

#include "tcpServer.h"
#include<QDebug>

Server::Server(QObject *parent, QString IP ,quint16 port):QTcpServer(parent)
{
    QHostAddress address(IP);
    this->listen(address,port);
}

quint16 Server::qlistCount()
{
    return clientList.count();
}

void Server::sendMessage(QByteArray msg, int i)
{
    temp = new QTcpSocket(this);
    temp = clientList.at(i);
    temp->write(msg);
}

void Server::incomingConnection(qintptr socketDescriptor)
{
    client = new Client(this);

    //將新創建的通信套接字描述符指定為參數socketdescriptor
    client->setSocketDescriptor(socketDescriptor);
//    qDebug()<<socketDescriptor<<QString::fromLocal8Bit("連接");
    // 將這個套接字加入客戶端套接字列表中
    clientList.append(client);

    emit newClientInfo(client->peerAddress(),client->peerPort());
//    qDebug()<<client->peerAddress()<<client->peerPort();


    connect(client,&Client::updateServer,this,&Server::slotUpdateServer);
    connect(client,&Client::clientDisconnected,this,&Server::slotClientDisconnected);
}

void Server::slotUpdateServer(QString msg)
{
    // 將這個信號發送給文本框
    emit updateServer(msg);
}

void Server::slotClientDisconnected(qintptr socketDescriptor)
{
    // 判斷斷開的客戶端，並將其從表中移除
    for(int i = 0; i< clientList.count(); i++)
    {
        deleteSocket = clientList.at(i);
        if(socketDescriptor == deleteSocket->socketDescriptor())
        {
            emit deleteClient(deleteSocket->peerAddress(),deleteSocket->peerPort());
//            qDebug()<<deleteSocket->peerAddress()<<deleteSocket->peerPort()
//                   <<QString::fromLocal8Bit("斷開");
            clientList.removeAt(i);
            return;
        }
    }
}

 

**注意

incomingConnection是虛函數，必須繼承重寫

 

5、創建一個管理類，tcp_Server，用於界面交互整合信息等等

界面：