Android AndBase框架使用封装好的函数完成Http请求（三）

public void get(final String url,final AbrequestParams params,final AbhttpResponseListener responseListener) {
  
  responseListener.setHandler(new ResponderHandler(responseListener));
  executorservice.submit(new Runnable() { 
   public void run() {
    try {
     doGet(url,params,responseListener);
    } catch (Exception E) { 
     e.printStackTrace();
    }
   }     
  });    
 }

private void doGet(String url,AbrequestParams params,AbhttpResponseListener responseListener){
   try {
    
    responseListener.sendStartmessage();
    
    if(!debug && !AbAppUtil.isNetworkAvailable(mContext)){
     responseListener.sendFailuremessage(AbConstant.CONNECT_FAILURE_CODE,AbConstant.CONNECTEXCEPTION,new AbAppException(AbConstant.CONNECTEXCEPTION));
     return;
    }
    
    //httpGet连接对象 
    if(params!=null){
     url += params.getParamString(); //如果有参,那么获取相关参数...
    }
    httpGet httprequest = new httpGet(url); //定义连接对象..
    
    BasichttpParams httpParams = new BasichttpParams();
    
    // 从连接池中取连接的超时时间，设置为1秒
    ConnManagerParams.setTimeout(httpParams,DEFAULT_SOCKET_TIMEOUT);
    ConnManagerParams.setMaxConnectionsPerRoute(httpParams,new ConnPerRouteBean(DEFAULT_MAX_CONNECTIONS));
    ConnManagerParams.setMax@R_662_10586@lConnections(httpParams,DEFAULT_MAX_CONNECTIONS);
    // 读响应数据的超时时间
    httpconnectionParams.setSoTimeout(httpParams,DEFAULT_SOCKET_TIMEOUT);
    httpconnectionParams.setConnectionTimeout(httpParams,DEFAULT_SOCKET_TIMEOUT);
    httpconnectionParams.setTcpNoDelay(httpParams,truE);
    httpconnectionParams.setSocketBufferSize(httpParams,DEFAULT_SOCKET_BUFFER_SIZE);
    //设置协议版本...
    httpProtocolParams.setVersion(httpParams,httpVersion.http_1_1);
    httpProtocolParams.setUserAgent(httpParams,String.format("andbase-http/%s (http://www.418log.org/)",1.0));
    // 设置请求参数
    httprequest.setParams(httpParams);
    
    //取得httpClient对象 
    httpClient httpClient = new DefaulthttpClient(); 
    //请求httpClient，取得httpResponse 
    httpResponse httpResponse = httpClient.execute(httprequest); 
    //请求成功 
    int statusCode = httpResponse.getStatusLine().getStatusCode();
    
    //取得返回的字符串 
    httpentity mhttpentity = httpResponse.getEntity();
    if (statusCode == httpStatus.SC_OK){ 
     if(responseListener instanceof AbStringhttpResponseListener){
      String content = EntityUtils.toString(mhttpentity);
      ((AbStringhttpResponseListener)responseListener).sendsuccessmessage(statusCode,content);
     }else if(responseListener instanceof AbBinaryhttpResponseListener){
      readResponseData(mhttpentity,((AbBinaryhttpResponseListener)responseListener));
     }else if(responseListener instanceof AbFilehttpResponseListener){
      //获取文件名
      String filename = AbFileUtil.getFilenameFromUrl(url,httpResponsE);
      writeResponseData(mhttpentity,filename,((AbFilehttpResponseListener)responseListener));
     }
    }else{
     String content = EntityUtils.toString(mhttpentity);
     responseListener.sendFailuremessage(statusCode,content,new AbAppException(AbConstant.UNKNowNHOSTEXCEPTION));
    }
  } catch (Exception E) {
   e.printStackTrace();
   //发送失败消息
   responseListener.sendFailuremessage(AbConstant.UNTREATED_CODE,e.getmessage(),new AbAppException(E));
  }finally{
   responseListener.sendFinishmessage();
  }
 }

public void FileClick(View v){
 url="http://192.168.199.172:8080/JSP/imageview.jpg";
 getView();
 httpUtil.get(url,new FileResponseListener(this,this,v,max_tv,num_tv,progressBar));
}
 GetResponseListener.java

package com.example.andbasehttp;

import java.io.File;

import android.app.AlertDialog;
import android.content.Context;
import android.content.DialogInterface;
import android.content.DialogInterface.onClickListener;
import android.graphics.bitmap;
import android.view.View;
import android.widget.ImageView;
import android.widget.TextView;
import com.ab.activity.ABACtivity;
import com.ab.http.AbFilehttpResponseListener;
import com.ab.util.AbFileUtil;
import com.ab.view.progress.AbHorizontalProgressBar;

public class FileResponseListener extends AbFilehttpResponseListener{

 
 privatE int max=100;
 privatE int progress=0;
 private ABACtivity activity;
 private Context context;
 private AlertDialog dialog;
 private View view;
 private TextView max_tv,num_tv;
 private AbHorizontalProgressBar progressBar;
 
 public FileResponseListener(ABACtivity activity,Context context,View v,TextView v1,TextView v2,AbHorizontalProgressBar progressBar ){
  this.activity=activity;
  this.context=context;
  this.view=v;
  this.max_tv=v1;
  this.num_tv=v2;
  this.progressBar=progressBar;
 }
 
 @Override
 public void onsuccess(int statusCode,File filE){
  Bitmap bitmap=AbFileUtil.getBitmapFromSD(filE);
  ImageView view=new ImageView(context);
  view.setImageBitmap(bitmap);
  activity.showDialog("返回结果",view,new OnClickListener() {
   
   @Override
   public void onClick(DialogInterface dialog,int which) {
    // TODO Auto-generated method stub
    
   }
  });
 }
 
 @Override
 public void onFailure(int statusCode,String content,Throwable error){
  activity.showToast(error.toString());
 }
 
 @Override
 public void onStart(){
  max_tv.setText(progress+"/"+String.valueOf(maX));
  progressBar.setMax(maX);
  progressBar.setProgress(progress);
  dialog=activity.showDialog("正在下载",view);
 }
 
 @Override
 public void onProgress(int bytesWritten,int @R_662_10586@lSizE){
  max_tv.setText(bytesWritten/(@R_662_10586@lSize/maX)+"/"+maX);
  progressBar.setProgress(bytesWritten/(@R_662_10586@lSize/maX));
 }
 
 @Override
 public void onFinish(){
  dialog.cancel();
  dialog=null;
 }
}

public void PostClick(View v){
 url="http://192.168.199.172:8080/JSP/post.jsp";
 params=new AbrequestParams();
 params.put("name","darker");
 params.put("password","49681888");
 httpUtil.post(url,new PostResponseListener(this));
}

<%
 String name=request.getParameter("name");
 String password=request.getParameter("password");
 if("darker".equals(Name)&& "49681888".equals(password)){
  out.println("Receive name is:"+Name);
 out.println("Receive password is:"+password);%>
 Your message are right!
 <%}else{
  out.println("Receive name is:"+Name);
 out.println("Receive password is:"+password);%>
 Your message are wrong!
 <%}%> 

public void FileLoadClick(View v){
  url="http://192.168.199.172:8080";
  AbrequestParams params = new AbrequestParams(); 
  File pathRoot = Environment.getExternalStorageDirectory();
  String path = pathRoot.getAbsolutePath();
  File file1 = new File(path+"/download/cache_files/aa.txt");
  params.put(file1.getName(),file1);
  
  getView();
  httpUtil.get(url,new FileSendResponseListener(this,progressBar));
 }

package com.example.andbasehttp;

import android.app.AlertDialog;
import android.content.Context;
import android.view.View;
import android.widget.TextView;
import com.ab.activity.ABACtivity;
import com.ab.http.AbStringhttpResponseListener;
import com.ab.view.progress.AbHorizontalProgressBar;

public class FileSendResponseListener extends AbStringhttpResponseListener{

 privatE int max=100;
 privatE int progress=0;
 private ABACtivity activity;
 private Context context;
 private AlertDialog dialog;
 private View view;
 private TextView max_tv,num_tv;
 private AbHorizontalProgressBar progressBar;
 
 public FileSendResponseListener(ABACtivity activity,String content){
  activity.showToast("Onsuccess");
  System.out.println(content);
 }
 
 @Override
 public void onFailure(int statusCode,Throwable error){
  activity.showToast(error.toString());
 }
 
 @Override
 public void onStart(){
  max_tv.setText(progress+"/"+String.valueOf(maX));
  progressBar.setMax(maX);
  progressBar.setProgress(progress);
  activity.showToast("正在下载");
  dialog=activity.showDialog("正在下载",int @R_662_10586@lSizE){
  max_tv.setText(bytesWritten/(@R_662_10586@lSize/maX)+"/"+maX);
  progressBar.setProgress(bytesWritten/(@R_662_10586@lSize/maX));
 }
 
 @Override
 public void onFinish(){
  dialog.cancel();
  dialog=null;
 }
}