网络下载速度测试的实验

1.定义一个回调返回下载文件的进度的接口ProgressListener

/**
* 回调返回下载了文件的进度
* */
public interface ProgressListener {
public void onStart(long totalSize);
public void onFinish (float agv_speed);
public void onProgress(long size);
public void onError (long position);
public boolean isInterrupte ();
public void onSpeed (float speed);
}


2.定义httptask
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;

import android.util.Log;

public class HttpTask {

private ProgressListener mProgressListener;
private String mUrl;
private File mSaveFile;

public HttpTask(String url, File savefile, ProgressListener listener) {
this.mUrl = url;
this.mProgressListener = listener;
mSaveFile = savefile;
}

private boolean isInterrupte() {
if (mProgressListener != null) {
return mProgressListener.isInterrupte();
}
return false;
}

public void startDownLoad () {
DefaultHttpClient httpclient = new DefaultHttpClient();
HttpGet httpget = new HttpGet(mUrl);
FileOutputStream fos = null;
InputStream is = null;
int totaldownload = 0;
try {
fos = new FileOutputStream(mSaveFile);
HttpResponse response = httpclient.execute(httpget);
if (response!=null) {
org.apache.http.Header mheader=response.getLastHeader("Content-Length");
if (mheader!=null) {
String tempValue=mheader.getValue();
String responseValue=tempValue.equals("")?"0":tempValue;
int totalSize = Integer.parseInt(responseValue);
HttpEntity entity = response.getEntity();
is = entity.getContent();
byte[] buffer = new byte[1024 * 1024];
int offset = 0;
if (mProgressListener != null) {
mProgressListener.onStart(totalSize);
}
long start = System.currentTimeMillis();
long current = start;
long compare = 0;
while ((offset = (is.read(buffer))) != -1 && !isInterrupte()) {
fos.write(buffer, 0, offset);
totaldownload += offset;
compare += offset;
if (mProgressListener != null) {
mProgressListener.onProgress(totaldownload);
// 每50k计算一次速度
if (compare >= 1024*10) {
long now = System.currentTimeMillis();
float lag = (float)(now - current) / 1000;
// 计算速度
float speed = (float)offset / lag;
mProgressListener.onSpeed(speed);
current = now;
compare = 0;
}
}
}
long end = System.currentTimeMillis();
float speed = (float)totalSize / ((float)(end - start) / 1000) / 1024;
Log.d("HttpTask", "平均速度:" + speed + "kb/s");
if (mProgressListener != null) {
mProgressListener.onFinish(speed);
}
}
else {
mProgressListener.onError(totaldownload);
}
}
} catch (ClientProtocolException e) {
e.printStackTrace();
if (mProgressListener != null) {
mProgressListener.onError(totaldownload);
}
} catch (IOException e) {
e.printStackTrace();
if (mProgressListener != null) {
mProgressListener.onError(totaldownload);
}
} finally {
if (fos != null) {
try {
fos.close();
} catch (IOException e) {
}
}
if (is != null) {
try {
is.close();
} catch (IOException e) {
}
}
}
}
}


3.你的activity，我的SpeedActivity如下所示，xml布局要你自己设置,一些工具类也需要你修改！
import java.io.File;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import android.app.Activity;
import android.app.AlertDialog;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.view.Window;
import android.view.WindowManager;
import android.widget.Button;
import android.widget.ImageView;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;

/**
** @author Alawn
** @Email AlawnXu@foxmail.com
* @createtime 2012-8-22 上午10:08:19
* @version 1.0
* @remark 网络测试activity
*/
public class SpeedActivity extends Activity {
/** Called when the activity is first created. */
private static final String TAG = "SpeedActivity";
TextView fileLength = null;
TextView tv_speed = null;
TextView percent = null;
TextView startDate;
TextView endDate, totalTime;
String url = "";
String startTime, endTime;
ImageView imageView = null;
byte[] imageData = null;
private ProgressBar pb;
private long clickTime, downloadtimeout;
private float m_speed=0;
private long m_totalsize=0;
private long m_progress=0;
private final int UPDATE_SPEED = 1;
private boolean isRemoteErro;
//private boolean isFisnishDownload=false;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,
WindowManager.LayoutParams.FLAG_FULLSCREEN);
requestWindowFeature(Window.FEATURE_NO_TITLE);// 设置全屏的
setContentView(R.layout.speed_test);
pb = (ProgressBar) findViewById(R.id.pb);
pb.setMax(100);
tv_speed = (TextView) findViewById(R.id.speed);
percent = (TextView) findViewById(R.id.percent);
imageView = (ImageView) findViewById(R.id.ImageView01);
Button b = (Button) findViewById(R.id.btn_starttest);
CustomButtonStyle.setButtonFocusChanged(b);// 按钮点击效果
startDate = (TextView) findViewById(R.id.startDate);
endDate = (TextView) findViewById(R.id.endDate);
totalTime = (TextView) findViewById(R.id.totalTime);
fileLength=(TextView)findViewById(R.id.fileLength);
b.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View arg0) {
if (isRemoteErro) {
Toast.makeText(SpeedActivity.this, "远程服务器发生错误,请稍后再测速", Toast.LENGTH_LONG).show();
isRemoteErro=false;
return;
}
if (!FileUtils.ExistSDCard()) {
Toast.makeText(SpeedActivity.this, "获取存储卡失败,请检查存储卡连接状况", Toast.LENGTH_LONG).show();
return;
}
if (BoNetworksTools.isConnectInternet(SpeedActivity.this, false, null)){
SimpleDateFormat sDateFormat = new SimpleDateFormat("hh:mm:ss");
startTime = sDateFormat.format(new java.util.Date());
clickTime = System.currentTimeMillis();
endTime = sDateFormat.format(new java.util.Date());
downloadtimeout = System.currentTimeMillis();
pb.setVisibility(ProgressBar.VISIBLE);
if (m_totalsize-m_progress==0) {
updateView();
new Thread(new Runnable() {
@Override
public void run() {
File sdcardDir = android.os.Environment
.getExternalStorageDirectory();
File save = new File(sdcardDir, "my_download.png");
if (save.exists()) {
save.delete();
}
HttpTask task = new HttpTask(
getString(R.string.image_url), save,
mProgressListener);
task.startDownLoad();
}
}).start();
}
}
else {
new AlertDialog.Builder(SpeedActivity.this).
setTitle("温馨提示：").
setMessage("测速失败，请检查你的网络状况").
setNegativeButton("确定", null).
show();
}
}
});
Button btn_speedback = (Button) findViewById(R.id.btn_speedback);
btn_speedback.setOnClickListener(new View.OnClickListener() {

@Override
public void onClick(View v) {
// TODO Auto-generated method stub
finish();
}
});
CustomButtonStyle.setButtonFocusChanged(btn_speedback);

}

/**
* Handler for post message into OS
*/
private Handler handler = new Handler() {
@Override
public void handleMessage(Message msg) {
int value = msg.what;
switch (value) {
case UPDATE_SPEED:
updateView();
break;
default:
break;
}
}
};

/**
* Update the view method
*/
private float speed_agv=0;
DecimalFormat fnum;
private void updateView() {
startDate.setText("开始时间:" + startTime);
endDate.setText("结束时间:" + endTime);
totalTime.setText("总计耗时:"
+ CalendarUtil.getDiffLongDate(downloadtimeout, clickTime));
if (fnum==null) {
fnum=new DecimalFormat( "##0.00
af1a
00");
}
String speed_str=fnum.format(m_speed/1024);
tv_speed.setText("平均网速:" + speed_str + "kb/s");
fileLength.setText("图片大小:" +m_totalsize/1024+"kb");
long m_percent=( int ) ((( double )m_progress/(double)m_totalsize) * 100);
percent.setText(m_percent+ "%");
int max_percent = (int) (((double) m_progress / (double) m_totalsize) * 100);
if (max_percent==100) {
String speed_agvstr=fnum.format(speed_agv);
tv_speed.setText("平均网速:" + speed_agvstr + "kb/s");
}
pb.setProgress(max_percent);
}

ProgressListener mProgressListener = new ProgressListener() {
@Override
public void onStart(long totalSize) {
Log.d(TAG, "开始,文件大小:" + totalSize);
m_totalsize = totalSize;
handler.sendEmptyMessage(UPDATE_SPEED);
}

@Override
public void onFinish(float agv_speed) {
Log.d(TAG, "下载完毕");
SimpleDateFormat sDateFormat = new SimpleDateFormat("hh:mm:ss");
speed_agv=agv_speed;
endTime = sDateFormat.format(new java.util.Date());
downloadtimeout = System.currentTimeMillis();
handler.sendEmptyMessage(UPDATE_SPEED);
}

@Override
public void onProgress(long size) {
Log.i(TAG, "进度:" + size);
m_progress = size;
handler.sendEmptyMessage(UPDATE_SPEED);
}

@Override
public void onError(long position) {
Log.e(TAG, "错误:" + position);
}

@Override
public boolean isInterrupte() {
return false;
}

// int speed_count=0;
// int speed_total=0;
@Override
public void onSpeed(float speed) {
Log.d(TAG, "速度:" + speed);
// speed_count++;
// speed_total+=speed/1024;
m_speed=speed;
downloadtimeout = System.currentTimeMillis();
SimpleDateFormat sDateFormat = new SimpleDateFormat("hh:mm:ss");
endTime = sDateFormat.format(new java.util.Date());
handler.sendEmptyMessage(UPDATE_SPEED);
// tv_speed.setText("平均网速:" + speed / 1024 + "kb/s");
}

};
}