Vertx客户端正在花时间检查故障

Question

我有一个要求，我通过Vertx客户端将一个微服务连接到其他微服务。在代码中，我正在检查另一个微服务是否关闭，然后在失败时它应该创建一些JsonObject，其中solrError为键，失败消息为值。如果有solr错误，我的意思是如果其他微服务关闭，通过负载平衡调用solr，那么它应该会抛出一些错误响应。但是Vertx客户端需要一些时间来检查失败，当条件被检查时，jsonject中没有solrError，因为Vertx客户端需要一些时间来检查失败，所以条件失败，resp为空。为了避免这种情况，可以做些什么，以便Vertx客户端在检查solrError的条件之前失败并返回内部服务器错误响应？

下面是代码：

 solrQueryService.executeQuery(query).subscribe().with(jsonObject -> {
        ObjectMapper objMapper = new ObjectMapper();
        SolrOutput solrOutput = new SolrOutput();
        List<Doc> docs = new ArrayList<>();
        try {
            if(null != jsonObject.getMap().get("solrError")){
             resp = Response.status(Response.Status.INTERNAL_SERVER_ERROR)
                        .entity(new BaseException(
                                exceptionService.processSolrDownError(request.header.referenceId))
                                        .getResponse()).build();
            }
            solrOutput = objMapper.readValue(jsonObject.toString(), SolrOutput.class);
            if (null != solrOutput.getResponse()
                    && CollectionUtils.isNotEmpty(solrOutput.getResponse().getDocs())) {
                docs.addAll(solrOutput.getResponse().getDocs());
                                    uniDocList  = Uni.createFrom().item(docs);
            }
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
    });
    
    if(null!=resp && resp.getStatus() !=200) {
        return resp ;
    }
    
    SolrQueryService is preparing query and send out URL and query to Vertx web client as below :
    
    public Uni<JsonObject> search(URL url, SolrQuery query,Integer timeout) {
    int port = url.getPort();
    if (port == -1 && "https".equals(url.getProtocol())) {
        port = 443;
    }
    if (port == -1 && "http".equals(url.getProtocol())) {
        port = 80;
    }
    HttpRequest<Buffer> request = client.post(port, url.getHost(), url.getPath()).timeout(timeout);
    return request.sendJson(query).map(resp -> {
        return resp.bodyAsJsonObject();
    }).onFailure().recoverWithUni(f -> {
        return Uni.createFrom().item(new JsonObject().put("solrError", f.getMessage()));
    });

}

Answer 1

我没有使用Vertx客户端，但假设它是被动的和非阻塞的。假设是这样，您的代码似乎混合了命令式和反应式构造。第一行中的subscribe是被动的，当服务器响应客户端请求时，将调用您提供的lambda。然而，在订阅之后，您有了在lambda甚至有机会被调用之前运行的命令式代码，因此您对“resp”对象的检查和访问永远不会是lambda本身发生的事情的结果。

您需要将所有代码移动到lambda中，或者至少在订阅的结果上生成后续代码链。