1

嗨，我不会在不接触磁盘驱动器的情况下自己处理上传流。所以，对我来说，自然选择是多方模块。

我采用了一般示例，并根据页面https://npmjs.org/package/multiparty的说明将 form.parse 更改为非回调请求。在这种情况下，磁盘不会被触及。

我的代码如下所示：

multiparty = require("multiparty")
http = require("http")
util = require("util")

# show a file upload form
http.createServer((req, res) ->
  if req.url is "/upload" and req.method is "POST"
    form = new multiparty.Form()

    form.on 'error', (err) ->
      console.log "Error received #{err}"

    form.on 'aborted',  ->
      console.log "Aborted"

    form.on 'part', (part) ->
      console.log "Part"

    form.on 'close', (part) ->
      console.log "close received"
      res.writeHead 200,
        "content-type": "text/plain"
      res.end "received upload:\n\n"

    form.on 'progress', (bytesReceived, bytesExpected) ->
      console.log "Received #{bytesReceived}, #{bytesExpected}"

    form.parse req
  else
    res.writeHead 200,
      "content-type": "text/html"

    res.end "<form action=\"/upload\" enctype=\"multipart/form-data\" method=\"post\">" + "<input type=\"text\" name=\"title\"><br>" + "<input type=\"file\" name=\"upload\" multiple=\"multiple\"><br>" + "<input type=\"submit\" value=\"Upload\">" + "</form>"
).listen 8080

控制台输出如下所示：

Part
Part
Received 64983, 337353
Received 130519, 337353
Aborted
Error received Error: Request aborted

没有生成关闭事件，所以我不知道读取套接字何时结束。如果我换行：

form.parse req

至：

form.parse req, (err, fields, files) ->
  res.writeHead 200,
    "content-type": "text/plain"

  res.write "received upload:\n\n"
  res.end util.inspect(
    fields: fields
    files: files
  )

然后一切都很好，关闭事件被调用。但是文件存储在磁盘上。控制台如下所示：

Part
Part
Received 65536, 337353
Received 131072, 337353
Received 196608, 337353
Received 262144, 337353
Received 327680, 337353
Received 337353, 337353
close received

知道有什么问题吗？

4

2 回答 2

5

在这种情况下，由于您没有将数据管道传输到文件，close因此仅当所有数据都已从req对象管道输出时才会发出，从而导致req内部发出它的finish事件，这会触发多方close事件。

在实践中，如果您需要close事件，请始终将数据拉出部分，无论是到黑洞还是有意义的位置（文件或临时保存流）。这也意味着使用close事件来持续控制流可能非常棘手。

如果你不想对数据做任何事情，你可以像这样黑洞：

form.on("part", function(part) {
    out = new stream.Writable(); // require("stream") to get this native class
    out._write = function (chunk, encoding, done) {
        done(); // Don't do anything with the data
    };
    part.pipe(out);
});

令人困惑的部分是不访问的代码part将调用close小文件的事件，但不会在大文件上调用（我是如何遇到这个问题的）。原因是该close事件与您是否part已从req.

节点流一次只在它们的缓冲区之间传输几个块。因此，小文件能够在不填充内部缓冲区的情况下将其整个缓冲区从 传输req到。较大的文件将填满 的缓冲区，但仍有数据留在 中，需要读取以获取缓冲区中剩余的数据。partpartpartreqpartreq

这一事实也使得将close事件用于与控制流有关的任何事情都很棘手。例如， apart仍然可以处理，但close将被发送，再次因为close不依赖于part完成，而是依赖于req为空。令人困惑！

于 2014-02-07T20:13:03.243 回答
1

我认为您至少需要在某处读取任何收到的部分才能完成请求处理并触发关闭事件：

form.on('part', function(part) {
    part.pipe(fs.createWriteStream('/dev/null'));
});

没有这个，我想这就像您的请求仍在等待处理。（请注意，有比 "> /dev/null" 更优雅、更少脚本的方式，但这只是一个示例；）

于 2014-01-15T21:34:28.567 回答