一个用JAVA写的测算服务器响应速度的程序[浩特个人网]

今天是：	本站首页文章频道动画频道下载频道图片频道在线书库魔方世界英语广播音乐在线笨笨论坛

·设为首页

·在线留言

·关于本站

您现在的位置：浩特个人网 >> 文章频道 >> 编程源码 >> JAVA源代码 >> 正文

本站公告：

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

热

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

［作者：无来源：搜集整理点击数：更新时间：2006-04-03 文章录入：无］

【字体：

】

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

2. 计划
因为java sdk中包含有比较全面的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()中调用，程序结构比较清晰。
程序工作如下：
在初始化一个TestThread实例的时候，接受一个Parameter参数（稍候介绍），并在线程启动时，计算开始的时间，向目标机器发送请求包，接受目标机器的返回结果，再次计算时间，并得到两次时间之差，这就是服务器的响应时间。
具体程序可以自己看懂，就不多说了。
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传递给它的对象。
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();
}
}
}
}

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

就这么简单。(当然，适当的改写一下，就可以做一个加贴机或者灌水机之类的东东，那是你的爱好，和我无关：-））
程序全文列在最后，并附上了说明
-------------------------------------------------------------------------------
/****************************************************************
Program: TestServer.java
Description: send requests in multiple threads to server to test
its responses delayance
Author: ariesram <ariesram@may10.ca>
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.*;
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);
}
}

上一篇文章： MIDP1.0小游戏入门-五子棋1.1

下一篇文章：用Java编写的密码算法类