java - WLP MicroProfile (FaultTolerance) 超时实现不会中断线程？

Question

我正在测试 websphere liberty 的容错(microprofile)实现。因此，我制作了一个简单的 REST 服务，其中的资源会 hibernate 5 秒:

 @Path("client")
 public class Client {

      @GET
      @Path("timeout")
      public Response getClientTimeout() throws InterruptedException {
          Thread.sleep(5000);
          return Response.ok().entity("text").build();
      }
 }

我在另一个 REST 服务的同一应用程序中调用此客户端:

 @Path("mpfaulttolerance")
 @RequestScoped
 public class MpFaultToleranceController {

      @GET
      @Path("timeout")
      @Timeout(4)
      public Response getFailingRequest() {
          System.out.println("start");
          // calls the 5 seconds-ressource; should time out
          Response response = ClientBuilder.newClient().target("http://localhost:9080").path("/resilience/api/client/timeout").request().get();
          System.out.println("hello");
      }
 }

现在我预计 getFailingRequest() 方法会在 4 毫秒后超时并抛出异常。实际行为是应用程序打印“start”，等待 5 秒直到客户端返回，打印“hello”，然后抛出“org.eclipse.microprofile.faulttolerance.exceptions.TimeoutException”。

我打开了更多调试信息:

<logging traceSpecification="com.ibm.ws.microprofile.*=all" />

在 server.xml 中。我得到这些信息，即使在调用客户端之前也已注册超时!但线程并没有被中断。

(如果有人告诉我如何在这里获得漂亮的堆栈跟踪......我可以做到。)

因为这是一个非常基本的例子:我在这里做错了什么吗？我该怎么做才能使这个例子正常运行。

谢谢

编辑:在 WebSphere Application Server 18.0.0.2/wlp-1.0.21.cl180220180619-0403) auf Java HotSpot(TM) 64 位服务器 VM，版本 1.8.0_172-b11 (de_DE) 上运行此示例，具有以下功能webProfile-8.0、mpFaultTolerance-1.0 和 localConnector-1.0。

编辑:解决方案，感谢 Andy McCright 和 Azquelt。由于调用不能被中断，我必须使其异步。所以你有 2 个线程:第一个线程通过调用调用第二个线程。第一个线程将被中断，第二个线程将保留直到调用完成。但现在您可以继续进行故障处理、打开电路等，以防止进一步调用损坏的服务。

@Path("mpfaulttolerance")
@RequestScoped
public class MpFaultToleranceController {

    @Inject
    private TestBase test;

    @GET
    @Path("timeout")
    @Timeout(4)
    public Response getFailingRequest() throws InterruptedException, ExecutionException {
        Future<Response> resp = test.createFailingRequestToClientAsynch();
        return resp.get();
    }
}

客户端调用:

@ApplicationScoped
public class TestBase {

    @Asynchronous
    public Future<Response> createFailingRequestToClientAsynch() {
        Response response = ClientBuilder.newClient().target("http://localhost:9080").path("/resilience/api/client/timeout").request().get();
        return CompletableFuture.completedFuture(response);
    }
}

Answer 1

它确实使用 Thread.interrupt() 中断线程，但遗憾的是并非所有 Java 操作都会响应线程中断。

很多东西确实通过抛出 InterruptedException 来响应中断(例如 Thread.sleep() 、 Object.wait() 、 Future.get() 和 InterruptableChannel 的子类)，但 InputStreams 和 Sockets 不会。

我怀疑您(或您用来发出请求的库)正在使用不可中断的 Socket，因此您不会看到您的方法提前返回。

这特别不直观，因为 Liberty 的 JAX-RS 客户端不会响应 Andy McCright 提到的线程中断。我们知道情况不太好，我们正在努力改善情况。