QT-TCP-server

为了实现高性能的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 datasocket.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 periodicallyQTimer *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 sendsendData();}void onReadyRead() {QByteArray data = socket->readAll();qDebug() << "Received from server:" << data;}void sendData() {QByteArray data = "Hello, Server!"; // Modify as needed for larger payloadssocket->write(data);}private:QTcpSocket *socket;
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);TcpClient client;return a.exec();
}#include "main.moc"