Как в Reactor Netty Http Server получить тело POST-запроса?

Question

[Wan-Derer]

Как в Reactor Netty Http Server (не Spring) получить тело POST-запроса? В теле есть Json, как мне его получить в переменную?

Comments

[Dmitry Roo]

Немного кода приложить не помешает.

[Wan-Derer]

Dmitry Roo, Алексей Черемисин, Сервер у меня определён так:

// Netty HTTP server
    final HttpServer httpServer = HttpServer.create()
      .host(config.server.host)
      .port(config.server.port)
      .wiretap(true)
      .accessLog(true)
      .compress(true)
      .route(routes -> routes
        .post(base + "/reports", reportController::addReport)
      );

    server = httpServer.bindNow();
    log.info("Server started");
    server.onDispose().block();

Контроллер такой:

public class ReportController {

  private static Flux<HttpContent> content;

  // POST /api/reports
  public Publisher<Void> addReport(HttpServerRequest req, HttpServerResponse resp) {

    System.out.println("POST");
//    System.out.println(req);

    content = req.receiveContent();
    handleContent();

    return resp
      .status(HttpResponseStatus.OK)
      .addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")     // CORS
      .sendString(Mono.just(""));
  }


  private void handleContent() {
    content
      .doOnNext(item -> {
        ByteBuf content = item.content();
        if (content.isReadable()) System.out.println(content.toString(StandardCharsets.UTF_8));
      })
      .doOnComplete(() -> System.out.println("COMPLETE"))
      .doOnError(System.out::println)
      .subscribe(System.out::println);
  }
}

При исполнении сразу выскакивает "COMPLETE" как будто данных нет, но они там точно есть, если включить полное логирование, то в логах они есть.
Пробовал и receive(), и receiveObject() - всё то же самое.

[Алексей Черемисин]

Э.... Тут такое дело.... Нельзя войти в inputsteam дважды. Выево прихраните куда, и уж затем и в логи и куда угодно...

[Wan-Derer]

Алексей Черемисин, Можно пример?

Answer 1

[Dmitry Roo]

public Publisher<Void> addReport(HttpServerRequest req, HttpServerResponse resp) {
        return req.receive()
                .asString()
                .doOnNext(string -> {
                    // todo :: make some handy job with string
                    System.out.println(string);
                })
                .flatMap(__ -> resp.status(HttpResponseStatus.OK)  
                        .addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")     // CORS
                        .sendString(Mono.just("")));
    }

Comments

[Wan-Derer]

Это работает! Но получается не всё тело, а часть.
По логам:
- прилетает чанк 1024 байта вкл заголовки, из него достаётся часть тела и печатается;
- сразу улетает RESPONSE, типа всё Ок;
- прилетает второй чанк с остатками тела, но он уже никуда не записывается.
Как получить всё тело?

[Dmitry Roo]

Wan-Derer, а так?

public Publisher<Void> addReport(HttpServerRequest req, HttpServerResponse resp) {
        return req.receive()
                .aggregate()
                .asString()
                .doOnNext(string -> {
                    // todo :: make some handy job
                    System.out.println(string);
                })
                .then()
                .doOnSuccess(__ -> resp.status(HttpResponseStatus.OK)
                        .addHeader(ACCESS_CONTROL_ALLOW_ORIGIN, "*")     // CORS
                        .sendString(Mono.just("")));

[Wan-Derer]

Dmitry Roo, Да, так пашет ваще огонь! Большое СПАСИБО! :)

[Wan-Derer]

Dmitry Roo, у меня следующий вопрос :)
Хочу обрабатывать ошибки, возникающие при обработке моего JSON.
Добавил в конец секцию:

.doOnError(__ -> resp.status(HttpResponseStatus.BAD_REQUEST))

Но она работает для Mono<String>, формируемого в строке asString(), я правильно понимаю?
Мне наверно надо в мой сервис отправлять не строку, а Mono<String> и там уже добавлять ошибки. Но как? Пока пришло в голову вместо .doOnNext() сделать .map(), которая будет вызывать сервис, а в нём уже делать .doOnNext(). Насколько правильная это мысль? Или есть более "типовой" способ? (учитывая что из сервиса значения возвращаться не будет, только success или error)

[Dmitry Roo]

Wan-Derer, .map и .doOnNext предоставляют разное поведение. .map - преобразует данные, и результат будет отправлен дальше по цепочке, .doOnNext - запускает какое-то действие в отдельном потоке.

Answer 2

[Алексей Черемисин]

https://www.baeldung.com/java-netty-http-server. Здесь кажется есть ответ.