泽西岛：异步请求后立即响应

Question

我试图理解异步响应在Jersey上的工作方式。我阅读了新泽西文档(https://jersey.java.net/documentation/latest/async.html)的第10章，但它对我的问题没有帮助。这里关于stackoverflow的研究也没有得出令人满意的答案(这一点我可以理解)。

我试图做的与本文中的一个问题类似（使用http状态202进行异步操作）。我想使用HTML表单文档将一个大文件上传到服务器。在请求被发送到服务器之后，web服务应该立即响应状态202和URI，在请求完成后可以在该URI中找到文件。

在阅读了这篇文章之后，这似乎是可能的，但遗憾的是没有给出如何实现这种行为的提示。

我编写了一个小的web服务来测试功能:

    @Path("/test/async/")
    public class TestAsyncResponse {

        @GET
        @Path("get")
        public Response asyncGet(@Suspended final AsyncResponse response) {

            new Thread(new Runnable() {

                @Override
                public void run() {

                    DateFormat df = new SimpleDateFormat("dd/MM/yy HH:mm:ss");

                    System.out.println("#### thread started: " 
                                       + df.format(new Date()) + " ####");
                    String result = veryExpensiveOperation();
                    System.out.println("#### thread finished: " 
                                        + df.format(new Date()) + " ####");

                    response.resume(result);
                }

                private String veryExpensiveOperation() {

                    try {

                        Thread.sleep(10000);
                    } 
                    catch (InterruptedException e) {

                        e.printStackTrace();
                    }

                    return "Woke up!";
                }
            }).start();

            return Response.status(202).entity("Request accepted. " + 
                                        "Long running operation started")
                                        .build();
        }
    }

该服务可以工作，但作为响应，我在10秒等待后收到“唤醒！”消息，而不是202响应，这似乎是合乎逻辑的，因为AsyncACK是处理响应的消息（据我所知）。

在阅读文档后，我得到的印象是，这是应该发生的，因为泽西岛对异步服务器响应所做的一切就是将线程从响应线程池外包到另一个线程池，以释放处理时间，以便对服务进行更多响应。

所以我的两个问题是：我的理解是否正确，我可以使用异步服务器响应来获得所需的行为吗？

我尝试在不使用＜code＞异步响应

任何回应都非常感谢。

问候语

Answer 1

我最近经历了同样的痛苦。泽西岛一直声称它支持异步REST调用，但我认为这是不诚实的。事实上，一旦我开始找出正确的方法，泽西实际上就阻碍了我。

private static ExecutorService executorService = Executors.newFixedThreadPool( Integer.valueOf( numberOfThreads ) );

@POST
@Path("async")
@Consumes(MediaType.MULTIPART_FORM_DATA)
public Response async( @FormDataParam("file") InputStream inputStream,
        @FormDataParam("file") FormDataContentDisposition des ) throws Throwable {

    String uniqueID = UUID.randomUUID().toString();
    executorService.execute( new Runnable() {

        @Override
        public void run() {
            try {
               // do long performing action
            } catch (Exception ex) {
            }
        }            

   } );
   return Response.accepted().location( getResultsURI( uniqueID ) ).build();
}

@GET
@Path("results/{uniqueID}")
@Produces("application/zip")
public Response results( @PathParam(value = "uniqueID ") String uniqueID ) {

   // Check status of job
   // If not finished...
   if (notFinished) {
   return Response.status( 202 ).location( getResultsURI( uniqueID ) )
                .entity( status ).build();
   }

   return Response.ok( FileUtils.readFileToByteArray( zip.toFile() ) ).type( "application/zip" )
            .header( "Content-Disposition", "attachment; filename=\"filename.zip\"" ).build();
  }

protected URI getResultsURI( String uniqueID ) throws URISyntaxException {
    return new URI( Constants.WS_VERSION + "/results/" + uniqueID );
}

最大的痛苦是当您设置Response.location()时，即使您将其设置为“./results”或“/results”，Jersey将其展开为完整的URL。这很好，只是它忽略了任何类级别的@Path:

@Path(Constants.WS_VERSION)
public class MyEndpoint {

因此，我没有与它作斗争，而是使用上面的代码来至少使其正确。理想情况下，我希望泽西岛不要使用“位置”标题。

总之，上面的代码就是我使用的代码（不包括业务逻辑位；）

Answer 2

你的问题混合了两个主题。

从HTTP的角度来看，202在技术上是一个完整的请求。而请求的结果是202，服务器告诉你它会在边上做。您必须发出另一个HTTP请求来获取更新的状态。

从应用程序的角度来看，异步意味着您将以单独的线程（或其他异步方式）执行请求。但是，这也意味着，在另一个“veryExpensiveOperation”完成之前，您不会返回结果，甚至不会返回202。跳过这个环的全部目的是释放调用线程。您的web服务器数量有限，例如20个，如果您的每个请求都花费了很长时间，那么所有20个请求都将挂起。使用@Suspended，您可以将执行从html" target="_blank">web服务器线程转移到其他方式（在您的情况下是另一个线程）。这实际上只是第一步。异步服务器背后的思想是，即使是非常昂贵的操作也是以某种异步方式实现的，因此等待数据库或文件不会占用整个线程。