<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    少年阿賓

    那些青春的歲月

      BlogJava :: 首頁 :: 聯(lián)系 :: 聚合  :: 管理
      500 Posts :: 0 Stories :: 135 Comments :: 0 Trackbacks
    View Code
     package generate.httpclient;
     
     import java.io.ByteArrayOutputStream;
     import java.io.IOException;
     import java.io.InputStream;
     import java.util.ArrayList;
     import java.util.HashMap;
     import java.util.List;
     import java.util.Map;
     import java.util.concurrent.CountDownLatch;
     
     import org.apache.http.HttpResponse;
     import org.apache.http.client.methods.HttpGet;
     import org.apache.http.concurrent.FutureCallback;
     import org.apache.http.impl.nio.client.DefaultHttpAsyncClient;
     import org.apache.http.nio.client.HttpAsyncClient;
     import org.apache.http.nio.reactor.IOReactorException;
     
     public class AsynClient{
         /**
          * @param args
          * @throws IOReactorException
          * @throws InterruptedException
          */
         private List<String> urls;
         private HandlerFailThread failHandler;
         public AsynClient(List<String> list){
             failHandler=new HandlerFailThread();
             urls=list;
         }
         public Map<String,String> asynGet() throws IOReactorException,
                 InterruptedException {
             final HttpAsyncClient httpclient = new DefaultHttpAsyncClient();
             httpclient.start();
             int urlLength=urls.size();
             HttpGet[] requests = new HttpGet[urlLength];
             int i=0;
             for(String url : urls){
                 requests[i]=new HttpGet(url);
                 i++;
             }
             final CountDownLatch latch = new CountDownLatch(requests.length);
             final Map<String, String> responseMap=new HashMap<String, String>();
             try {
                 for (final HttpGet request : requests) {
                     httpclient.execute(request, new FutureCallback<HttpResponse>() {
     
                         public void completed(final HttpResponse response) {
                             latch.countDown();
                             responseMap.put(request.getURI().toString(), response.getStatusLine().toString());
                             try {
                                 System.out.println(request.getRequestLine() + "->"
                                         + response.getStatusLine()+"->");
                                 //+readInputStream(response.getEntity().getContent())
                                
                             } catch (IllegalStateException e) {
                                 failHandler.putFailUrl(request.getURI().toString(),
                                         response.getStatusLine().toString());
                                 e.printStackTrace();
                             } catch (Exception e) {
                                 failHandler.putFailUrl(request.getURI().toString(),
                                         response.getStatusLine().toString());
                                 e.printStackTrace();
                             }
                         }
     
                         public void failed(final Exception ex) {
                             latch.countDown();
                             ex.printStackTrace();
                             failHandler.putFailUrl(request.getURI().toString(),
                                     ex.getMessage());
                         }
     
                         public void cancelled() {
                             latch.countDown();
                         }
     
                     });
                 }
                 System.out.println("Doing...");
             } finally {
                 latch.await();
                 httpclient.shutdown();
             }
             System.out.println("Done");
             failHandler.printFailUrl();
             return responseMap;
         }
         private String readInputStream(InputStream input) throws IOException{
             byte[] buffer = new byte[128];
             int len = 0;
             ByteArrayOutputStream bytes = new ByteArrayOutputStream();
             while((len = input.read(buffer)) >= 0) {
                 bytes.write(buffer, 0, len);
             }
             return bytes.toString();
         }
         /**
          * Test
          * @param args
          */
         public static void main(String[] args) {
             List<String> urls=new ArrayList<String>();
             urls.add("         urls.add("         urls.add("         for(int i=0;i<10;i++){
                 urls.addAll(urls);
             }
             System.out.println(urls.size());
             AsynClient client=new AsynClient(urls);
             try {
                 client.asynGet();
             } catch (IOReactorException e) {
                 e.printStackTrace();
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
             System.out.println("done");
         }
     }
    主站蜘蛛池模板: 中国国语毛片免费观看视频| MM1313亚洲国产精品| 一个人免费观看www视频| 亚洲中文字幕在线无码一区二区 | 久久WWW免费人成—看片| 一级毛片在线观看免费| 国产精品亚洲片在线观看不卡| 亚洲精品国产福利片| 日韩精品无码免费一区二区三区| 色播在线永久免费视频| 国产亚洲中文日本不卡二区| 最近中文字幕大全免费版在线 | 日韩精品极品视频在线观看免费| 亚洲AV天天做在线观看| 亚洲第一男人天堂| 成熟女人特级毛片www免费| 亚洲精品夜夜夜妓女网| 国产午夜精品久久久久免费视| 亚洲国产精品福利片在线观看| 免费女人高潮流视频在线观看| 亚洲精品91在线| 在线观看视频免费国语| 久久亚洲日韩精品一区二区三区| 日韩成人精品日本亚洲| 亚洲国产V高清在线观看| 亚洲制服丝袜一区二区三区| 久久久久久久国产免费看| 亚洲AV无码码潮喷在线观看 | 免费福利视频导航| 亚洲欧美日韩一区二区三区在线| 免费国产综合视频在线看| 亚洲免费中文字幕| 国产成人精品高清免费| 在线观看免费黄色网址| 亚洲AV综合色区无码二区偷拍 | 四虎国产成人永久精品免费| 亚洲香蕉在线观看| 99久久久国产精品免费牛牛四川| 丁香婷婷亚洲六月综合色| 亚洲狠狠爱综合影院婷婷| 特级一级毛片免费看|