如何在webflux中异步解析/写入json？ ObjectMapper方法被阻止

Question

我看到杰克逊从2.9开始支持无阻塞，但是如何在webflux中使用它呢？有演示吗？

Answer 1

[您可以使用WebClient向Github的列表存储库API进行GET请求的方法

public Flux<GithubRepo> listGithubRepositories(String username, String token) {
     return webClient.get()
            .uri("/user/repos")
            .header("Authorization", "Basic " + Base64Utils
                    .encodeToString((username + ":" + token).getBytes(UTF_8)))
            .retrieve()
            .bodyToFlux(GithubRepo.class);
}

[假设我们有一个名为GithubRepo的类，它确认Github的API响应，以上函数将返回GithubRepo对象的Flux。

Answer 2

[如果要查找阻塞的ObjectMapper，请在线程池（例如有限弹性）中尝试使用subscriptionOn方法。并用Mono.fromCallable

包裹