异步编程 - 适用于 Java 的 AWS 软件开发工具包
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

异步编程

使用同步异步方法都可以调用对 AWS 服务的操作。同步方法会阻止执行您的线程,直到客户端接收到服务的响应。异步方法会立即返回,并控制调用的线程,而不必等待响应。

由于异步方法在收到响应之前返回,所以需要通过某种方法在响应准备就绪时接收响应。AWS SDK for Java提供两种方式:Future 对象回调方法

Java Futures

AWS SDK for Java 中的异步方法会返回 Future 对象,其中包含之后 的异步操作的结果。

调用 Future isDone() 方法,确定该服务是否已提供响应对象。当响应准备好时,可以通过调用 Future get() 方法来获取响应对象。在应用程序继续处理其他任务时,可使用该机制定期轮询异步操作的结果。

以下示例演示一个调用 Lambda 函数的异步操作,该操作收到可包含 FutureInvokeResult 对象的 。仅当 InvokeResult 为 时,才会检索 isDone() 对象true

import com.amazonaws.services.lambda.AWSLambdaAsyncClient; import com.amazonaws.services.lambda.model.InvokeRequest; import com.amazonaws.services.lambda.model.InvokeResult; import java.nio.ByteBuffer; import java.util.concurrent.Future; import java.util.concurrent.ExecutionException; public class InvokeLambdaFunctionAsync { public static void main(String[] args) { String function_name = "HelloFunction"; String function_input = "{\"who\":\"AWS SDK for Java\"}"; AWSLambdaAsync lambda = AWSLambdaAsyncClientBuilder.defaultClient(); InvokeRequest req = new InvokeRequest() .withFunctionName(function_name) .withPayload(ByteBuffer.wrap(function_input.getBytes())); Future<InvokeResult> future_res = lambda.invokeAsync(req); System.out.print("Waiting for future"); while (future_res.isDone() == false) { System.out.print("."); try { Thread.sleep(1000); } catch (InterruptedException e) { System.err.println("\nThread.sleep() was interrupted!"); System.exit(1); } } try { InvokeResult res = future_res.get(); if (res.getStatusCode() == 200) { System.out.println("\nLambda function returned:"); ByteBuffer response_payload = res.getPayload(); System.out.println(new String(response_payload.array())); } else { System.out.format("Received a non-OK response from AWS: %d\n", res.getStatusCode()); } } catch (InterruptedException | ExecutionException e) { System.err.println(e.getMessage()); System.exit(1); } System.exit(0); } }

异步回调

除了使用 Java Future 对象监控异步请求的状态之外,开发工具包还允许您实施使用 AsyncHandler 接口的类。AsyncHandler 提供两种方法,根据完成请求的方式进行调用:onSuccessonError

回调接口方法的主要优势是它让您无需轮询 Future 对象即可确定请求是否已完成。相反,您的代码能够立即开始其下一个活动,并由开发工具包在适当时调用处理程序。

import com.amazonaws.services.lambda.AWSLambdaAsync; import com.amazonaws.services.lambda.AWSLambdaAsyncClientBuilder; import com.amazonaws.services.lambda.model.InvokeRequest; import com.amazonaws.services.lambda.model.InvokeResult; import com.amazonaws.handlers.AsyncHandler; import java.nio.ByteBuffer; import java.util.concurrent.Future; public class InvokeLambdaFunctionCallback { private class AsyncLambdaHandler implements AsyncHandler<InvokeRequest, InvokeResult> { public void onSuccess(InvokeRequest req, InvokeResult res) { System.out.println("\nLambda function returned:"); ByteBuffer response_payload = res.getPayload(); System.out.println(new String(response_payload.array())); System.exit(0); } public void onError(Exception e) { System.out.println(e.getMessage()); System.exit(1); } } public static void main(String[] args) { String function_name = "HelloFunction"; String function_input = "{\"who\":\"AWS SDK for Java\"}"; AWSLambdaAsync lambda = AWSLambdaAsyncClientBuilder.defaultClient(); InvokeRequest req = new InvokeRequest() .withFunctionName(function_name) .withPayload(ByteBuffer.wrap(function_input.getBytes())); Future<InvokeResult> future_res = lambda.invokeAsync(req, new AsyncLambdaHandler()); System.out.print("Waiting for async callback"); while (!future_res.isDone() && !future_res.isCancelled()) { // perform some other tasks... try { Thread.sleep(1000); } catch (InterruptedException e) { System.err.println("Thread.sleep() was interrupted!"); System.exit(0); } System.out.print("."); } } }

最佳实践

回调执行

AsyncHandler 的实施在异步客户端拥有的线程池内执行。简短、快速执行的代码在您的 AsyncHandler 实施内最适合。如果您的处理程序方法包含长时间运行的代码或阻码,会导致对异步客户端所使用线程池的争用,并阻止客户端执行请求。如果需要从回调开始一种长期运行的任务,请在新的线程或应用程序托管的线程池中让回调运行其任务。

线程池配置

AWS SDK for Java 中的异步客户端提供应当用于大多数应用程序的默认线程池。如果希望加强对线程池管理方式的控制,可以实施自定义 ExecutorService 并将其传递给AWS SDK for Java异步客户端。

例如,您可以提供一个 ExecutorService 实施,它使用自定义的 ThreadFactory 控制池中各个线程的命名方式,或者记录有关线程使用的更多信息。

Amazon S3 异步访问

开发工具包中的 TransferManager 类为使用 Amazon S3 提供异步支持。TransferManager 管理异步上传和下载、提供传输的详细进度报告并支持对不同事件的回调。