在Qt中实现HTTP服务端通讯,可以使用Qt提供的QTcpServer类和相关类来完成。具体步骤如下:
- 创建一个QTcpServer对象,并监听指定端口。
QTcpServer *server = new QTcpServer(this);
if (!server->listen(QHostAddress::Any, 8080)) {
qDebug() << "Error: " << server->errorString();
}
else {
connect(server, SIGNAL(newConnection()), this, SLOT(newConnection()));
}
- 当有新的客户端连接时,会触发newConnection信号,可以在该槽函数中获取对应的QTcpSocket对象进行处理。
void Server::newConnection()
{
while (server->hasPendingConnections()) {
QTcpSocket *socket = server->nextPendingConnection();
connect(socket, SIGNAL(readyRead()), this, SLOT(readClient()));
connect(socket, SIGNAL(disconnected()), socket, SLOT(deleteLater()));
}
}
- 当收到客户端发送的请求数据时,会触发readyRead信号。在该槽函数中可以获取请求数据并进行处理。
void Server::readClient()
{
QTcpSocket *socket = qobject_cast<QTcpSocket*>(sender());
if (!socket)
return;
QByteArray requestData = socket->readAll();
// 对请求数据进行处理
QByteArray responseData = "HTTP/1.1 200 OK\r\nContent-Type: text/html; charset=UTF-8\r\n\r\n<html><body>Hello World!</body></html>";
socket->write(responseData);
}
完整代码示例:
#include <QtNetwork>
#include <QDebug>
class Server : public QObject
{
Q_OBJECT
public:
Server(QObject *parent = nullptr) : QObject(parent)
{
server = new QTcpServer(this);
if (!server->listen(QHostAddress::Any, 8080)) {
qDebug() << "Error: " << server->errorString();
}
else {
connect(server, SIGNAL(newConnection()), this, SLOT(newConnection()));
}
}
private slots:
void newConnection()
{
while (server->hasPendingConnections()) {
QTcpSocket *socket = server->nextPendingConnection();
connect(socket, SIGNAL(readyRead()), this, SLOT(readClient()));
connect(socket, SIGNAL(disconnected()), socket, SLOT(deleteLater()));
}
}
void readClient()
{
QTcpSocket *socket = qobject_cast<QTcpSocket*>(sender());
if (!socket)
return;
QByteArray requestData = socket->readAll();
// 对请求数据进行处理
QByteArray responseData = "HTTP/1.1 200 OK\r\nContent-Type: text/html; charset=UTF-8\r\n\r\n<html><body>Hello World!</body></html>";
socket->write(responseData);
}
private:
QTcpServer *server;
};
int main(int argc, char *argv[])
{
QCoreApplication app(argc, argv);
Server server;
return app.exec();
}
#include "main.moc"