병렬 GET 요청을 보내고 결과 응답을 기다리는 방법은 무엇입니까?

Question

스프링 mvc 3.2.2에서 apache http 클라이언트를 사용하여 그림과 같이 get get requests를 동 기적으로 보냅니다.

어떻게 (병렬) 비동기 적으로이 모두를 전송하고 요청이 GET 요청을 모두로부터 분석 된 페이로드 문자열을 반환하기 위해 돌아 기다릴 수 ? 그냥 일반적으로

public String myMVCControllerGETdataMethod() 
{ 
    // Send 1st request 
    HttpClient httpclient = new DefaultHttpClient(); 
    HttpGet httpget = new HttpGet("http://api/data?type=1"); 
    ResponseHandler<String> responseHandler = new BasicResponseHandler(); 
    String responseBody = httpclient.execute(httpget, responseHandler); 

    // Send 2st request 
    HttpClient httpclient2 = new DefaultHttpClient(); 
    HttpGet httpget2 = new HttpGet("http://api/data?type=2"); 
    ResponseHandler2<String> responseHandler2 = new BasicResponseHandler(); 
    String responseBody2 = httpclient.execute(httpget, responseHandler2); 

    // o o o more gets here 

    // Perform some work here...and wait for all requests to return 
    // Parse info out of multiple requests and return 
    String results = doWorkwithMultipleDataReturned(); 

    model.addAttribute(results, results); 
    return "index"; 

} 

Answer 1

, 당신은 Runnable 또는 java.util.concurrent.Callable에서 작업 귀하의 단위를 캡슐화하고 java.util.concurrent.Executor (또는 org.springframework.core.task.TaskExecutor)을 통해 그것들을 실행해야합니다. 이를 통해 각 작업 단위 (일반적으로 비동기식)가 별도로 실행될 수 있습니다 (Executor의 구현에 따라 다름). 이 코드는 테스트되지 않았 음을

import java.util.ArrayList; 
import java.util.Iterator; 
import java.util.List; 
import java.util.concurrent.Callable; 
import java.util.concurrent.Executor; 
import java.util.concurrent.FutureTask; 
import org.apache.http.client.methods.HttpGet; 
import org.apache.http.impl.client.BasicResponseHandler; 
import org.apache.http.impl.client.DefaultHttpClient; 
import org.springframework.stereotype.Controller; 
import org.springframework.ui.Model; 
import org.springframework.web.bind.annotation.RequestMapping; 

@Controller 
public class MyController { 
    //inject this 
    private Executor executor; 

    @RequestMapping("/your/path/here") 
    public String myMVCControllerGETdataMethod(Model model) { 
     //define all async requests and give them to injected Executor 
     List<GetRequestTask> tasks = new ArrayList<GetRequestTask>(); 
     tasks.add(new GetRequestTask("http://api/data?type=1", this.executor)); 
     tasks.add(new GetRequestTask("http://api/data?type=2", this.executor)); 
     //... 
     //do other work here 
     //... 
     //now wait for all async tasks to complete 
     while(!tasks.isEmpty()) { 
      for(Iterator<GetRequestTask> it = tasks.iterator(); it.hasNext();) { 
       GetRequestTask task = it.next(); 
       if(task.isDone()) { 
        String request = task.getRequest(); 
        String response = task.getResponse(); 
        //PUT YOUR CODE HERE 
        //possibly aggregate request and response in Map<String,String> 
        //or do something else with request and response 
        it.remove(); 
       } 
      } 
      //avoid tight loop in "main" thread 
      if(!tasks.isEmpty()) Thread.sleep(100); 
     } 
     //now you have all responses for all async requests 

     //the following from your original code 
     //note: you should probably pass the responses from above 
     //to this next method (to keep your controller stateless) 
     String results = doWorkwithMultipleDataReturned(); 
     model.addAttribute(results, results); 
     return "index"; 
    } 

    //abstraction to wrap Callable and Future 
    class GetRequestTask { 
     private GetRequestWork work; 
     private FutureTask<String> task; 
     public GetRequestTask(String url, Executor executor) { 
      this.work = new GetRequestWork(url); 
      this.task = new FutureTask<String>(work); 
      executor.execute(this.task); 
     } 
     public String getRequest() { 
      return this.work.getUrl(); 
     } 
     public boolean isDone() { 
      return this.task.isDone(); 
     } 
     public String getResponse() { 
      try { 
       return this.task.get(); 
      } catch(Exception e) { 
       throw new RuntimeException(e); 
      } 
     } 
    } 

    //Callable representing actual HTTP GET request 
    class GetRequestWork implements Callable<String> { 
     private final String url; 
     public GetRequestWork(String url) { 
      this.url = url; 
     } 
     public String getUrl() { 
      return this.url; 
     } 
     public String call() throws Exception { 
      return new DefaultHttpClient().execute(new HttpGet(getUrl()), new BasicResponseHandler()); 
     } 
    } 
} 

참고 :

그래서 특정 문제에 대한, 당신이 뭔가를 할 수 있습니다.

Executor 구현의 경우 Spring's TaskExecutor 및 task:executor namespace을 확인하십시오. 매번 새로운 스레드를 만드는 대신에이 유스 케이스에 재사용 가능한 스레드 풀이 필요할 것이다.

Answer 2

AsyncHttpClient를 사용해야합니다. 원하는 수의 요청을 할 수 있으며 응답을 받으면 다시 전화를 겁니다. 만들 수있는 연결 수를 구성 할 수 있습니다. 모든 스레딩은 라이브러리에 의해 처리되므로 스레드를 직접 관리하는 것보다 훨씬 쉽습니다.

여기 봐에게 예제를 가지고 : https://github.com/AsyncHttpClient/async-http-client