管道流请求后

我有multipart/form-data，我发布一个Express端点/data/upload，下面的表格标记：管道流请求后

form(enctype="multipart/form-data", action="/data/upload", method="post") 
    input(type="file", name="data")

我使用busboy读取文件流，这是工作的罚款。从那里，我想要使用request npm模块将流再次作为multipart/form-data发送到第二个Java后端。 JS客户端/服务器的Java代码如下：

req.busboy.on('file', function (fieldName, fileStream, fileName, encoding, mimeType) { 

    var reqBody = { 
     url: server.baseURL + 'api/data', 
     headers: { 
     'Connection': 'keep-alive', 
     'Content-Type': 'multipart/form-data' 
     }, 
     formData: { 
     file: fileStream 
     } 
    }; 

    request.post(reqBody, function (err, r, body) { 
     // Do rendering stuff, handle callback 
    }); 
});

Java的端点（API /数据）

@POST 
@Consumes(MediaType.MULTIPART_FORM_DATA) 
public void addData(FormDataMultiPart formDataMultiPart) { 
    // Handle multipart data here  
}

我不认为我正确地发送文件作为multipart/form-data这里......但我很难搞清楚如何在不从客户端的临时文件读取/写入的情况下将流从busboy直接流到request。有任何想法吗？

Java堆栈跟踪：

Apr 27, 2016 5:07:12 PM org.glassfish.jersey.filter.LoggingFilter log 
INFO: 3 * Server has received a request on thread qtp1631904921-24 
3 > POST http://localhost:8080/api/data 
3 > Connection: keep-alive 
3 > Content-Length: 199 
3 > Content-Type: multipart/form-data; boundary=--------------------------331473417509479560313628 
3 > Host: localhost:8080 

Apr 27, 2016 5:07:12 PM org.glassfish.jersey.filter.LoggingFilter log 
INFO: 3 * Server responded with a response on thread qtp1631904921-24 
3 < 400 

17:07:13.003 [qtp1631904921-24] WARN org.eclipse.jetty.http.HttpParser parseNext - bad HTTP parsed: 400 No URI for [email protected]{r=1,c=false,a=IDLE,uri=null}

拉哈特推荐的变化：

31  var reqBody = { 
32  url: server.baseURL + 'data', 
33  headers: { 
34   'Connection': 'keep-alive', 
35   'Content-Type': 'multipart/form-data' 
36  } 
37  }; 
38 
39  req.pipe(req.busboy.pipe(request.post(reqBody)));

投掷了错误：

Error: Cannot pipe. Not readable. 
    at Busboy.Writable.pipe (_stream_writable.js:154:22)

来源

2016-04-24 sir_thursday

您正在重新定义'req'。这是打算吗？ –

这是一个很差的变量名称选择，但它不是问题。我会在上面的文章中更改它。 –

你有没有研究过你的'busboy'管道到你的java端点？ –

此处的问题是，您需要手动为分段上传提供“内容长度”，因为request（和底层的form-data）无法自行计算出来。因此请求发送无效的Content-Length：199（对于任何传入文件大小都是相同的），这会中断java multipart解析器。

有多种变通方法：

1）使用输入的请求“的Content-Length”

request.post({ 
    url: server.baseURL + 'api/data', 
    formData: { 
    file: { 
     value: fileStream, 
     options: { 
     knownLength: req.headers['content-length'] 
     } 
    } 
    } 
}, function (err, r, body) { 
    // Do rendering stuff, handle callback 
})

这将虽然产生比特不正确请求，因为进入的长度包括其他上传域和边界，但busboy的是能够解析它的w/o任何投诉

2）等待，直到文件完全由节点应用缓冲然后将其发送到Java

var concat = require('concat-stream') 
req.busboy.on('file', function (fieldName, fileStream, fileName, encoding, mimeType) { 
    fileStream.pipe(concat(function (fileBuffer) { 
    request.post({ 
     url: server.baseURL + 'api/data', 
     formData: { 
     file: fileBuffer 
     } 
    }, function (err, r, body) { 
     // Do rendering stuff, handle callback 
    }) 
    })) 
})

这会增加应用程序的内存消耗，所以你必须要小心，并考虑使用busboy limits

3）缓冲到磁盘文件上传（仅供参考）

express + multer前 - 我推荐使用express for webservers，它使事情更易于管理，并且multer基于busboy
formidable

来源

2016-04-28 01:25:12

刚刚尝试过它似乎工作。非常感谢你花时间写这篇文章。我会尽快给予奖赏。 –

不客气！另一个可能对您的案例有用的lib（node-java集成） - 是https://github.com/nodejitsu/node-http-proxy直接向java代理一些请求，另外我建议看看https://github.com/visionmedia/superagent作为'请求'的替代品 - 它有更清晰的语法，可以在浏览器和后端运行。 –

在我的测试中，2仍然不适用于某些小文件。请考虑发送一个自定义标题，其中包含确切的文件大小，可以在流式启动之前始终读取。 – felipeaf

如果可能，发送一个自定义标题，大小确切的文件（字节）。标题总是可以在处理有效载荷流之前被读取。使用它而不是以前的答案的内容长度标题，因为这有时不起作用（我猜小文件，但我不能确保它适用于大文件）。

来源

2018-01-15 16:32:51 felipeaf

管道流请求后

回答

相关问题