垂直。已写入x响应

Question

我面临着一个与垂直的问题。x、 当超时被触发时，它会生成一个响应，然后实际响应（需要10秒）出现并尝试进行响应，因此我得到：

JAVAlang.IllegalStateException：已写入响应

我是Vert的新手。x和我不确定想要的行为，我应该怎么做？，由于代码是异步的，我找不到检查响应是否已经发送的方法。

有没有办法做到这一点？

我有以下代码：

private void setExternalCallAccessibleWithCircuitBreaker() {

        CircuitBreaker breaker = CircuitBreaker.create("my-circuit-breaker", vertx,
                new CircuitBreakerOptions().setMaxFailures(3) // number of failure before opening the circuit
                        .setTimeout(1000) // consider a failure if the operation does not succeed in time
                        .setFallbackOnFailure(true) // do we call the fallback on failure
                        .setResetTimeout(10000) // time spent in open state before attempting to re-try
        );

        vertx.createHttpServer().requestHandler(req -> {

            // some code executing with the breaker
            // the code reports failures or success on the given future.
            // if this future is marked as failed, the breaker increased the
            // number of failures
            breaker.executeWithFallback(future -> {

                // call the external service
                WebClient client = WebClient.create(vertx);

                client.get(8080, "localhost", "/wait10Seconds").send(ar -> {
                    if (ar.succeeded()) {

                        HttpResponse<Buffer> response = ar.result();

                        System.out.println("Received response with status code" + response.statusCode());
                        System.out.println("response.bodyAsString()" + response.bodyAsString());

                        req.response().end(response.body());
                        future.complete();

                    } else {
                        System.out.println("Something went wrong " + ar.cause().getMessage());
                        req.response().end("error");
                        future.fail("not possible to complete the request");
                    }
                });

            }, (Throwable exception) -> {

                req.response().end("error " + exception.getMessage());
                return exception;

            }).setHandler(ar -> {
                // Get the operation result.
                System.out.println("ar: " + ar);
            });

        }).listen(8088);
        System.out.println("Running");
    }

Answer 1

我发现了这个方法，显然它是有效的：

if (!req.response().ended()) {
    req.response().end(response.body());
}