用于从AKKA发送非阻塞http请求的Java示例

问题描述

在AKKA文档中写道

I have found the following information at the moment :

1. 我读了并在

I发现以下文章解释如何使用非阻止http客户端与akka。但是用Scala编写。

I found following article http://nurkiewicz.blogspot.de/2012/11/non-blocking-io-discovering-akka.html explaining how to use https://github.com/AsyncHttpClient/async-http-client non blocking http client with akka. But is written in Scala.

我如何编写一个制作非阻塞http请求的演员？

How can i write an actor that make non-blocking http requests?

它必须将远程URL页面作为文件，而不是将生成的文件对象发送给主actor。然后主actor将此请求发送给解析器actor以解析文件...

It must downlad a remote url page as file and than send the generated file object to the master actor. master actor then sends this request to parser actor to parse the file...

推荐答案

我已经以这种方式实现了这一点。

I have implemented this in this way.

public class ReduceActor extends UntypedActor {
@Override
public void onReceive(Object message) throws Exception {
    if (message instanceof URI) {
        URI url = (URI) message;

        AsyncHttpClient asyncHttpClient = new AsyncHttpClient();

        asyncHttpClient.prepareGet(url.toURL().toString()).execute(new AsyncCompletionHandler<Response>() {

            @Override
            public Response onCompleted(Response response) throws Exception {
                File f = new File("e:/tmp/crawler/" + UUID.randomUUID().toString() + ".html");
                // Do something with the Response
                // ...
                // System.out.println(response1.getStatusLine());
                FileOutputStream fao = new FileOutputStream(f);
                IOUtils.copy(response.getResponseBodyAsStream(), fao);
                System.out.println("File downloaded " + f);
                getSender().tell(new WordCount(f));
                return response;
            }

            @Override
            public void onThrowable(Throwable t) {
                // Something wrong happened.
            }
        });
    } else
        unhandled(message);
}

这篇关于用于从AKKA发送非阻塞http请求的Java示例的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！