从反应式spring启动应用程序调用非反应式遗留服务？

Question

我面临的问题是，有一个服务，我必须调用，这是一个传统的Spring启动应用程序，而不是反应性的！

下面是一个示例endpoint，它接近上述遗留系统的想法：

@RequestMapping(value = "/people/**", method = RequestMethod.GET)
public ResponseEntity<InputStreamResource> getPerson(HttpServletRequest request) {
    String pattern = (String) request.getAttribute(HandlerMapping.BEST_MATCHING_PATTERN_ATTRIBUTE);
    String key = new AntPathMatcher().extractPathWithinPattern(pattern, request.getRequestURI());
    
        return personService.getPersonByKey(key);
    }

我知道我不能用这个来实现真正的反应性善，有没有一个快乐的非阻塞和阻塞的媒介我可以在这里实现？

谢谢

Answer 1

当您使用WebClient从SpringWebFlux应用程序调用服务时，它将以反应式非阻塞方式工作。这意味着您可以在应用程序上实现真正的反应性优点。在上游服务返回响应之前，线程不会被阻塞。

下面是使用WebClient调用服务的示例代码：

WebClient webClient = WebClient.create("http://localhost:8080");

Mono<Person> result = webClient.get()
    .uri("/people/{id}")
    .retrieve()
    .bodyToMono(Person.class);