public static void main(String[] args) throws Exception{
RequestModel r = new RequestModel();
r.setTimestamp("123");
RequestModel model = new RequestModel();
model.setIdentityCard("310103198802264029");
model.setFamilyAddress("中国");
long start = System.currentTimeMillis();
try {
int pagecount = 300;
ExecutorService executors = Executors.newFixedThreadPool(pagecount);
CountDownLatch countDownLatch = new CountDownLatch(pagecount);
for (int i = 0; i < pagecount; i++) {
String requestInfo = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"+
"<Agw direction=\"request\"><Head><Trade>829401</Trade><App>000001</App><Channel>EAPCM</Channel>"+
"</Head><Body><field name=\"user_no\">310103198802264029</field><field name=\"address\">中国Demo+"+i+"</field>"+
"<field name=\"channel\">01</field></Body></Agw>";
// 启动线程抓取
executors.execute(new GetRunnable(requestInfo, countDownLatch,i));
}
countDownLatch.await();
executors.shutdown();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
System.out.println("线程" + Thread.currentThread().getName() + "," + System.currentTimeMillis() + ", 所有线程已完成，开始进入下一步！");
}
long end = System.currentTimeMillis();
System.out.println("consume -> " + (end - start));
}
static class GetRunnable implements Runnable {
private CountDownLatch countDownLatch;
private String requestInfo;
private int cou;
public GetRunnable(String requestInfo, CountDownLatch countDownLatch,int cou) {
this.requestInfo = requestInfo;
this.countDownLatch = countDownLatch;
this.cou = cou;
}
@Override
public void run() {
try {
try {
System.out.println("++++++++++"+requestInfo+"+++++++++++");
System.out.println(sendSPDBData(requestInfo));
System.out.println("============"+cou+"=============");
} catch (Exception e) {
e.printStackTrace();
}
} finally {
countDownLatch.countDown();
}
}
}
