QT-TCP-server

news2025/1/9 12:21:57

为了实现高性能的TCP通讯，以下是一个基于Qt的示例，展示如何利用多个线程、非阻塞I/O、数据分块和自定义协议进行优化。该示例以TCP服务器和客户端的形式展示，能够承受高负载并实现快速数据传输。

高性能TCP Server示例

#include <QTcpServer>
#include <QTcpSocket>
#include <QThread>
#include <QCoreApplication>
#include <QDebug>

class ClientHandler : public QThread {
    Q_OBJECT
public:
    ClientHandler(qintptr socketDescriptor, QObject *parent = nullptr)
        : QThread(parent), socketDescriptor(socketDescriptor) {}

    void run() override {
        QTcpSocket socket;
        if (!socket.setSocketDescriptor(socketDescriptor)) {
            qCritical() << "Failed to set socket descriptor.";
            return;
        }

        connect(&socket, &QTcpSocket::readyRead, this, [&]() {
            while (socket.bytesAvailable()) {
                QByteArray data = socket.readAll();
                qDebug() << "Received:" << data;

                // Echo back data
                socket.write("Echo: " + data);
            }
        });

        connect(&socket, &QTcpSocket::disconnected, &socket, &QTcpSocket::deleteLater);
        exec(); // Start the event loop
    }

private:
    qintptr socketDescriptor;
};

class TcpServer : public QTcpServer {
    Q_OBJECT
public:
    TcpServer() {
        connect(this, &QTcpServer::newConnection, this, &TcpServer::onNewConnection);
    }

private slots:
    void onNewConnection() {
        qintptr socketDescriptor = nextPendingConnection()->socketDescriptor();
        ClientHandler *handler = new ClientHandler(socketDescriptor);
        handler->start(); // Start handling client connection in a new thread
    }
};

int main(int argc, char *argv[]) {
    QCoreApplication a(argc, argv);
    TcpServer server;

    if (server.listen(QHostAddress::Any, 1234)) {
        qDebug() << "Server started on port 1234";
    } else {
        qCritical() << "Server could not start!";
    }

    return a.exec();
}

#include "main.moc"

高性能TCP Client示例

#include <QTcpSocket>
#include <QCoreApplication>
#include <QDebug>
#include <QTimer>

class TcpClient : public QObject {
    Q_OBJECT
public:
    TcpClient() {
        socket = new QTcpSocket(this);
        connect(socket, &QTcpSocket::connected, this, &TcpClient::onConnected);
        connect(socket, &QTcpSocket::readyRead, this, &TcpClient::onReadyRead);
        socket->connectToHost("127.0.0.1", 1234);

        // Send data periodically
        QTimer *timer = new QTimer(this);
        connect(timer, &QTimer::timeout, this, &TcpClient::sendData);
        timer->start(1000); // Adjust interval as needed
    }

private slots:
    void onConnected() {
        qDebug() << "Connected to server";
        // Initial data send
        sendData();
    }

    void onReadyRead() {
        QByteArray data = socket->readAll();
        qDebug() << "Received from server:" << data;
    }

    void sendData() {
        QByteArray data = "Hello, Server!"; // Modify as needed for larger payloads
        socket->write(data);
    }

private:
    QTcpSocket *socket;
};

int main(int argc, char *argv[]) {
    QCoreApplication a(argc, argv);
    TcpClient client;
    return a.exec();
}

#include "main.moc"