在JAX-RS中处理异步请求中的超时

JAX-RS 2.0在客户端和服务器端都支持异步编程范例。这篇文章重点介绍了使用JAX-RS（2.0）API在服务器端执行异步REST请求时的超时功能

无需过多介绍，这里是一个快速概述。为了以异步方式执行方法，您只需

需要指定AsyncResponse接口的实例作为方法参数之一
使用@Suspended批注对其进行批注（只要 JAX-RS检测到此批注，JAX-RS就会为您注入AsyncResponse的实例）
需要在不同的线程中调用请求–在Java EE 7中推荐的方法是使用托管服务执行程序

@GET
@Produces("text/plain")
public void execute(@Suspended AsyncResponse response){System.out.println("Initially invoked on thread - "+ Thread.currentThread.getName() + ". This will free up soon !");new Thread(){@Overridepublic void run(){response.resume("executed asynchronously on thread - "+ Thread.currentThread.getName());}}.start();
}//JDK 8 version - passing a Runnable (in form of a Lambda Expression) to a thread@GET
@Produces("text/plain")
public void execute(@Suspended AsyncResponse response){System.out.println("Initially invoked on thread - "+ Thread.currentThread.getName() + ". This will free up soon !");new Thread(() -> response.resume("executed asynchronously on thread - "+ Thread.currentThread().getName())).start();
}

在幕后？

服务器和客户端之间的基础I / O连接不受影响。但是在某些情况下，您可能不希望客户端永远等待响应。在这种情况下，您可以分配超时（阈值）

超时的默认行为是HTTP 503响应。如果要覆盖此行为，则可以实现TimeoutHandler并将其注册到AsyncResponse。如果您使用的是Java 8，则无需麻烦使用单独的实现类甚至是匿名内部类-您只需提供Lambda表达式即可，因为TimeoutHandler是具有单个抽象方法的功能接口

@GET
@Produces("text/plain")
public void execute(@Suspended AsyncResponse response){System.out.println("Initially invoked on thread - "+ Thread.currentThread.getName() + ". This will free up soon !");//just having this would result in HTTP 503 after 10 secondsresponse.setTimeout(10, TimeUnit.SECONDS); //client will recieve a HTTP 408 (timeout error) after 10 secondsresponse.setTimeoutHandler((asyncResp) -> asyncResp.resume(Response.status(Response.Status.REQUEST_TIMEOUT)).build());new Thread(() -> {try {Thread.sleep(11000);} catch (InterruptedException ex) {//ignoring}}).start();
}

干杯!