【连载 32】HTTP异步客户端

admin管理员组

文章数量:1440220

【连载 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异步客户端。

首先要引入异步客户端的依赖：

代码语言：javascript代码运行次数：0运行复制

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpasyncclient</artifactId>
    <version>4.1.5</version>
</dependency>

需要注意的是，不同版本的依赖可能有所不同，在最新的HttpClient5中，已经集成了异步客户端的代码。

1. FutureCallback方式

代码语言：javascript代码运行次数：0运行复制

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线程执行：

代码语言：javascript代码运行次数：0运行复制

I/O dispatcher 1  FunTester响应：{"code":0,"msg":"hello FunTester"}

本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。原始发表：2025-04-13，如有侵权请联系 cloudcommunity@tencent 删除http性能测试客户端同步异步

本文标签： 连载 32HTTP异步客户端