WebFlux在使用应用程序/流json时不发送数据

Question

我有一个反应式核心WebClient要发布到给定的endpoint。有效负载是Job对象的流量，内容类型是application/stream json flux jobFlux=flux。只是（新工作）；

Mono<JsonNode> response = localEP.post().uri( "/dev/job" )
    .contentType(MediaType.APPLICATION_STREAM_JSON)
    .body( BodyInserters.fromObject(jobFlux))
    .retrieve()
    .bodyToMono( JsonNode.class );

在服务器端，我尝试了Spring控制器样式和Spring Web反应式FunctionHandler，以使用流量负载处理上述调用的负载。

  @PostMapping(path = "/dev/job", consumes = MediaType.APPLICATION_STREAM_JSON_VALUE)
  @ResponseStatus( HttpStatus.CREATED )
 public Mono<Void> loadJobs (@RequestBody Flux<Job> jobs) {
    return this.repository.create(jobs); 
 }

当实例化一个新对象时，域类Job创建和标识：

  public Job() {
    UUID guid = UUID.randomUUID();
    id = guid.toString();
    title = "Random String";
  }

仓库目前只是一个存根：

@Repository
public class DemoJobRepository implements ReactiveRepository<Job> {
   private static Logger logger = LoggerFactory.getLogger(DemoJobRepository.class);
   private final List<Job> jobs = Lists.newArrayList();

@Override
public Mono<Void> create(Publisher<Job> jobStream) {
    return Flux.from(jobStream).doOnNext(jobs::add).then();
}

@Override
public Flux<Job> getAll() {
    return Flux.fromIterable(jobs);
}

@Override
public Mono<Job> findById(String id) {
    return null;
}
}

我没有看到客户端试图发送requestbody。我在客户机上调用了block来获得结果，我看到客户机发送了请求，但是服务器endpoint总是看到一个空流量。请，任何帮助都非常感谢。

Answer 1

对于被动类型，在您订阅之前不会发生任何事情-构建被动管道不会执行它应该执行的操作，只有订阅它才会启动流程。

有几种订阅方式：

>

调用任何块/收集方法。这不仅订阅，而且返回期望值。

这两种选择都不应该在返回反应性类型的方法中进行，否则这将导致应用程序中出现严重问题。