1. 任务描述</td> </tr> </table>
需要做一个程序,对某一服务器运行的web server进行测算,看对
提出的request做出相应的时间,并且在多个request同时提出时的响应时间。
2. 计划
因为java中包含有比较全面的class,能够对http等多种协议的处理
方法进行了封装,用起来比较方便,能够在比较短的时间内快速开发出这一
测算工具。
需要2个功能:
a. 因为不是仅仅对一个web server或者一个form进行测算,所以需要程序能
够灵活处理,完成各种工作。我采用了配置文件的形式,让程序从配置文件
中读取数据,并作相应动作。
b.需要采用多线程方式,对同一个web server提交多次request.
3.开发过程
(读者可以跟随这一过程,自己动手写代码,到全文结束,就能有一个完整可用的程序了)
主要的工作都有TestThread来完成。代码如下:
class TestThread implements Runnable { Parameter param; TestThread(Parameter par) { param = par; } public void run() { long time1 = new Date().getTime(); try { URL target = param.url; HttpURLConnection conn = (HttpURLConnection) target.openConnection(); conn.setRequestMethod(param.method); int i; for( i = 0; i < param.length; i++ ) { conn.setRequestProperty(param.key[i], param.value[i]); } conn.connect(); BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream())); String inputLine; while( (inputLine = in.readLine()) != null ); }catch(Exception e) { } long time2 = new Date().getTime(); System.out.println(time2 - time1); } }class TestThread implements Runnable, 而不是用extends Thread, 的好处是独立设计一个类,这个类还可以extends其它的class, 而不是单独的extends Thread. 另外一个好处是,可以把处理方法放在各个不同的方法中,然后在void run()中调用,程序结构比较清晰。
import java.io.*; import java.lang.reflect.Array; import java.net.*; import java.util.*; public class TestServer { static int loopTimes = 500; public Parameter readFromArgFile(String str){ FileInputStream fileInput; BufferedReader br; Parameter param = new Parameter(); try { fileInput = new FileInputStream(new File(str)); br = new BufferedReader(new InputStreamReader( fileInput )); String line; while( (line = br.readLine()) != null ) { if( line.startsWith("URL") == true && line.indexOf("=") >= 3) { int f = line.indexOf("="); String urlstring = line.substring(f+1); urlstring.trim(); param.url = new URL(urlstring); }else if( line.startsWith("METHOD") == true && line.indexOf("=") >= 3) { int f = line.indexOf("="); String method = line.substring(f+1); method.trim(); param.method = method; }else if( line.indexOf("=") != -1 ) { int f = line.indexOf("="); String key = line.substring(0, f-1); String value = line.substring(f+1); param.addPair(key.trim(), value.trim()); } } fileInput.close(); br.close(); }catch(FileNotFoundException e) { System.out.println("File " + str + " not found."); }catch(NullPointerException e) { }catch(IOException e) { System.out.println(e); } return param; } public static void main(String[] args) { int i; int j; Parameter param; TestServer tester = new TestServer(); for(i = 0; i < Array.getLength(args); i++) { param = tester.readFromArgFile(args[i]); for(j = 0; j < loopTimes; j++) { Thread th = new Thread(new TestThread(param)); th.start(); } } } }
import java.io.*; import java.lang.reflect.Array; import java.net.*; import java.util.*; public class TestServer { static int loopTimes = 500; public Parameter readFromArgFile(String str){ FileInputStream fileInput; BufferedReader br; Parameter param = new Parameter(); try { fileInput = new FileInputStream(new File(str)); br = new BufferedReader(new InputStreamReader( fileInput )); String line; while( (line = br.readLine()) != null ) { if( line.startsWith("URL") == true && line.indexOf("=") >= 3) { int f = line.indexOf("="); String urlstring = line.substring(f+1); urlstring.trim(); param.url = new URL(urlstring); }else if( line.startsWith("METHOD") == true && line.indexOf("=") >= 3) { int f = line.indexOf("="); String method = line.substring(f+1); method.trim(); param.method = method; }else if( line.indexOf("=") != -1 ) { int f = line.indexOf("="); String key = line.substring(0, f-1); String value = line.substring(f+1); param.addPair(key.trim(), value.trim()); } } fileInput.close(); br.close(); }catch(FileNotFoundException e) { System.out.println("File " + str + " not found."); }catch(NullPointerException e) { }catch(IOException e) { System.out.println(e); } return param; } public static void main(String[] args) { int i; int j; Parameter param; TestServer tester = new TestServer(); for(i = 0; i < Array.getLength(args); i++) { param = tester.readFromArgFile(args[i]); for(j = 0; j < loopTimes; j++) { Thread th = new Thread(new TestThread(param)); th.start(); } } } } class Parameter { URL url; String[] key; String[] value; String method; int length = 0; public void addPair(String k, String v) { Array.set(key, length, k); Array.set(value, length, v); length++; } } class TestThread implements Runnable { Parameter param; TestThread(Parameter par) { param = par; } public void run() { long time1 = new Date().getTime(); try { URL target = param.url; HttpURLConnection conn = (HttpURLConnection) target.openConnection(); conn.setRequestMethod(param.method); int i; for( i = 0; i < param.length; i++ ) { conn.setRequestProperty(param.key[i], param.value[i]); } conn.connect(); BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream())); String inputLine; while( (inputLine = in.readLine()) != null ); }catch(Exception e) { } long time2 = new Date().getTime(); System.out.println(time2 - time1); } }</td> </tr> <tr>
↑返回目录
前一篇: 如何更好更快的debug
后一篇: java程序破解-JPTXXXXXXX1_91