输入已存在邮箱时返回failure.html遇ECONNABORTED错误排查

基于Express开发邮件订阅系统对接Mailchimp API，当用户输入已存在的邮箱注册时，预期返回failure.html页面，但触发Error: Request aborted (ECONNABORTED)，报错栈如下：

Error: Request aborted
at onaborted (C:\Users\Bivek\OneDrive\Desktop\Newsletter-Signuo\node_modules\express\lib\response.js:1052:15)
at Immediate._onImmediate (C:\Users\Bivek\OneDrive\Desktop\Newsletter-Signuo\node_modules\express\lib\response.js:1094:9)
at process.processImmediate (node:internal/timers:476:21) {
code: 'ECONNABORTED'
}

问题根源 #

• 代码中对Mailchimp的响应做了两次响应发送操作：一次在response.on("data")回调里判断errors并发送页面，另一次在回调外部根据response.statusCode再次发送页面。Express不允许同一个HTTP请求被多次发送响应，因此会中止请求，抛出ECONNABORTED错误。
• response.on("data")的回调可能被多次触发（响应数据分块传输），直接解析单块数据会导致无法获取完整的错误信息，甚至JSON解析失败。

修复后的完整代码 #

const Express = require("express");
const body_parser = require("body-parser");
const https = require("https");

const app = Express();

app.use(Express.static("public"));
app.use(body_parser.urlencoded({ extended: true }));

app.get("/", function(req, res) {
    res.sendFile(__dirname + "/signup.html");
});

app.post("/", function(req, res) {
    const FirstName = req.body.first;
    const LastName = req.body.last;
    const Email = req.body.email;
    const data = {
        members: [{
            email_address: Email,
            status: "subscribed",
            merge_fields: {
                FNAME: FirstName,
                LNAME: LastName,
            }
        }]
    };
    const jsonData = JSON.stringify(data);
    const url = "https://us18.api.mailchimp.com/3.0/lists/92a6b8971c";
    const option = {
        method: "POST",
        auth: "Bivek:a40acb902c010418f36154cb92f63edb-us18"
    };

    const request = https.request(url, option, function(response) {
        let responseData = "";

        // 拼接分块的响应数据
        response.on("data", function(chunk) {
            responseData += chunk;
        });

        // 响应结束后统一处理逻辑
        response.on("end", function() {
            try {
                const result = JSON.parse(responseData);
                // 判断是否存在错误（比如邮箱已存在）
                if (result.errors && result.errors.length > 0) {
                    res.sendFile(__dirname + "/failure.html");
                } else if (response.statusCode === 200) {
                    res.sendFile(__dirname + "/success.html");
                } else {
                    res.sendFile(__dirname + "/failure.html");
                }
            } catch (parseErr) {
                console.error("JSON解析错误:", parseErr);
                res.sendFile(__dirname + "/failure.html");
            }
        });

        // 处理响应错误
        response.on("error", function(err) {
            console.error("Mailchimp响应错误:", err);
            res.sendFile(__dirname + "/failure.html");
        });
    });

    // 处理请求发送错误
    request.on("error", function(err) {
        console.error("发送请求到Mailchimp失败:", err);
        res.sendFile(__dirname + "/failure.html");
    });

    request.write(jsonData);
    request.end();
});

app.post("/failure", function(req, res) {
    res.redirect("/");
});

app.listen(3000, function() {
    console.log("Server is running at port 3000");
});
// Audience ID: 92a6b8971c

关键修复点说明 #

1. 拼接完整响应数据：通过responseData += chunk收集所有分块数据，在end事件中统一解析，避免分块解析导致的不完整问题。
2. 统一响应发送逻辑：只在end事件中处理响应结果，确保每个请求只发送一次res.sendFile，避免重复响应触发的ECONNABORTED错误。
3. 增加错误捕获：添加JSON解析错误捕获、请求发送错误捕获、响应错误捕获，确保各种异常情况都能正确返回failure页面。
4. 明确错误判断：先检查Mailchimp返回的errors数组（邮箱已存在时会包含具体错误信息），再结合statusCode判断，逻辑更准确。

内容的提问来源于stack exchange，提问作者samuel clark