Java模拟并发操作进行压力测试代码

 

 

 

 

 

 

import java.io.BufferedReader; 
　　import java.io.File; 
　　import java.io.FileInputStream; 
　　import java.io.InputStreamReader; 
　　import java.io.PrintWriter; 
　　import java.net.HttpURLConnection; 
　　import java.net.URL; 
　　import java.util.HashMap; 
　　import java.util.Map; 
　　import java.util.concurrent.ExecutorService; 
　　import java.util.concurrent.Executors; 
　　import java.util.concurrent.Semaphore; 
　　public class ConcurrentTest { 
　　private static int thread_num = 200; 
　　private static int client_num = 460; 
　　private static Map keywordMap = new HashMap(); 
　　static { 
　　try { 
　　InputStreamReader isr = new InputStreamReader(new FileInputStream( 
　　new File("clicks.txt")), "GBK"); 
　　BufferedReader buffer = new BufferedReader(isr); 
　　String line = ""; 
　　while ((line = buffer.readLine()) != null) { 
　　keywordMap.put(line.substring(0, line.lastIndexOf(":")), ""); 
　　} 
　　} catch (Exception e) { 
　　e.printStackTrace(); 
　　} 
　　} 
　　public static void main(String[] args) { 
　　int size = keywordMap.size(); 
　　// TODO Auto-generated method stub 
　　ExecutorService exec = Executors.newCachedThreadPool(); 
　　// 50个线程可以同时访问 
　　final Semaphore semp = new Semaphore(thread_num); 
　　// 模拟2000个客户端访问 
　　for (int index = 0; index < client_num; index++) { 
　　final int NO = index; 
　　Runnable run = new Runnable() { 
　　public void run() { 
　　try { 
　　// 获取许可
semp.acquire(); 
　　System.out.println("Thread:" + NO); 
　　String host = "http://10.99.23.42:7001/KMQueryCenter/query.do?"; 
　　String para = "method=getQueryResult&pageNum=1&pageSize=5&" 
　　+ "queryKeyWord=" 
　　+ getRandomSearchKey(NO) 
　　+ "&questionID=-1&questionIdPath=-1&searchType=1" 
　　+ "&proLine=&proSeries=&proType=" + NO; 
　　System.out.println(host + para); 
　　URL url = new URL(host);// 此处填写供测试的url 
　　HttpURLConnection connection = (HttpURLConnection) url 
　　.openConnection(); 
　　// connection.setRequestMethod("POST"); 
　　// connection.setRequestProperty("Proxy-Connection", 
　　// "Keep-Alive"); 
　　connection.setDoOutput(true); 
　　connection.setDoInput(true); 
　　PrintWriter out = new PrintWriter(connection 
　　.getOutputStream()); 
　　out.print(para); 
　　out.flush(); 
　　out.close(); 
　　BufferedReader in = new BufferedReader( 
　　new InputStreamReader(connection 
　　.getInputStream())); 
　　String line = ""; 
　　String result = ""; 
　　while ((line = in.readLine()) != null) { 
　　result += line; 
　　} 
　　// System.out.println(result); 
　　// Thread.sleep((long) (Math.random()) * 1000); 
　　// 释放 
　　System.out.println("第：" + NO + " 个"); 
　　semp.release(); 
　　} catch (Exception e) { 
　　e.printStackTrace(); 
　　} 
　　} 
　　}; 
　　exec.execute(run); 
　　} 
　　// 退出线程池 
　　exec.shutdown(); 
　　} 
　　private static String getRandomSearchKey(final int no) { 
　　String ret = ""; 
　　int size = keywordMap.size(); 
　　// int wanna = (int) (Math.random()) * (size - 1); 
　　ret = (keywordMap.entrySet().toArray())[no].toString(); 
　　ret = ret.substring(0, ret.lastIndexOf("=")); 
　　System.out.println("\t" + ret); 
　　return ret; 
　　} 
　　}