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.setMaxTotalConnections(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 totalSize){
max_tv.setText(bytesWritten/(totalSize/max)+"/"+max);
progressBar.setProgress(bytesWritten/(totalSize/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, params, 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, params, new FileSendResponseListener(this, this, v, max_tv, num_tv, 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,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, String content){
activity.showToast("OnSuccess");
System.out.println(content);
}
@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);
activity.showToast("正在下载");
dialog=activity.showDialog("正在下载", view);
}
@Override
public void onProgress(int bytesWritten, int totalSize){
max_tv.setText(bytesWritten/(totalSize/max)+"/"+max);
progressBar.setProgress(bytesWritten/(totalSize/max));
}
@Override
public void onFinish(){
dialog.cancel();
dialog=null;
}
}
机械节能产品生产企业官网模板...
大气智能家居家具装修装饰类企业通用网站模板...
礼品公司网站模板
宽屏简约大气婚纱摄影影楼模板...
蓝白WAP手机综合医院类整站源码(独立后台)...苏ICP备2024110244号-2 苏公网安备32050702011978号 增值电信业务经营许可证编号:苏B2-20251499 | Copyright 2018 - 2025 源码网商城 (www.ymwmall.com) 版权所有