C#使用HttpWebRequest以PUT方法上传文件至NodeJS Express的服务端实现问题

你当前代码的常见问题 #

• 时序错误：在刚挂上流监听逻辑就直接返回成功响应，此时客户端的文件可能还未传输完成，客户端收到响应后直接断开连接，会导致写入的文件内容残缺、不完整。
• 实现效率低：逐块调用fs.appendFile的方式，每接收一块数据就重复打开、定位、写入、关闭文件句柄，大文件场景下性能极差，且无法保障写入顺序的一致性。
• 非必要的底层操作：直接监听req.socket事件绕开了Express封装的可读流层，容易出现事件绑定混乱、数据丢失、重复接收的问题。
• 硬编码文件名：完全忽略了C#客户端通过查询参数传递的真实文件名，所有上传内容都会被覆盖写入同一个固定文件。

准确判断文件上传完成的时机 #

Express的req对象本身就是Node.js封装好的IncomingMessage可读流，不需要操作底层socket，两个事件节点就能覆盖全场景的完成判断：

• 正常完成节点：当你通过fs.createWriteStream把req流的内容管道写入磁盘时，写入流触发finish事件的瞬间，代表所有从客户端接收的字节都已经成功刷盘、文件句柄正常关闭，这是最可靠的落盘完成节点——这个事件触发的时候，没有任何后续待写入的数据了。
• 异常兜底节点：必须同时给req流和写入流绑定error事件：如果上传过程中出现连接中断、磁盘写入失败、权限不足等问题，会直接触发error事件，此时要立即销毁两个流、清理不完整的临时文件、返回错误响应，避免一直挂起请求或者残留垃圾文件。

注意：必须等写入流的finish事件触发，且后续哈希计算、数据库操作全部执行完成之后，再调用res.send返回自定义响应，绝对不能提前发送响应。

PUT直传场景的规范实现 #

你的客户端是纯二进制PUT上传（不是multipart/form-data表单格式），不需要引入专门处理表单的上传中间件，纯原生流实现就能达到最好的兼容性和性能，完全适配不能修改的C#客户端逻辑：

1. 从req.query.name中读取客户端传递的文件名，通过path.basename剥离所有路径字符，防止出现路径穿越的安全漏洞，将文件写入提前创建好的专用上传目录。
2. 用fs.createWriteStream创建目标文件的写入流，通过req.pipe(writeStream)把接收的请求体直接管道到写入流，利用Node原生的流背压机制自动处理大文件场景，不会因为一次性读入整个文件占用过高内存。
3. 等写入流触发finish事件后，再依次执行文件哈希计算、MySQL数据写入等后续业务逻辑，全部成功后再返回自定义响应文本。

兼容要求的正确实现示例 #

const express = require('express');
const fs = require('fs');
const path = require('path');
const crypto = require('crypto');
// 提前初始化好的MySQL连接池
const mysqlPool = require('./db/pool');

const app = express();
const port = process.env.PORT || 10090;
// 提前创建的文件存储目录
const UPLOAD_ROOT = path.join(__dirname, 'upload_storage');
fs.mkdirSync(UPLOAD_ROOT, { recursive: true });

app.put('/upload', (req, res) => {
    try {
        // 读取客户端传递的文件名，做安全校验
        const rawFileName = req.query.name;
        if (!rawFileName) {
            return res.status(400).send('Missing target file name');
        }
        // 剥离路径，防止路径穿越
        const safeFileName = path.basename(decodeURIComponent(rawFileName));
        const targetFilePath = path.join(UPLOAD_ROOT, safeFileName);

        // 创建磁盘写入流
        const fileWriteStream = fs.createWriteStream(targetFilePath);
        let requestError = false;

        // 处理请求流异常（客户端断连、传输中断）
        req.on('error', (err) => {
            requestError = true;
            fileWriteStream.destroy(err);
            // 清理不完整文件
            fs.unlink(targetFilePath, () => {});
            res.status(500).send(`Upload interrupted: ${err.message}`);
        });

        // 处理写入流异常（磁盘满、权限不足）
        fileWriteStream.on('error', (err) => {
            requestError = true;
            req.destroy();
            fs.unlink(targetFilePath, () => {});
            res.status(500).send(`File save failed: ${err.message}`);
        });

        // 管道接通，自动处理流背压
        req.pipe(fileWriteStream);

        // 落盘完成后的业务逻辑
        fileWriteStream.on('finish', async () => {
            if (requestError) return;
            try {
                // 计算文件哈希
                const fileHash = crypto.createHash('sha256')
                    .update(fs.readFileSync(targetFilePath))
                    .digest('hex');
                
                // 执行MySQL入库操作
                await mysqlPool.execute(
                    'INSERT INTO file_records (file_name, file_path, sha256_hash) VALUES (?, ?, ?)',
                    [safeFileName, targetFilePath, fileHash]
                );

                // 全部业务完成后再返回响应，匹配C#客户端的等待逻辑
                res.send(`Upload completed, hash: ${fileHash}`);
            } catch (err) {
                fs.unlink(targetFilePath, () => {});
                res.status(500).send(`Post-processing failed: ${err.message}`);
            }
        });

    } catch (err) {
        res.status(500).send(err.message);
    }
});

app.listen(port, () => {
    console.log(`Server listening on port ${port}`);
});

额外注意事项 #

• 不要用硬编码的固定文件名存储所有上传内容，要从请求参数中获取客户端指定的文件名，避免不同文件互相覆盖。
• 你当前使用的new Buffer是Node.js已经废弃的API，上述实现中完全不需要手动操作原始Buffer，由流管道自动处理块数据的拼接和写入。
• C#客户端通过HTTPS访问服务端，要确保Express配置的HTTPS证书是客户端可信任的，自签证书需要提前在客户端配置信任规则，否则会出现连接被拒绝的问题。

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