gpt4 book ai didi

java - 下载多个文件 Java Spring

转载 作者:可可西里 更新时间:2023-11-01 16:11:03 27 4
gpt4 key购买 nike

我正在尝试在我的 spring-mvc 应用程序中使用一个 http get 请求下载多个文件。

我看过其他帖子,说您可以压缩文件并发送此文件,但在我的情况下这并不理想,因为无法从应用程序直接访问该文件。要获取文件,我必须查询 REST 接口(interface),该接口(interface)从 hbase 或 hadoop 流式传输文件。

我可以拥有大于 1 Go 的文件,因此将文件下载到存储库、压缩它们并将它们发送到客户端会太长。 (考虑到大文件已经压缩,压缩不会压缩它们)。

我看到了herethere您可以使用 multipart-response 一次下载多个文件,但我无法得到任何结果。这是我的代码:

String boundaryTxt = "--AMZ90RFX875LKMFasdf09DDFF3";
response.setContentType("multipart/x-mixed-replace;boundary=" + boundaryTxt.substring(2));
ServletOutputStream out = response.getOutputStream();

// write the first boundary
out.write(("\r\n"+boundaryTxt+"\r\n").getBytes());

String contentType = "Content-type: application/octet-stream\n";

for (String s:files){
System.out.println(s);
String[] split = s.trim().split("/");
db = split[1];
key = split[2]+"/"+split[3]+"/"+split[4];
filename = split[4];

out.write((contentType + "\r\n").getBytes());
out.write(("\r\nContent-Disposition: attachment; filename=" +filename+"\r\n").getBytes());

InputStream is = null;
if (db.equals("hadoop")){
is = HadoopUtils.get(key);
}
else if (db.equals("hbase")){
is = HbaseUtils.get(key);
}
else{
System.out.println("Wrong db with name: " + db);
}
byte[] buffer = new byte[9000]; // max 8kB for http get
int data;
while((data = is.read(buffer)) != -1) {
out.write(buffer, 0, data);
}
is.close();

// write bndry after data
out.write(("\r\n"+boundaryTxt+"\r\n").getBytes());
response.flushBuffer();
}
// write the ending boundary
out.write((boundaryTxt + "--\r\n").getBytes());
response.flushBuffer();
out.close();
}

奇怪的是我根据导航器得到不同的结果。在 Chrome(查看控制台)和 Firefox 中没有任何反应,我收到了要求下载每个文件的提示,但它没有正确的类型或正确的名称(控制台中也没有)。

我的代码有什么错误吗?如果没有,还有其他选择吗?

编辑

我还看到了这个帖子:Unable to send a multipart/mixed request to spring MVC based REST service

编辑2

firefox result

这个文件的内容是我想要的,可是为什么我取不了正确的名字,为什么chrome也下载不了什么?

最佳答案

这是您可以通过 zip 下载的方式:

try {
List<GroupAttachments> groupAttachmentsList = attachIdList.stream().map(this::getAttachmentObjectOnlyById).collect(Collectors.toList()); // Get list of Attachment objects
Person person = this.personService.getCurrentlyAuthenticatedUser();
String zipSavedAt = zipLocation + String.valueOf(new BigInteger(130, random).toString(32)); // File saved location
byte[] buffer = new byte[1024];
FileOutputStream fos = new FileOutputStream(zipSavedAt);
ZipOutputStream zos = new ZipOutputStream(fos);

GroupAttachments attachments = getAttachmentObjectOnlyById(attachIdList.get(0));

for (GroupAttachments groupAttachments : groupAttachmentsList) {
Path path = Paths.get(msg + groupAttachments.getGroupId() + "/" +
groupAttachments.getFileIdentifier()); // Get the file from server from given path
File file = path.toFile();
FileInputStream fis = new FileInputStream(file);
zos.putNextEntry(new ZipEntry(groupAttachments.getFileName()));
int length;

while ((length = fis.read(buffer)) > 0) {
zos.write(buffer, 0, length);
}
zos.closeEntry();
fis.close();

zos.close();
return zipSavedAt;
}
} catch (Exception ignored) {
}
return null;
}

下载zip的 Controller 方法:

 @RequestMapping(value = "/URL/{mode}/{token}")
public void downloadZip(HttpServletResponse response, @PathVariable("token") String token,
@PathVariable("mode") boolean mode) {
response.setContentType("application/octet-stream");
try {
Person person = this.personService.getCurrentlyAuthenticatedUser();
List<Integer> integerList = new ArrayList<>();
String[] integerArray = token.split(":");
for (String value : integerArray) {
integerList.add(Integer.valueOf(value));
}
if (!mode) {
String zipPath = this.groupAttachmentsService.downloadAttachmentsAsZip(integerList);
File file = new File(zipPath);
response.setHeader("Content-Length", String.valueOf(file.length()));
response.setHeader("Content-Disposition", "attachment; filename=\"" + person.getFirstName() + ".zip" + "\"");
InputStream is = new FileInputStream(file);
FileCopyUtils.copy(IOUtils.toByteArray(is), response.getOutputStream());
response.flushBuffer();
}
} catch (Exception e) {
e.printStackTrace();
}
}

玩得开心,如有疑问,让我知道。

更新

ZIP 文件中的字节数组。您可以像我给出的第一种方法一样在循环中使用此代码:

public static byte[] zipBytes(String filename, byte[] input) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ZipOutputStream zos = new ZipOutputStream(baos);
ZipEntry entry = new ZipEntry(filename);
entry.setSize(input.length);
zos.putNextEntry(entry);
zos.write(input);
zos.closeEntry();
zos.close();
return baos.toByteArray();
}

关于java - 下载多个文件 Java Spring,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36886141/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com