package org.jivesoftware.spark.util;import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;import org.apache.http.HttpResponse;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.concurrent.FutureCallback;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
import org.apache.http.impl.nio.client.HttpAsyncClients;
import org.jivesoftware.DebugPrint;
import org.jivesoftware.spark.SparkManager;//异步埋点数据采集工具类
public class HotClickAsync {static ExecutorService service = Executors.newSingleThreadExecutor(); //单一线程// 调用http请求。不阻塞主线程public static void SendRequest(final String event)throws InterruptedException, IOException {Runnable run = new Runnable() {@Overridepublic void run() {try {SendRequestAsync(event,SparkManager.getSessionManager().getUsername());} catch (InterruptedException e) {// TODO Auto-generated catch block
                    e.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch block
                    e.printStackTrace();}}};service.execute(run);}// 阻塞HTTP调用private static void SendRequestAsync(String event,String username)throws InterruptedException, IOException {RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(1000) // http超时.setConnectTimeout(1000).build(); // 连接超时CloseableHttpAsyncClient httpclient = HttpAsyncClients.custom().setDefaultRequestConfig(requestConfig).build();try {httpclient.start();final HttpGet[] requests = new HttpGet[] { new HttpGet("http://XXXXXX.cn:81/HotClick.aspx?event="+ event +"&username="+username) // 第一个采集地址// , new HttpGet("http://mta.qq.com")//第二个采集地址, http://mta.qq.com/
            };// 同步计数final CountDownLatch latch = new CountDownLatch(requests.length);for (final HttpGet request : requests) {httpclient.execute(request, new FutureCallback<HttpResponse>() {@Overridepublic void completed(final HttpResponse response) {latch.countDown();DebugPrint.outStirng(request.getRequestLine() + "####->"+ response.getStatusLine());}@Overridepublic void failed(final Exception ex) {latch.countDown();DebugPrint.outStirng(request.getRequestLine() + "####->" + ex);}@Overridepublic void cancelled() {latch.countDown();//DebugPrint.outStirng(request.getRequestLine()//        + " cancelled");
                    }});}latch.await();} finally {httpclient.close();}DebugPrint.outStirng(" ###  HotClickAsync Done ###");}}