java - AsyncHttpClient 可以执行非阻塞、异步 HTTP 调用吗?

标签 java netty asynchttpclient

全部,

我正在尝试决定是为我的应用程序使用 NodeJS 还是 Java。我将通过 HTTP 与 CouchDB 通信,并希望采用异步非阻塞设计,在这种设计中,我的应用程序线程可以在等待来自 CouchDB 的查询响应时处理其他请求。

我更愿意使用 Java,几天来我一直在研究 AsyncHttpClient 作为一个潜在的解决方案。但是,我在理解这个库时遇到了一些困难,我想我可能对某些事情有根本性的误解。

我在这里发布了一个要点:https://gist.github.com/conorgil/5505603

我希望这个要点打印出“Request X sent!”以及每个请求的“响应 X:某物”。但是,似乎在每个 Future 调用 get() 之前不会进行 HTTP 调用(因此,不会执行处理程序)。取消注释第 23 行 f.get() 使代码按预期工作,但对 Future#get() 的调用是阻塞的,对吗?有没有一种方法可以只提供一个回调函数,一旦 HTTP 响应被完全检索而不会阻塞,该回调函数就会被执行?

类似下面的内容: 1)请求进入主线程 2) 对 CouchDB 进行异步、非阻塞 HTTP 调用。完成处理程序已注册以处理来自 CouchDB 的响应 3) 主线程现在可以自由处理下一个请求 4) 来自 CouchDB 的 HTTP 响应到达某个点,注册的处理程序被调用以执行一些业务逻辑 5) 主线程继续处理请求(对于不需要打CouchDB的请求,可以很快响应)

我是不是从根本上误解了什么?有可能在 Java 中做这种事情吗? AsyncHttpClient 是答案吗?这个问题是相关的,但不确定自 2011 年以来情况是否发生了变化(Perform Async Connect with Java AsyncHttpClient Library?)

由于 NodeJS 运行事件循环,因此这种非阻塞、异步行为是标准的。您只需注册一个回调函数来在收到数据库响应时处理它,同时事件循环只会处理其他事情。

感谢任何和所有建议。

谢谢, 康纳

最佳答案

AsyncHttpClient 的主要目的是非阻塞 HTTP,我已经成功地使用它达到了这个效果。例如,我运行了您代码的这个简化版本:

public class MyAsyncHttpClientTest {
  public static void main(String[] args) throws Exception {
    AsyncHttpClient asyncHttpClient = new AsyncHttpClient();
    for (int i = 0; i < 10; i++) {
      asyncHttpClient.prepareGet("http://www.google.com")
        .execute(new CompletionHandler(i));
      System.out.println(String.format("Request %d sent! ", i));
      System.out.flush();
    }
  }
  static class CompletionHandler extends AsyncCompletionHandler<Void> {
    private final int reqNumber;
    public CompletionHandler(int reqNumber) { this.reqNumber = reqNumber; }
    @Override public Void onCompleted(Response response) throws Exception {
      System.out.println(String.format("Response %d: %s", reqNumber,
          response.getResponseBody()));
      return null;
    }
  }
}

注意不涉及 future 。正如人们所期望的那样,它会产生以下输出:

Request 0 sent! 
Request 1 sent! 
Request 2 sent! 
Request 3 sent! 
Request 4 sent! 
Request 5 sent! 
Request 6 sent! 
Request 7 sent! 
Request 8 sent! 
Request 9 sent! 
Response 1: <HTML><HEAD><meta http-equiv="content-type" content="text/html;charset=utf-8">
<TITLE>302 Moved</TITLE></HEAD><BODY>
<H1>302 Moved</H1>
The document has moved
<A HREF="http://www.google.hr/">here</A>.
</BODY></HTML>

Response 0: <HTML><HEAD><meta http-equiv="content-type" content="text/html;charset=utf-8">
<TITLE>302 Moved</TITLE></HEAD><BODY>
<H1>302 Moved</H1>
The document has moved
<A HREF="http://www.google.hr/">here</A>.
</BODY></HTML>

...

唯一的问题是,由于没有关闭客户端的代码,所以进程挂起,但那是另外一回事了。

关于java - AsyncHttpClient 可以执行非阻塞、异步 HTTP 调用吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16349797/

相关文章:

java - 使用 jslider 播放声音以监视流声音/音乐的长度

java - Java 注解会影响运行时性能吗?

multithreading - 每个连接的 Netty 多线程

java - 当我使用 ReplaySubject 中的 Observable 时阻止 ChannelHandlerContext

apache-beam - 如何使用 Apache Beam (Java) 进行异步 Http 调用?

java - Matlab deploytool 可以编译带有 javax.swing 元素的文件吗?

java - 标准生成器 转换 下限

java - 使用 Netty 的异步 HTTP 客户端

ssl - 宁异步http客户端如何接受任何证书

java - 如何使用 AsyncHttpClient 构建 URL?