【连载 32】HTTP异步客户端
【连载 32】HTTP异步客户端
前面讲解了使用Java进行HTTP请求的基础，有一个隐含条件：基于同步的HttpClient。这是因为在性能测试实践当中，绝大部分都是同步客户端，有以下几个优势：
（1）使用简单：同步客户端遵循HTTP协议的工作流，编写代码流程清楚，过程简单，新手也能快速上手，可谓是"一看就懂，一学就会"。 （2）数据统计方便：统计响应的耗时等数据就像"探囊取物"，使用时间戳相减即可完成，简单直接。 （3）安全性好：同步客户端天生具备线程安全特性，大大降低了程序出现安全问题的风险，让测试更稳健。 （4）可控性好：性能测试中，我们可以通过灵活使用自定义线程池来控制并发，对测试过程"收放自如"。
虽然同步客户端有如此多优点，但异步客户端依然在特定场景下"大显身手"。其核心优势就是高性能。异步HTTP客户端支持同步和异步操作，使用异步功能时，允许在发送HTTP请求时不阻塞当前线程，当请求完成后，可以通过org.apache.http.concurrent.FutureCallback或者java.util.concurrent.Future来处理响应结果。除了在性能测试中大放异彩外，异步客户端也常用于HTTP接口自动化测试，通过提升请求速率来显著缩短用例执行时间。
异步HTTP客户端的使用跟同步HTTP客户端大部分类都是通用的，主要区别集中在创建和执行请求的方法上。创建异步客户端用的是org.apache.http.impl.nio.client.HttpAsyncClients类，与org.apache.http.impl.client.CloseableHttpClient相比，API设计大同小异，可以相互对照学习。这里我们直接使用org.apache.http.impl.nio.client.HttpAsyncClients#createDefault方法创建HTTP异步客户端。
首先要引入异步客户端的依赖：
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpasyncclient</artifactId>
<version>4.1.5</version>
</dependency>
需要注意的是，不同版本的依赖可能有所不同，在最新的HttpClient5中，已经集成了异步客户端的代码。
1. FutureCallback方式
public class FunTesterAsyncCallbackDemo {
public static void main(String[] args) throws IOException, InterruptedException {
CloseableHttpAsyncClient httpAsyncClient = HttpAsyncClients.createDefault();
httpAsyncClient.start();
JSONObject params = new JSONObject();
params.put("start", 0);
params.put("pageSize", 10);
HttpGet httpGet = HttpRequestTool.getHttpGet("http://localhost:8080/query", params);
httpAsyncClient.execute(httpGet, new FutureCallback<HttpResponse>() {
@Override
public void completed(HttpResponse httpResponse) {
try {
String response = EntityUtils.toString(httpResponse.getEntity());
System.out.println(Thread.currentThread().getName() + " FunTester响应：" + response);
} catch (IOException e) {
thrownew RuntimeException(e);
}
}
@Override
public void failed(Exception e) {
System.out.println("FunTester请求失败：" + e.getMessage());
}
@Override
public void cancelled() {
System.out.println("FunTester请求取消");
}
});
Thread.sleep(1000);
httpAsyncClient.close();
}
}
最后等待了1000毫秒是为了确保能看到控制台打印日志。从输出可以看出响应处理并非由main线程执行：
I/O dispatcher 1 FunTester响应：{"code":0,"msg":"hello FunTester"}
腾讯云开发者
