使用 WinAPI 的 InternetReadFile() 进行长轮询
Longpolling with WinAPI's InternetReadFile()
我正在编写跨平台应用程序。我需要从 longpoll url.
获取数据
在 Mac/Linux 我可以使用 curl,curl_easy_perform()
会自动处理所有事情。
在 Windows 我必须使用本机 api。下面的代码适用于正常的 urls,但是当我尝试使用长轮询 url 时,它会立即退出 (nr_read == 0
),而不是等到有新数据:
...
flags =
INTERNET_FLAG_HYPERLINK | INTERNET_FLAG_IGNORE_CERT_CN_INVALID |
INTERNET_FLAG_IGNORE_CERT_DATE_INVALID |
INTERNET_FLAG_IGNORE_REDIRECT_TO_HTTP |
INTERNET_FLAG_IGNORE_REDIRECT_TO_HTTPS | INTERNET_FLAG_NO_AUTH |
INTERNET_FLAG_NO_CACHE_WRITE | INTERNET_FLAG_NO_UI |
INTERNET_FLAG_NO_COOKIES |
INTERNET_FLAG_KEEP_CONNECTION |
INTERNET_FLAG_PRAGMA_NOCACHE | INTERNET_FLAG_RELOAD
INTERNET_FLAG_SECURE;
...
HINTERNET internet = InternetOpenA(user_agent, INTERNET_OPEN_TYPE_PRECONFIG, NULL, NULL, 0);
HINTERNET connect = InternetConnectA(internet, host, port, NULL, NULL, INTERNET_SERVICE_HTTP, 0, 0);
HINTERNET request = HttpOpenRequest(connect, req_typ, path, "HTTP/1.1", NULL, NULL, flags, NULL);
#define BUF_MAX 1024
TCHAR buf[BUF_MAX + 1];
int nr_read = 0;
while (1) {
int ok = InternetReadFile(request, buf, BUF_MAX, &nr_read);
if (!ok) {
puts("not ok");
break;
}
if (nr_read == 0) {
puts("nr read 0, breaking");
break;
}
buf[nr_read] = 0;
printf("buf='%s'\n", buf);
nr_read = 0;
}
响应headers我得到:
HTTP/1.1 101
Switching Protocols
upgrade: websocket
connection: upgrade
握手后,libcurl 保留管道 websocket 数据(我可以手动处理),但 InternetReadFile()
只是退出。
我用
发送了一个 http 请求
Connection: Upgrade
Upgrade: websocket
Sec-WebSocket-Key: key
Sec-WebSocket-Version: 13
服务器用上面的 headers 回答,然后 libcurl 给我 {"type": "hello"}
等等,但是 InternetReadFile()
就退出了。
我最终使用了 libcurl :)
..
我正在编写跨平台应用程序。我需要从 longpoll url.
获取数据在 Mac/Linux 我可以使用 curl,curl_easy_perform()
会自动处理所有事情。
在 Windows 我必须使用本机 api。下面的代码适用于正常的 urls,但是当我尝试使用长轮询 url 时,它会立即退出 (nr_read == 0
),而不是等到有新数据:
...
flags =
INTERNET_FLAG_HYPERLINK | INTERNET_FLAG_IGNORE_CERT_CN_INVALID |
INTERNET_FLAG_IGNORE_CERT_DATE_INVALID |
INTERNET_FLAG_IGNORE_REDIRECT_TO_HTTP |
INTERNET_FLAG_IGNORE_REDIRECT_TO_HTTPS | INTERNET_FLAG_NO_AUTH |
INTERNET_FLAG_NO_CACHE_WRITE | INTERNET_FLAG_NO_UI |
INTERNET_FLAG_NO_COOKIES |
INTERNET_FLAG_KEEP_CONNECTION |
INTERNET_FLAG_PRAGMA_NOCACHE | INTERNET_FLAG_RELOAD
INTERNET_FLAG_SECURE;
...
HINTERNET internet = InternetOpenA(user_agent, INTERNET_OPEN_TYPE_PRECONFIG, NULL, NULL, 0);
HINTERNET connect = InternetConnectA(internet, host, port, NULL, NULL, INTERNET_SERVICE_HTTP, 0, 0);
HINTERNET request = HttpOpenRequest(connect, req_typ, path, "HTTP/1.1", NULL, NULL, flags, NULL);
#define BUF_MAX 1024
TCHAR buf[BUF_MAX + 1];
int nr_read = 0;
while (1) {
int ok = InternetReadFile(request, buf, BUF_MAX, &nr_read);
if (!ok) {
puts("not ok");
break;
}
if (nr_read == 0) {
puts("nr read 0, breaking");
break;
}
buf[nr_read] = 0;
printf("buf='%s'\n", buf);
nr_read = 0;
}
响应headers我得到:
HTTP/1.1 101
Switching Protocols
upgrade: websocket
connection: upgrade
握手后,libcurl 保留管道 websocket 数据(我可以手动处理),但 InternetReadFile()
只是退出。
我用
发送了一个 http 请求Connection: Upgrade
Upgrade: websocket
Sec-WebSocket-Key: key
Sec-WebSocket-Version: 13
服务器用上面的 headers 回答,然后 libcurl 给我 {"type": "hello"}
等等,但是 InternetReadFile()
就退出了。
我最终使用了 libcurl :)
..