如何在Spring Webflux中从单一对象中提取数据而不阻塞？

Question

我正在使用Postman向我的Spring应用程序发送POST请求。请求有一个JSON主体，如下所示：

{
        "documents": [
            {
                "id": "1",
                "text": "Piece of text 1",
                "lang": "en"
            },
            {
                "id": "2",
                "text": "Piece of text 2",
                "lang": "en"
            }
        ],
        "domain": "hr",
        "text_key": "text"
    }

我有一个方法来处理这些POST请求，我需要能够从请求主体中提取上述JSON数据而不会阻塞。我现在的方法看起来像这样：

public void requestBody(ServerRequest request) {


      Mono<String> bodyData = request.bodyToMono(String.class);

      System.out.println("\nsubscribing to the Mono.....");

      bodyData.subscribeOn(Schedulers.newParallel("requestBody")).subscribe(value -> {
        log.debug(String.format("%n value consumed: %s" ,value));
      });

}

然而，这没有任何作用。我尝试使用ServerRequest查看Spring中的答案，并从Spring ServerRequest中获取字符串体，但没有成功。请帮忙。

更新#1

谢谢https://stackoverflow.com/users/1189885/chrylis-cautiouslyoptimistic

根据你的回答，这就是我正在努力的：

    request.bodyToMono(String.class).map(
        (String rqBody) -> {
          setRequestBody(rqBody);
          return ServerResponse.status(HttpStatus.CREATED).contentType(APPLICATION_JSON).body(rqBody, Object.class);
        }
      );

setRequestBody（）正在将一个全局字符串变量设置为请求正文。这样地：

  public void setRequestBody (String rqBody){
    System.out.println("\nset request body called with: " + rqBody);
    request_body=rqBody;
  }

但是，全局请求_body变量仍然为空。

更新#2

根据你最近的评论，这就是我想做的：

    RedissonClient redisson = Redisson.create();

    RBucket<Object> bucket = redisson.getBucket("requestKey");

      request.bodyToMono(String.class).doOnNext(
        (String rqBody) -> {
          bucket.set(rqBody);
        }
      );

当我进入Redis-cli并尝试获取请求密钥时，它会给我零代码

Answer 1

你不能；这就是反应模型的全部含义。相反，您通常应该使用诸如map（通过应用函数修改值）或doOnNext（执行某些操作但不返回结果）之类的操作。

如果使用反应式执行模型，如Spring WebFlux，则直接返回Mono