c++workflow库实现非阻塞http请求

2024-05-31 15:25:53 浏览数 (2)

接手了之前的服务端老项目,整个项目是用的单线程,然后最近加了新需求,需要同时发送多个用户的订单结算请求到第三方服务,同步请求肯定是不行的,会阻塞其他程序接口运行,这种情况下肯定只能用异步请求了,还好c 本身就有异步并发库,而这个库刚好还在我们的项目依赖中,直接异步http请求走起。

代码语言:cpp复制
#include <iostream>
#include "workflow/WFFacilities.h"


int main() {
    for (int i = 0; i < 10; i  ) {
        int order_id = i;
        // 创建一个workflow对象
        WFHttpTask *task = WFTaskFactory::create_http_task("http://www.baidu.com", 0, 1, nullptr);
        // 设置回调函数
        task->set_callback([order_id](WFHttpTask *task) {
            // 打印请求结果
            std::cout << "结算处理完成,订单id: " << order_id << std::endl;
        });
        // 发送请求
        task->start();
        std::cout << "发送结算请求,订单id: " << order_id << std::endl;
    }

    // 等待所有请求完成
    WFFacilities::WaitGroup wait_group(10);
    wait_group.wait();
    return 0;
}

搞定啦,需要在短时间内并发大量请求时,用这个方法很有效,且节省性能。

0 人点赞