QT httpServer多线程后台服务器的例子实现

1.需求

1.1 用户需要其他平台（web端）调用Qt平台的接口，获取想要的数据并实时显示在网页里，比如实时的温湿度，用户数据等

1.2 用户需要在其他平台（web端）调用Qt平台的接口，下发数据给本地QT客户端显示，如下发用户数据，下发任务等

2.解决方案

这是就需要一个类似httpServer的服务端了，实时监听端口，随时接收web平台的请求，根据请求内容，接收平台下发的数据并存储到本地客户端显示，或者根据请求，上传需要的信息给web平台

现成的接口是没有的，需要自己写，底层本质都是基于QWebServer加上多线程封装实现的，轮子是已经有的，已经造好了，我们用就行了，想深入了解的，可以看源码的实现

我就挂在下面的链接里了，开源的Qt httpServer代码，里面有很多

链接: https://pan.baidu.com/s/1SHqSCGiGQblur69oCz_LXg?pwd=1234 提取码: 1234 

 3. 实现

建立一个WebServerApi的工程项目，没有界面的，一般后台服务都是没有界面的，更加轻便，反应快，可以建立控制台项目或者动态库/插件库，都可以，我这里用来演示，就用控制台项目演示了

建好工程项目后，在有了已经写好的轮子基础上，就简单了，先把需要的httpServer文件引入程序目录里

然后建一个WebApi1的类，用来表示一个接口类，专门处理Api1接口的内容

#ifndef WEBAPI1_H
#define WEBAPI1_H

#include "httprequesthandler.h"
using namespace stefanfrings;

class WebApi1: public HttpRequestHandler
{
public:
    WebApi1(QObject *parent = nullptr);
    void service(HttpRequest &request, HttpResponse &response) override;
    QJsonObject changeByteArrayToJsonObject(const QByteArray &ba);
};

#endif // WEBAPI1_H

#include "webapi1.h"
#include <QJsonObject>
#include <QJsonDocument>


WebApi1::WebApi1(QObject *parent)
{

}

void WebApi1::service(HttpRequest &request, HttpResponse &response)
{
    QString path = request.getPath();
    QStringList pathList = path.split("/");
    //QString interfaceName = pathList.value(3);
    if (pathList.size()<3) {
        this->returnError(response);
        return;
    }
    QString method = pathList.value(3);
    QByteArray responseMsg;

    if(method == "getUserInfo") {
        QJsonObject obj;
        obj.insert("name", "小明");
        obj.insert("age", 18);
        obj.insert("success", true);
        responseMsg =  QJsonDocument(obj).toJson();
    }
    else if(method == "setUserInfo") {
        auto recvData = request.getBody();
        QJsonObject data = changeByteArrayToJsonObject(recvData);

        QString name = data.value("name").toString();
        int age = data.value("name").toInt();
        qDebug()<<QString("收到平台下发用户信息，name:%1，age:%2").arg(name).arg(age);

        QJsonObject obj;
        obj.insert("success", true);
        responseMsg =  QJsonDocument(obj).toJson();
    }
    else {
        QJsonObject obj;
        obj.insert("error", "没有这个方法");
        obj.insert("success", false);
        responseMsg =  QJsonDocument(obj).toJson();
    }

    response.write(responseMsg);
}

QJsonObject WebApi1::changeByteArrayToJsonObject(const QByteArray &ba)
{
    // 将数据转化成json内容
    QJsonParseError jsonpe;
    QJsonDocument json = QJsonDocument::fromJson(ba, &jsonpe);
    if (jsonpe.error == QJsonParseError::NoError) {
        if (json.isObject()) {
            QJsonObject obj = json.object();
            if (obj.contains("error")) {
                qDebug() << "error:" << obj["error"];
                return QJsonObject();
            } else {
                return obj;
            }
        } else {
            qDebug() << "error, shoud json object";
            return QJsonObject();
        }
    } else {
        qDebug() << "error:" << jsonpe.errorString();
        return QJsonObject();
    }
}

然后在建一个WebApi2的接口类，同上，名字不一样而已，我用来演示

在建一个RequestMapper类，用来做请求映射的管理，也就是对于每一个不同类型接口，可以根据定义好的类型来做出相应的处理，内容如下：

#ifndef REQUESTMAPPER_H
#define REQUESTMAPPER_H

#include "httprequesthandler.h"

using namespace stefanfrings;

class RequestMapper : public HttpRequestHandler
{
public:
    RequestMapper(QObject *parent = nullptr);

    ~RequestMapper() override;

    void service(HttpRequest &request, HttpResponse &response) override;

private:
    QHash<QString, HttpRequestHandler *> m_requestMap;

};

#endif // REQUESTMAPPER_H

#include "requestmapper.h"
#include <QDateTime>
#include "webapi1.h"
#include "webapi2.h"

RequestMapper::RequestMapper(QObject *parent)
{
    m_requestMap.insert("WebApi1", new WebApi1(this));
    m_requestMap.insert("WebApi2", new WebApi2(this));
}

RequestMapper::~RequestMapper() {
    qDeleteAll(m_requestMap);
    m_requestMap.clear();
}

void RequestMapper::service(HttpRequest &request, HttpResponse &response) {
    response.setHeader("Access-Control-Allow-Origin", "*");
    response.setHeader("Access-Control-Allow-Credentials", "true");
    response.setHeader("P3P", "CP=CAO PSA OUR");
    if (!request.getHeader("Access-Control-Request-Method").isNull() && request.getMethod() == "OPTIONS") {
        response.setHeader("Access-Control-Allow-Methods", "POST,GET,TRACE,OPTIONS");
        response.setHeader("Access-Control-Allow-Headers", "Content-Type,Origin,Accept");
        response.setHeader("Access-Control-Max-Age", 86400);
    }
    response.setHeader("Content-Type", "application/json;charset=utf-8");
    response.setHeader("Date", QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss").toUtf8());
    QString path = request.getPath();
    QStringList pathList = path.split("/");
    // 因为path以/为开头，使用split，第一个元素为空串
    if (pathList.size() < 3+1) {
        this->returnError(response);
        return;
    }
    if (pathList.value(1) != "Stms") {
        this->returnError(response);
        return;
    }
    // 如请url后缀为 /test/Stms/WebApi1

    HttpRequestHandler *handler = m_requestMap.value(pathList.value(2));
    if (handler != nullptr) {
        handler->service(request, response);
    } else {
        this->returnError(response);
    }
}

在建立一个WebApiManager的管理类，内容如下
#ifndef WEBAPIMANAGER_H
#define WEBAPIMANAGER_H

#include <QObject>

class WebApiManager: public QObject
{
public:
    WebApiManager(QObject *parent = nullptr);

    void init();
};


#endif // WEBAPIMANAGER_H

#include "webapimanager.h"
#include "requestmapper.h"
#include "httplistener.h"
#include "httpsessionstore.h"
#include "staticfilecontroller.h"
#include <QCoreApplication>
#include <QSettings>

StaticFileController* s_staticFileController = nullptr;

using namespace stefanfrings;

WebApiManager::WebApiManager(QObject *parent): QObject(parent)
{

}

void WebApiManager::init()
{
    QString configFileName = QCoreApplication::applicationDirPath() + "/config/WebConfig.ini";

    // Configure logging into a file
//    QSettings *logSettings = new QSettings(configFileName, QSettings::IniFormat, this);
//    logSettings->beginGroup("logging");
//    auto logger = new FileLogger(logSettings, 10000, this);
//#ifndef QT_DEBUG
//    logger->installMsgHandler();
//#endif

    // Configure session store
    QSettings *sessionSettings = new QSettings(configFileName, QSettings::IniFormat, this);
    sessionSettings->beginGroup("sessions");
    new HttpSessionStore(sessionSettings, this);

    // Configure static file controller
    //    QSettings *fileSettings = new QSettings(configFileName, QSettings::IniFormat, this);
    //    fileSettings->beginGroup("docroot");
    //    s_staticFileController = new StaticFileController(fileSettings, this);

    // Configure and start the TCP listener
    QSettings *listenerSettings = new QSettings(configFileName, QSettings::IniFormat, this);
    listenerSettings->beginGroup("listener");
    new HttpListener(listenerSettings, new RequestMapper(this), this);
}

 在init()的函数中，初始化了webServer的配置信息，这里用的是配置文件（WebConfig.ini）的方式进行配置，如监听的端口，还有一些其他的配置 

配置文件内容如下，可配置监听的端口，线程数等，还有其他的信息不就不解析了，想知道的可以去查

[listener]
host=0.0.0.0
#监听端口
port=8080
#最小线程数量
minThreads=4
#最大线程数量
maxThreads=100
#自动清理延时
cleanupInterval=60000
#读取超时时长
readTimeout=60000
#证书秘钥文件
#sslKeyFile=../../static/certChain/devkey.pem
#证书文件
#sslCertFile=../../static/certChain/devcert.pem
#最大请求长度
maxRequestSize=500000
#最大多包大小
maxMultiPartSize=10000000

[templates]
path=templates
suffix=.tpl
encoding=UTF-8
cacheSize=1000000
cacheTime=60000

[docroot]
#页面静态内容位置
path=../../static
#编码
encoding=UTF-8
#cookie存活时间
maxAge=60000
#缓存保持时间
cacheTime=60000
#缓存大小
cacheSize=1000000
#最大单个缓存文件大小
maxCachedFileSize=65536

[sessions]
#session超时时间
expirationTime=600000
#默认cookie名称
cookieName=sessionid
#默认cookie地址
cookiePath=/
#默认cookie说明
cookieComment=Identifies the user
;cookieDomain=stefanfrings.de

[logging]
; The logging settings become effective after you comment in the related lines of code in main.cpp.
#log输出路径
fileName=../../logs/webRuntime.log
#最小输出等级（0=DEBUG, 1=WARNING, 2=CRITICAL, 3=FATAL, 4=INFO）
minLevel=1
#缓冲区大小
bufferSize=100
#日志文件大小
maxSize=1000000
#日志最大备份数量
maxBackups=2
#日志时间格式
timestampFormat=yyyy-MM-dd hh:mm:ss.zzz
;msgFormat={timestamp} {typeNr} {type} {thread} {msg}
#日志内容格式
msgFormat={timestamp} {typeNr} {type} {thread} {msg}\n  in {file} line {line} function {function}
; QT5 supports: msgFormat={timestamp} {typeNr} {type} {thread} {msg}\n  in {file} line {line} function {function}


[socketserver]
host=127.0.0.1
port=8160

记得把文件放在程序目录下

编译运行启动程序，监听端口

然后用浏览器请求这个服务器，获取想要的内容

这个多线程好用的httpserver就弄好了，不怎么懂的，可以断点调试，慢慢理解，提升蛮大的

有什么不懂的，可以评论区留言

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/584462.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

使用 GitHub Actions 实现项目的持续集成(CI)

使用 GitHub Actions 实现项目的持续集成(CI)

目录 什么是 GitHub Actions 基础概念 Workflow 文件 Workflow 语法 实例&#xff1a;编译 OpenWrt 什么是 GitHub Actions GitHub Actions 是 GitHub 推出的持续集成&#xff08;Continuous Integration&#xff0c;简称 CI&#xff09;服务它允许你创建自定义工作流&am…
阅读更多...
【webrtc】MessageHandler 3： 基于线程的消息处理：以sctp测试为例

【webrtc】MessageHandler 3： 基于线程的消息处理：以sctp测试为例

消息处理可以用于模拟发包处理G:\CDN\rtcCli\m98\src\net\dcsctp\socket\dcsctp_socket_network_test.cc 这个实现中，onMessage还是仅对了一种消息进行处理，就是接收则模式下，打印带宽。当然，可能程序有多个消息，分别在不同的onmessage中执行？SctpActor：以一个恒定的速率…
阅读更多...
【webrtc】MessageHandler 1： 基于线程的消息处理：以10毫秒处理音频为例

【webrtc】MessageHandler 1： 基于线程的消息处理：以10毫秒处理音频为例

基于m98 G:\CDN\rtcCli\m98\src\audio\null_audio_poller.h分发的消息由MessageHandler 类通过其抽象接口OnMessage 实现处理 NullAudioPoller NullAudioPoller 是一个处理audio的消息的分发器 poll 启动：
阅读更多...
Adobe Firefly 3.0 AI 图像生成器来了

Adobe Firefly 3.0 AI 图像生成器来了

Adobe 发布其 Midjourney 和 Dall-E 3 竞争对手Firefly 2.0已经半年了。几天前&#xff0c;他们发布了Firefly 3.0&#xff08;目前处于测试阶段&#xff09;&#xff0c;这是他们最新的文本到图像人工智能工具&#xff0c;其中包含一些非常酷的更新。在我们深入了解细节之前&a…
阅读更多...
开发一个语音聊天社交app小程序H5需要多少钱？

开发一个语音聊天社交app小程序H5需要多少钱？

社交&#xff0c;即时通讯APP系统。如何开发一个社交App||开发一个即时通信应用是一项复杂而充满挑战的任务&#xff0c;需要考虑多个技术、开发时间和功能方面的因素。以下是一个概要&#xff0c;描述了从技术、开发时间和功能角度如何开发这样的应用&#xff1a; 1. 技术要点…
阅读更多...
Docker-compose的介绍与用法

Docker-compose的介绍与用法

Docker-compose Docker Compose 是一个开源的容器编排工具&#xff0c;由 Docker 官方开发。它允许开发者定义一个或多个 Docker 容器作为单个服务&#xff0c;并将这些服务组合成一个项目。这些定义被保存在一个 YAML 文件中&#xff0c;称为 docker-compose.yml。 使用 Dock…
阅读更多...
低代码技术在构建质量管理系统中的应用与优势

低代码技术在构建质量管理系统中的应用与优势

引言 在当今快节奏的商业环境中&#xff0c;高效的质量管理系统对于组织的成功至关重要。质量管理系统帮助组织确保产品或服务符合客户的期望、符合法规标准&#xff0c;并持续改进以满足不断变化的需求。与此同时&#xff0c;随着技术的不断进步&#xff0c;低代码技术作为一…
阅读更多...
Qt下使用7Z源码进行压缩和解压缩

Qt下使用7Z源码进行压缩和解压缩

7Z压缩是一款常用的压缩算法和工具&#xff0c;本文主要介绍一款在qt环境下进行编译的压缩方法。 本人测试是可以正常跑通的&#xff0c;具体代码部分请下载&#xff1a;下载链接&#xff0c;提取码&#xff1a;ev9t 7z源码网址&#xff1a;7-Zip 7z简介&#xff1a; 7z 是…
阅读更多...
一文带你了解5款高效率软件，建议收藏

一文带你了解5款高效率软件，建议收藏

​ 人类与99%的动物之间最大差别在于是否会运用工具&#xff0c;借助好的工具&#xff0c;能提升几倍的工作效率。 1. 高速文件复制——TeraCopy ​ TeraCopy是一款高效的文件复制工具&#xff0c;可以大幅度提高文件复制和移动的速度。它支持多线程复制、错误恢复、校验和等…
阅读更多...
2024-04学习笔记

2024-04学习笔记

1.sql优化-子查询改为外连接 1.改之前 改之前是这样&#xff0c;那针对查出来的每一条数据&#xff0c;都要执行一次箭头所指的函数 执行的sql很慢 2.改之后 改之后是这样&#xff0c;整体做外连接&#xff0c;不用每一条都再执行一次查询 执行时间缩短了好几倍 2.Mybatis中…
阅读更多...
maven修改默认编码格式为UTF-8

maven修改默认编码格式为UTF-8

执行mvn -version查看maven版本信息发现&#xff0c;maven使用的编码格式为GBK。 为什么想到要修改编码格式呢&#xff1f;因为idea中我将文件格式统一设置为UTF-8&#xff08;如果不知道如何修改文件编码&#xff0c;可以参考文末&#xff09;&#xff0c;然后使用maven打包时…
阅读更多...
ubuntu22 部署fastDFS单节点和集群，整合Spring Boot（刚部署成功）

ubuntu22 部署fastDFS单节点和集群，整合Spring Boot（刚部署成功）

ubuntu22 部署fastDFS单节点和集群 一、先准备1、所需依赖安装2、下载安装包 二、安装FastDFS单节点1、libfastcommon安装1.1、创建软连接 2、安装fastDFS2.1、fastDFS目录简单介绍2.2、创建软连接 3、配置和启动Tracker服务3.1、修改Tracker配置文件3.2、启动Tracker 4、配置和…
阅读更多...
字节码插桩 -- 入门篇

字节码插桩 -- 入门篇

背景 我们先了解下什么情况下会用到字节码插桩。学技术并不是为了秀技术&#xff0c;而是为了解决业务问题。 我们先想象一个业务场景— 我们需要统计耗时方法&#xff0c;这时&#xff0c;我们会怎么做&#xff1f; 在每个方法开头和结尾处分别记录开始时间与结束时间&…
阅读更多...
学生管理系统[Python语言]

学生管理系统[Python语言]

各位大佬好 &#xff0c;这里是阿川的博客 &#xff0c; 祝您变得更强 个人主页&#xff1a;在线OJ的阿川 大佬的支持和鼓励&#xff0c;将是我成长路上最大的动力 阿川水平有限&#xff0c;如有错误&#xff0c;欢迎大佬指正 学生管理系统是计算机专业最基础的一个作业&#…
阅读更多...
高扬程水泵，提升水源新选择！— 恒峰智慧科技

高扬程水泵，提升水源新选择！— 恒峰智慧科技

在炎炎夏日&#xff0c;阳光炙烤着大地&#xff0c;森林火灾的发生频率也随之上升。火势猛烈&#xff0c;烟雾弥漫&#xff0c;给森林带来了极大的破坏。为了保护森林资源&#xff0c;我们必须采取有效的措施来扑灭火灾。而在这其中&#xff0c;高扬程水泵成为了提升水源新选择…
阅读更多...
智慧旅游驱动行业革新：智能技术引领服务全面升级，匠心打造高品质、个性化旅游新体验

智慧旅游驱动行业革新：智能技术引领服务全面升级，匠心打造高品质、个性化旅游新体验

一、引言 随着科技的飞速发展和信息化程度的不断提高&#xff0c;智慧旅游正逐渐成为旅游业发展的新趋势。智慧旅游&#xff0c;顾名思义&#xff0c;是以智能化技术为支撑&#xff0c;通过大数据、云计算、物联网、人工智能等先进技术的应用&#xff0c;实现旅游服务的全面升…
阅读更多...
Java项目：基于SSM框架实现的实践项目管理系统（ssm+B/S架构+源码+数据库+毕业论文+开题报告）

Java项目：基于SSM框架实现的实践项目管理系统（ssm+B/S架构+源码+数据库+毕业论文+开题报告）

一、项目简介 本项目是一套基于SSM框架实现的实践项目管理系统&#xff0c;主要针对计算机相关专业的正在做毕设的学生与需要项目实战练习的Java学习者。 包含&#xff1a;项目源码、数据库脚本等&#xff0c;该项目附带全部源码可作为毕设使用。 项目都经过严格调试&#xff…
阅读更多...
BIMBase浏览器新功能——碰撞检测

BIMBase浏览器新功能——碰撞检测

BIMBase浏览器&#xff08;原BIMBase建模软件 Lite&#xff09;全新R1.14版本已经全面上线&#xff0c;新版本下载链接&#xff1a;BIMBase浏览器R1.14。本次给大家介绍一下本次版本的重点功能&#xff1a;碰撞检测。 各位设计院/施工单位/运维单位的伙伴们在模型交付、方案讨论…
阅读更多...
第三节课，功能2：开发后端用户的管理接口5min(用户的查询/状态更改)【4】【9开始--本人】

第三节课，功能2：开发后端用户的管理接口5min(用户的查询/状态更改)【4】【9开始--本人】

一、代码任务 【录个屏】 二、写代码 2.1 代码文件位置 2.2 代码如下&#xff1a; 2.3 官方文档&#xff1a; 网址&#xff1a; 逻辑删除 | MyBatis-Plus (baomidou.com) 三、代码有bug&#xff0c;没有鉴权&#xff0c;表里添加一个字段。role 管理员 3.1 判断操作的人&am…
阅读更多...
【开发工具】pythontutor——在线内存可视化工具

【开发工具】pythontutor——在线内存可视化工具

笔者在学习RISC-V时&#xff0c;希望找到一款可视化的内存工具&#xff0c;遗憾目前还未找到。发现了pythontutor这个网站&#xff0c;可以对C、python等多种语言进行内存可视化。结果似乎是x86架构的&#xff0c;符合小端存储。 贴一下网址&#xff0c;原准备依据开源版本进行…
阅读更多...
最新文章

Copyright @ 2022~2023