一个用JAVA写测算服务器响应速度程序

    1. 任务描述

    需要做一个程序，对某一服务器运行的web server进行测算，看对提出的request做出相应的时间，并且在多个request同时提出时的响应时间。 网管网www.bitscn.com

    2. 计划 中国网管论坛bbs.bitsCN.com

    因为java sdk中包含有比较全面的class能够对http等多种协议的处理方法进行了封装，用起来比较方便，能够在比较短的时间内快速开发出这一测算工具。

网管u家u.bitsCN.com

    需要2个功能： 网管bitscn_com

    a. 因为不是仅仅对一个web server或者一个form进行测算，所以需要程序能够灵活处理，完成各种工作。我采用了配置文件的形式，让程序从配置文件中读取数据，并作相应动作。 网管联盟bitsCN@com

    b.需要采用多线程方式，对同一个web server提交多次request. 网管联盟bitsCN_com

    3.开发过程

网管论坛bbs_bitsCN_com

   （读者可以跟随这一过程，自己动手写代码，到全文结束，就能有一个完整可用的程序了）

网管u家u.bitscn@com

    主要的工作都有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(  网管论坛bbs_bitsCN_com 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()中调用，程序结构比较清晰。 网管u家u.bitscn@com

    程序工作如下：

    在初始化一个TestThread实例的时候，接受一个Parameter参数（稍候介绍），并在线程启动时，计算开始的时间，向目标机器发送请求包，接受目标机器的返回结果，再次计算时间，并得到两次时间之差，这就是服务器的响应时间。 网管网www.bitscn.com

    具体程序可以自己看懂，就不多说了。

网管u家u.bitsCN.com

    

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++;  }  }

    
    是用来传递参数的一个类。参数是主程序从文件中读出来并存入这个类的一个对象里，然后通过初始化TestThread传递给它的对象。 中国网管联盟bitsCN.com

    

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);  网管联盟bitsCN@com 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) {  }  网管联盟bitsCN_com 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();  }  }  }  }

    
    主程序main也比较简单，从命令行参数中读取文件名，并依次打开，读取其中的配置参数，创建Parameter对象，并传递给TestThread对象，然后启动TestThread线程。需要注意的是其中的错误处理，当发现某个文件读写错误的时候，是跳过这个文件而读取下一个文件，而不是简单的退出。

中国网管论坛bbs.bitsCN.com

    就这么简单。(当然，适当的改写一下，就可以做一个加贴机或者灌水机之类的东东，那是你的爱好，和我无关：-））

网管联盟bitsCN@com

    程序全文列在最后，并附上了说明

网管下载dl.bitscn.com

 

-------------------------------------------------------------------------------  /****************************************************************  Program: TestServer.java  Description: send requests in multiple threads to server to test  its responses delayance  Author: ariesram   Date: Aug 23, 2001  Usage: java TestServer file1 file2 ...  file format:  URL=[Full URL of form]  METHOD=GET|POST|...  key1=value1  key2=value2  and so on ...  ****************************************************************/  import java.io.*;  import java.lang.reflect.Array;  import java.net.*;  中国网管论坛bbs.bitsCN.com 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) {  网管u家u.bitsCN.com 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;  网管论坛bbs_bitsCN_com 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) {  网管联盟bitsCN_com 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);  }  }

   

网管联盟bitsCN@com