如何用Reqwest实现FCM批量请求？排查400错误问题

你的Reqwest代码出现400错误主要有以下几个问题：

1. 未添加批量请求的结束边界标记 #

HTTP multipart格式要求在所有子请求结束后，必须添加--{boundary}--来标记整个请求体结束。你的代码只在每个子请求前添加了起始边界，缺少结束标记，导致服务器无法正确解析请求结构。

2. Content-Type头的boundary值带多余引号 #

curl命令里的引号是shell转义需要，实际HTTP头中boundary的值不需要加引号。你代码里设置的boundary=\"subrequest_boundary\"会让服务器认为边界字符串是带引号的"subrequest_boundary"，但你实际使用的边界是不带引号的，两者不匹配导致解析失败。

3. 子请求开头的多余换行 #

你通过format生成的子请求开头带有换行，会导致整个请求体的第一个边界前出现空行，不符合multipart格式规范，干扰服务器解析。

修复后的代码示例 #

let mut to_send = String::new();

for message in messages {
    let json = serde_json::to_string(&message).unwrap();
    // 去掉开头的换行，确保边界前没有多余空行
    let request = format!(r#"--subrequest_boundary
Content-Type: application/http
Content-Transfer-Encoding: binary

POST /v1/projects/{}/messages:send
Content-Type: application/json
accept: application/json

{json}
"#, self.project_id);

    to_send.push_str(&request);
}

// 添加结束边界标记
to_send.push_str("\n--subrequest_boundary--");

let resp = self
    .inner
    .post("https://fcm.googleapis.com/batch")
    .timeout(self.timeout)
    .bearer_auth(tok.token().unwrap())
    // 去掉boundary值的引号
    .header(CONTENT_TYPE, HeaderValue::from_static("multipart/mixed; boundary=subrequest_boundary"))
    .body(to_send)
    .send()
    .await
    .map_err(|_| Error::Timeout)?;

内容的提问来源于stack exchange，提问作者J. Doe