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，用于界面交互整合信息等等

界面：