我有 multipart/form-data
我要发布到快速端点 /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 HttpChannelOverHttp@425137da{r=1,c=false,a=IDLE,uri=null}
Rahat 建议的更改:
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)
最佳答案
这里的问题是您需要手动为分段上传提供'Content-Length',因为request
(和底层 form-data
)自己无法弄清楚。
所以请求发送无效的 Content-Length: 199(对于任何传入的文件大小都相同),这会破坏 java 多部分解析器。
有多种解决方法:
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 能够在没有任何投诉的情况下解析它
2) 等到文件被 Node 应用程序完全缓冲后再发送到 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,它使事情更易于管理,而 multer 是基于 busboy 的
- formidable
关于javascript - 从 busboy 管道流到请求帖子,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36829197/