Как скачивать файл в Spring WebFlux?

Question

[Wan-Derer]

Искал сабж, нашёл такую статью. Это работает, но у меня задача такая:
- с фронта идёт команда;
- бэк формирует нужный файл;
- файл скачивается;
- файл на бэке удаляется.

Используя статью, я могу сделать так:
- запрос с фронта на формирование файла;
- бэк формирует файл и возвращает его имя;
- запрос с фронта на скачивание как описано в статье.

Проблемы:
- два разных запроса, мне кажется, это несколько громоздко;
- главное - нет возможности понять что файл скачался и его можно удалить.

Я изначально себе мыслил так:
- бэк формирует файл и возвращает ссылку на скачивание: http://...../file.txt;
- скачивание происходит средствами фронта (в моём случае Angular);
- после скачивания фронт шлёт запрос что completed и бэк удаляет файл.

Вопрос: как это вообще делается, можно ли поправить метод из статьи или надо делать как-то (как?) по-другому?

Comments

[сергей кузьмин]

интересно а как бы вы это сделали в обычном спринг не реактивном ?

[Wan-Derer]

сергей кузьмин, т.к. я впервые сталкиваюсь с такой задачей, то и поступил бы так же: поискал пример в интернетах :)

[Сергей Горностаев]

При реактивном подходе файл не формируется и не удаляется, он отдаётся клиенту частями по мере формирования.

[Wan-Derer]

Сергей Горностаев, Это как? OutputStream отдавать на контроллер? Или как? Можно пример?

[Сергей Горностаев]

Wan-Derer, возможно Flux<DataBuffer>, возможно Mono<ServerResponse>, где в body передан Publisher, может быть и что-то ещё. Зависит от того, какой файл вы формируете и как.

[Wan-Derer]

Сергей Горностаев, у меня 2 типа файлов: Excel (через библиотеку Apache POI) и PDF (через библиотеку https://github.com/LibrePDF/OpenPDF).
В обоих случаях файлы небольшие по размеру, на входе моих методов JSON с содержимым, на выходе - файл.
Для Excel я создаю XSSFWorkbook (класс библы), наполняю его содержимым, потом вызываю его метод write(), который принимает FileOutputStream и получаю файл.
Для PDF есть некая внутренняя магия библы под названием PdfWriter, в который я сначала должен передать "заготовку" Document и FileOutputStream, потом наполнить документ данными, потом сделать document.close(); и получается файл.

[сергей кузьмин]

реактивный и регулярный просто открывают файл стрим и передают это в ответ на запрос:

public @ResponseBody byte[] getImage()
InputStream in = ... ;
    return IOUtils.toByteArray(in);

e

узнать что клиент загрузил файл полностью сервер так просто не может клиект должен выполнить что нибудь еще - напишите отдельный эндпойнт для обаботки запроса "файл получил можете удалять"

[Wan-Derer]

сергей кузьмин, По результатам обсуждения здесь я нашёл пример, в котором работа идёт не с файлом, а со стримом. Причём годится не только FileOutputStream а любой OutputStream, например, ByteArrayOutputStream. Т.е. файл создавать не надо, значит и удалять ничего не надо.
Я максимально упростил пример и получился такой тест:

@GetMapping("/dl")
@ResponseBody
public ResponseEntity<Mono<Resource>> download() throws IOException {

  String text = """
    aaa,
    bbb,
    яяя
    """;

  byte[] bytes = text.getBytes();

  ByteArrayOutputStream out = new ByteArrayOutputStream();
  out.write(bytes);
  out.close();

  ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());

  Mono<ByteArrayInputStream> file = Mono.just(in);

  String filename = "1.txt";
  return ResponseEntity
    .ok()
    .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=" + filename)
    .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_OCTET_STREAM_VALUE)
    .body(file
      .flatMap(x -> Mono.just(new InputStreamResource(x)))
    )
    ;
}

Это работает. Теперь занимаюсь переделкой своих классов, создающих "файлы" чтобы они отдавали нужные стримы.

[сергей кузьмин]

Wan-Derer, поздравляю это все примеры из учебника

textbook examples

[Wan-Derer]

сергей кузьмин, можно попросить ссылочку на этот учебник?

[сергей кузьмин]

стандартное и лучшее место где очень много очень хорошей документации по спринг это
https://www.baeldung.com