获取microservice中的连接超时错误

Question

我已经使用Java8和SpringBoot 2构建了一个微服务。在此微服务中，我试图使用另一个REST API服务。但是，我得到以下错误在Chrome。我已经禁用了Windows防火墙和McAfee防病毒防火墙，但仍然得到相同的错误。我可以直接使用Postman工具调用REST API，但不能通过我的微服务。

错误：-

JAVAlang.IllegalStateException：底层HTTP客户端已完成，但未发出响应。

2018-06-12 15:21:29.300错误17996---[ctor-http-nio-3]。a、 w.r.e.DefaultErrorWebExceptionHandler:无法处理请求[GET]http://localhost:8080/category/search]木卫一。内蒂。频道AbstractChannel$AnnotatedConnectionException:连接超时：无进一步信息：测试。usdemo。xyz。com/92.54.41.24:443在太阳。尼奥。索克坦林普尔主教。选中连接（本机方法）~[na:1.8.0_171]在sun。尼奥。索克坦林普尔主教。在io上完成连接（socketchannelmpl.java:717）~[na:1.8.0_171]。内蒂。频道插座尼奥。NioSocketChannel。doFinishConnect（NioSocketChannel.java:325）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]位于io。内蒂。频道尼奥。AbstractNioChannel$AbstractNioSafe。finishConnect（AbstractNioChannel.java:340）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]。内蒂。频道尼奥。NioEventLoop。processSelectedKey（NioEventLoop.java:633）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]。内蒂。频道尼奥。NioEventLoop。processSelectedKeysOptimized（NioEventLoop.java:580）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]。内蒂。频道尼奥。NioEventLoop。在io上处理SelectedKeys（NioEventLoop.java:497）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]。内蒂。频道尼奥。NioEventLoop。在io上运行（NioEventLoop.java:459）~[netty-transport-4.1.24.Final.jar:4.1.24.Final]。内蒂。util。同时发生的SingleThreadEventExecutor$5。在java上运行（SingleThreadEventExecutor.java:884）~[netty-common-4.1.24.Final.jar:4.1.24.Final]。朗。丝线。运行（Thread.java:748）~[na:1.8.0_171]由：java引起。网ConnectException:连接超时：无进一步信息。。。省略10个公共框架

控制器类：-

@RestController
public class CategorySearchController {

    private final CategorySearchService categorySearchService;

    @Autowired
    public CategorySearchController(CategorySearchService categorySearchService) {
        this.categorySearchService = categorySearchService;
    }


    @GetMapping(path = "/search-category")
    public Mono<CategoryResponse> searchCategories(SearchRequest categorySearchRequest){
        return categorySearchService
                .searchCategories()
                .switchIfEmpty(Mono.error(
                        new EntityNotFoundException("No category matching " + categorySearchRequest.getSearchTerm() + " was found")));
    }

}

服务类别：-

@Service
public class CategorySearchServiceImpl implements CategorySearchService {
    private String baseUrl = "https://demo0954903.mockable.io";

    @Override
    public Mono<CategoryResponse> searchCategories() {
        WebClient webClient = WebClient.create(baseUrl);
        return webClient.
                 get()
                .uri("/category-search")
                .retrieve()
                .bodyToMono(CategoryResponse.class);
    }
}

Answer 1

我找到了解决这个问题的方法。我需要添加代理在网络客户端如下：-

private final WebClient webClient;
ReactorClientHttpConnector connector = new ReactorClientHttpConnector(
                options -> options.httpProxy(addressSpec -> {
                return addressSpec.host(PROXY_HOST).port(PROXY_PORT);
                }));

        this.webClient = webClientBuilder.baseUrl(BASE_URL).clientConnector(connector).build();