mirror of
https://github.com/yhirose/cpp-httplib.git
synced 2026-09-02 06:43:48 +00:00
c7db3da982
CPPHTTPLIB_MULTIPART_FORM_DATA_FILE_MAX_COUNT is enforced only in Server::read_content(), where parts are accumulated into req.form. The streaming ContentReader path keeps nothing and was never in scope, but this was undocumented (GHSA-923p-8q8g-xcqj). Note the split in the README and show how to bound the part count from inside a ContentReader handler.
104 lines
3.9 KiB
Markdown
104 lines
3.9 KiB
Markdown
---
|
||
title: "S07. マルチパートデータをストリーミングで受け取る"
|
||
order: 26
|
||
status: "draft"
|
||
---
|
||
|
||
大きなファイルをアップロードするハンドラを普通に書くと、`req.body`にリクエスト全体が載ってしまいメモリを圧迫します。`HandlerWithContentReader`を使うと、ボディをチャンクごとに受け取れます。
|
||
|
||
## 基本の使い方
|
||
|
||
```cpp
|
||
svr.Post("/upload",
|
||
[](const httplib::Request &req, httplib::Response &res,
|
||
const httplib::ContentReader &content_reader) {
|
||
if (req.is_multipart_form_data()) {
|
||
content_reader(
|
||
// 各パートのヘッダー
|
||
[&](const httplib::FormData &file) {
|
||
std::cout << "name: " << file.name
|
||
<< ", filename: " << file.filename << std::endl;
|
||
return true;
|
||
},
|
||
// 各パートのボディ（複数回呼ばれる）
|
||
[&](const char *data, size_t len) {
|
||
// ここでファイルに書き出すなど
|
||
return true;
|
||
});
|
||
} else {
|
||
// 普通のリクエストボディ
|
||
content_reader([&](const char *data, size_t len) {
|
||
return true;
|
||
});
|
||
}
|
||
|
||
res.set_content("ok", "text/plain");
|
||
});
|
||
```
|
||
|
||
`content_reader`は2通りの呼び方ができます。マルチパートのときは2つのコールバック（ヘッダー用とデータ用）を渡し、そうでないときは1つのコールバックだけを渡します。
|
||
|
||
## ファイルに直接書き出す
|
||
|
||
大きなファイルをそのままディスクに書き出す例です。
|
||
|
||
```cpp
|
||
svr.Post("/upload",
|
||
[](const httplib::Request &req, httplib::Response &res,
|
||
const httplib::ContentReader &content_reader) {
|
||
std::ofstream ofs;
|
||
|
||
content_reader(
|
||
[&](const httplib::FormData &file) {
|
||
if (!file.filename.empty()) {
|
||
ofs.open("uploads/" + file.filename, std::ios::binary);
|
||
}
|
||
return static_cast<bool>(ofs);
|
||
},
|
||
[&](const char *data, size_t len) {
|
||
ofs.write(data, len);
|
||
return static_cast<bool>(ofs);
|
||
});
|
||
|
||
res.set_content("uploaded", "text/plain");
|
||
});
|
||
```
|
||
|
||
メモリには常に小さなチャンクしか載らないので、ギガバイト級のファイルでも扱えます。
|
||
|
||
## パート数は自分で数える
|
||
|
||
`CPPHTTPLIB_MULTIPART_FORM_DATA_FILE_MAX_COUNT`（デフォルト1024）というパート数の上限がありますが、これが効くのは`req.form`にすべてのパートを溜め込むバッファリング側だけです。`ContentReader`はライブラリ側で何も溜め込まないので、この上限は適用されません。
|
||
|
||
パート数に上限をつけたいときは、自分で数えてヘッダーのコールバックから`false`を返してください。パースはその場で止まります。
|
||
|
||
```cpp
|
||
svr.Post("/upload",
|
||
[](const httplib::Request &req, httplib::Response &res,
|
||
const httplib::ContentReader &content_reader) {
|
||
size_t count = 0;
|
||
|
||
auto ok = content_reader(
|
||
[&](const httplib::FormData &file) {
|
||
if (++count > 100) { return false; } // ここで打ち切る
|
||
return true;
|
||
},
|
||
[&](const char *data, size_t len) {
|
||
return true;
|
||
});
|
||
|
||
if (!ok) {
|
||
res.status = httplib::StatusCode::BadRequest_400;
|
||
return;
|
||
}
|
||
|
||
res.set_content("ok", "text/plain");
|
||
});
|
||
```
|
||
|
||
`content_reader`が`false`を返したら、レスポンスのステータスは自分でセットしてください。ボディの残りは読まずに接続を閉じるので、送信中のクライアントには接続が切れたように見えます。
|
||
|
||
> **Warning:** `HandlerWithContentReader`を使うと、`req.body`は**空のまま**です。ボディはコールバック内で自分で処理してください。
|
||
|
||
> クライアント側でマルチパートを送る方法は[C07. ファイルをマルチパートフォームとしてアップロードする](../c07-multipart-upload)を参照してください。
|