Libcurl C++：将请求发送到单个 URL 的非阻塞方式

Question

目标：将请求发送到同一 URL，而不必等待请求发送函数完成执行。

目前，当我向 URL 发送请求时，我必须等待大约 10 毫秒才能得到服务器的响应，然后才能使用相同的函数发送另一个请求。目的是检测网页上的变化比程序当前执行的速度稍快，以便 WHILE 循环以非阻塞方式运行。

问题：使用 libcurl C++，如果我有一个 WHILE 循环调用一个函数来向 URL 发送请求，如何避免在向同一 URL发送另一个请求之前等待该函数完成执行？

注意：我一直在研究 libcurl，multi-interface但我正在努力确定该接口是否更适合对多个 URL 的并行请求，而不是将请求发送到同一 URL，而无需每次都等待该函数完成执行。我尝试了以下方法并查看了这些资源：

• 尝试使用 libcurl 请求对 C 程序进行多线程处理
• 如何在 C++ 中异步执行curl_multi_perform()？
• http://www.godpatterns.com/2011/09/asynchronous-non-blocking-curl-multi.html
• https://curl.se/libcurl/c/multi-single.html
• https://curl.se/libcurl/c/multi-poll.html

这是我向一个 URL 发送请求的尝试，但我必须等待该request()函数完成并返回响应代码，然后才能再次发送相同的请求。

#include <vector>
#include <iostream>
#include <curl/curl.h>

size_t write_callback(char *ptr, size_t size, size_t nmemb, void *userdata) {

        std::vector<char> *response = reinterpret_cast<std::vector<char> *>(userdata);
        response->insert(response->end(), ptr, ptr+nmemb);
        return nmemb;
}

long request(CURL *curl, const std::string &url) {

        std::vector<char> response;
        long response_code;

        curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
        curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &response_code);
        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
        curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response);

        auto res = curl_easy_perform(curl);
     
        // ...
        // Print variable "response"
        // ...

        return response_code;
}

int main() {
        curl_global_init(CURL_GLOBAL_ALL);
        CURL *curl = curl_easy_init();

        while (true) {
                // blocking: request() must complete before executing again
                long response_code = request(curl, "https://example.com");
                // ...
                // Some condition breaks loop
        }

        curl_easy_cleanup(curl);
        curl_global_cleanup();
        return 0;
}

我正试图multi-interface尽可能地理解文档，但仍然很难完全理解它/确定它是否真正适合我的特定问题。如果这个问题似乎没有提供足够的我自己的研究，我深表歉意，但我正在努力填补我的 libcurl 知识中的空白。

如果有人能建议/解释我可以修改上面的单个 libcurl 示例以非阻塞方式运行的方法，我将不胜感激。

---

编辑：

从 libcurl 的名为“multi-poll”的C 实现示例中，当我运行下面的程序时，会打印 URL 的内容，但因为尽管存在循环，但它只打印一次，所以WHILE (1)我很困惑它是否正在发送重复的非阻塞请求到 URL（这是目标），或者只是一个请求并正在等待其他一些更改/事件？

#include <stdio.h>
#include <string.h>

/* somewhat unix-specific */
#include <sys/time.h>
#include <unistd.h>

/* curl stuff */
#include <curl/curl.h>

int main(void)
{
        CURL *http_handle;
        CURLM *multi_handle;
        int still_running = 1; /* keep number of running handles */

        curl_global_init(CURL_GLOBAL_DEFAULT);

        http_handle = curl_easy_init();

        curl_easy_setopt(http_handle, CURLOPT_URL, "https://example.com");

        multi_handle = curl_multi_init();

        curl_multi_add_handle(multi_handle, http_handle);

        while (1) {
                CURLMcode mc; /* curl_multi_poll() return code */
                int numfds;

                /* we start some action by calling perform right away */
                mc = curl_multi_perform(multi_handle, &still_running);

                if(still_running) {
                        /* wait for activity, timeout or "nothing" */
                        mc = curl_multi_poll(multi_handle, NULL, 0, 1000, &numfds);
                }

//              if(mc != CURLM_OK) {
//                      fprintf(stderr, "curl_multi_wait() failed, code %d.\n", mc);
//                      break;
//              }
        }

        curl_multi_remove_handle(multi_handle, http_handle);
        curl_easy_cleanup(http_handle);
        curl_multi_cleanup(multi_handle);
        curl_global_cleanup();

        return 0;
}

Answer 1

您需要在 while 循环内移动curl_multi_add_handle 和curl_multi_remove_handle。以下是curl文档的摘录https://curl.se/libcurl/c/libcurl-multi.html

当单次传输完成后，简单句柄仍会添加到>多堆栈中。您需要首先使用curl_multi_remove_handle>删除简单句柄，然后使用curl_easy_cleanup关闭它，或者可能为其设置新选项并使用curl_multi_add_handle再次添加>它以开始另一次传输。