Java源码示例：com.lidroid.xutils.exception.HttpException
示例1
/**
* get请求数据
* @param view
*/
@OnClick(R.id.get)
public void get(View view) {
String url = "http://www.weather.com.cn/data/cityinfo/101010100.html";
RequestParams params = new RequestParams();
/* //添加请求参数
params.addBodyParameter(key, value);*/
/* //添加请求头
params.addHeader(name, value);*/
http.send(HttpMethod.GET, url, params, new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
data.setText(responseInfo.result);
}
@Override
public void onFailure(HttpException error, String msg) {
Toast.makeText(getActivity(), "访问失败" + msg, Toast.LENGTH_SHORT).show();
}
});
}
示例2
/**
* post请求数据
* @param view
*/
@OnClick(R.id.post)
public void post(View view) {
//这个地址只支持get， 这里只是示范。
String url = "http://www.weather.com.cn/data/cityinfo/101010100.html";
RequestParams params = new RequestParams();
/* //添加请求参数
params.addBodyParameter(key, value);*/
/* //添加请求头
params.addHeader(name, value);*/
http.send(HttpMethod.POST, url, params, new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
data.setText(responseInfo.result);
}
@Override
public void onFailure(HttpException error, String msg) {
Toast.makeText(getActivity(), "访问失败" + msg, Toast.LENGTH_SHORT).show();
}
});
}
示例3
private ResponseStream handleResponse(HttpResponse response) throws HttpException, IOException {
if (response == null) {
throw new HttpException("response is null");
}
StatusLine status = response.getStatusLine();
int statusCode = status.getStatusCode();
if (statusCode < 300) {
ResponseStream responseStream = new ResponseStream(response, charset, requestUrl, expiry);
responseStream.setRequestMethod(requestMethod);
return responseStream;
} else if (statusCode == 301 || statusCode == 302) {
if (httpRedirectHandler == null) {
httpRedirectHandler = new DefaultHttpRedirectHandler();
}
HttpRequestBase request = httpRedirectHandler.getDirectRequest(response);
if (request != null) {
return this.sendRequest(request);
}
} else if (statusCode == 416) {
throw new HttpException(statusCode, "maybe the file has downloaded completely");
} else {
throw new HttpException(statusCode, status.getReasonPhrase());
}
return null;
}
示例4
public static void getTradeInfo(final Context paramContext, final String paramString) {
Log.i("tag", "getTradeInfo:1 ");
long l = System.currentTimeMillis();
String str1 = getCurrentDate();
String str2 = "https://mbillexprod.alipay.com/enterprise/simpleTradeOrderQuery.json?beginTime=" + (l - 864000000L) + "&limitTime=" + l + "&pageSize=20&pageNum=1&channelType=ALL";
HttpUtils localHttpUtils = new HttpUtils(15000);
localHttpUtils.configResponseTextCharset("GBK");
RequestParams localRequestParams = new RequestParams();
localRequestParams.addHeader("Cookie", paramString);
localRequestParams.addHeader("Referer", "https://render.alipay.com/p/z/merchant-mgnt/simple-order.html?beginTime=" + str1 + "&endTime=" + str1 + "&fromBill=true&channelType=ALL");
localHttpUtils.send(HttpRequest.HttpMethod.GET, str2, localRequestParams, new RequestCallBack() {
public void onFailure(HttpException paramAnonymousHttpException, String paramAnonymousString) {
// PayHelperUtils.sendmsg(PayHelperUtils.this, "服务器异常" + paramAnonymousString);
Log.i("tag", "服务器异常");
}
public void onSuccess(ResponseInfo paramAnonymousResponseInfo) {
String result = (String) paramAnonymousResponseInfo.result;
try {
Log.i("tag", "getTradeInfo2" + result);
JSONArray array = new JSONObject(result).getJSONObject("result").getJSONArray("list");
if ((array != null) && (array.length() > 0)) {
String json = array.getJSONObject(0).getString("tradeNo");
Log.i("tag", "getTradeInfo3" + json);
Intent localIntent = new Intent();
localIntent.putExtra("tradeno", json);
localIntent.putExtra("cookie", paramString);
localIntent.setAction(Constans.ACTION_PAY_SUCCESS);
paramContext.sendBroadcast(localIntent);
// EventBus.getDefault().post(new MessageEvent(MessageEvent.MessageType.TRADENORECEIVED_ACTION,json,paramString));
}
return;
} catch (Exception p) {
// PayHelperUtils.sendmsg(PayHelperUtils.this, "getTradeInfo异常" + paramAnonymousResponseInfo.getMessage());
Log.i("tag", "getTradeInfo异常" + p.getMessage());
}
}
});
}
示例5
private static void loadSmileyZip(final Context context, String url) {
// ZogUtils.printError(LoadEmojiUtils.class, "loadSmileyZip url：" + url);
initDir(context);
HttpUtils http = new HttpUtils();
http.download(url, SmileyUtils.getSmileyZipFilePath(context),
true,// 如果目标文件存在，接着未完成的部分继续下载。服务器不支持RANGE时将重新下载。
false, // 如果从请求返回信息中获取到文件名，下载完成后自动重命名。
new RequestCallBack<File>() {
@Override
public void onStart() {
super.onStart();
ZogUtils.printError(LoadEmojiUtils.class, "loadSmileyZip onStart");
}
@Override
public void onSuccess(ResponseInfo<File> responseInfo) {
ZogUtils.printError(LoadEmojiUtils.class, "loadSmileyZip onSuccess dir:" + responseInfo.result.getPath());
SmileyInfo smileyInfo = AppSPUtils.getContentConfig(context).getSmileyInfo();
String fileMD5 = MD5Utils.getFileMD5(new File(SmileyUtils.getSmileyZipFilePath(context)));
ZogUtils.printError(LoadEmojiUtils.class, "fileMD5:" + fileMD5 + " smileyInfo.getMD5()):" + smileyInfo.getMD5());
// if (fileMD5.equals(smileyInfo.getMD5())) {
loadSmileyMap(context);
// } else {
// ZogUtils.printError(LoadEmojiUtils.class, "Smiley Zip MD5不匹配");
// }
}
@Override
public void onFailure(HttpException e, String s) {
ZogUtils.printError(LoadEmojiUtils.class, "loadSmileyZip onFailure");
SmileyUtils.distory(context);
// JsonUtils.printAsJson(e);
// ToastUtils.mkLongTimeToast(context, context.getString(R.string.download_emoji_fail));
}
});
}
示例6
@Override
public void setPortrait(final Handler handler, String userId, String portraitURL) {
Log.e(TAG, "setPortrait");
HttpUtils http = new HttpUtils();
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("userId", userId);
params.addQueryStringParameter("portraitURL", portraitURL);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_SET_PORTRAIT, params,
new RequestCallBack<String>() {
@SuppressWarnings("rawtypes")
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if(code == Constants.SUCCESS) {
Log.e(TAG, "set portrait success");
handler.sendEmptyMessage(Constants.SUCCESS_1);
} else {
Log.e(TAG, "set portrait fail, fail msg is " + map.get("msg"));
handler.sendEmptyMessage(Constants.FAILURE_1);
ToastUtils.showMessage(mContext,
R.string.set_portrait_fail);
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "set portrait error", error);
handler.sendEmptyMessage(Constants.FAILURE_1);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
ToastUtils.showMessage(mContext,
R.string.set_portrait_fail);
}
}
});
}
示例7
@Override
public void checkUserExeist(String phone, final ApiCallBack apiCallBack) {
HttpUtils http = new HttpUtils();
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
http.configDefaultHttpCacheExpiry(0);
RequestParams params = new RequestParams();
params.addQueryStringParameter("phone", phone);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_CHECK_EXEIST, params,
new RequestCallBack<String>() {
@SuppressWarnings("rawtypes")
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if(code == Constants.SUCCESS) {
Log.e(TAG, "checkUserExeist success");
apiCallBack.onSuccess(code);
} else {
Log.e(TAG, "checkUserExeist fail, fail msg is " + map.get("msg"));
apiCallBack.onFailure(String.valueOf(code));
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "checkUserExeist error", error);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
apiCallBack.onError(error, msg);
}
}
});
}
示例8
@Override
public void reSetPassword(String phone, String password,
final ApiCallBack apiCallBack) {
HttpUtils http = new HttpUtils();
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
http.configDefaultHttpCacheExpiry(0);
RequestParams params = new RequestParams();
params.addQueryStringParameter("phone", phone);
params.addQueryStringParameter("password", password);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_RESET_PWD, params,
new RequestCallBack<String>() {
@SuppressWarnings("rawtypes")
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if(code == Constants.SUCCESS) {
Log.e(TAG, "reSetPassword success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
apiCallBack.onSuccess(user);
} else {
Log.e(TAG, "reSetPassword fail, fail msg is " + map.get("msg"));
apiCallBack.onFailure(String.valueOf(code));
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "reSetPassword error", error);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
apiCallBack.onError(error, msg);
}
}
});
}
示例9
@Override
public void getQuTu(final Handler handler, int newOrHotFlag, int offset,
int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("newOrHotFlag", String.valueOf(newOrHotFlag));
params.addQueryStringParameter("offset", String.valueOf(offset));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_LIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例10
@Override
public void refush(final Handler handler, int newOrHotFlag, int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(0); //缓存超期时间0分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("newOrHotFlag", String.valueOf(newOrHotFlag));
// params.addQueryStringParameter("offset", String.valueOf(1));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_LIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS_1;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例11
@Override
public void getMeiTu(final Handler handler, int newOrHotFlag, int offset,
int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("newOrHotFlag", String.valueOf(newOrHotFlag));
params.addQueryStringParameter("offset", String.valueOf(offset));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_LIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例12
@Override
public void refresh(final Handler handler, int newOrHotFlag, int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(0); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("newOrHotFlag", String.valueOf(newOrHotFlag));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_LIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS_1;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例13
@Override
public void refushAll(final Handler handler, int newOrHotFlag, int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(0); //缓存超期时间0分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("newOrHotFlag", String.valueOf(newOrHotFlag));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_LIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
try {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS_1;
message.setData(bundle);
handler.sendMessage(message);
} catch (Exception e) {
handler.sendEmptyMessage(Constants.FAILURE);
}
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例14
@Override
public void getCommentByJokeId(final Handler handler, int jokeId, int offset,
int count) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(60); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("qushiId", String.valueOf(jokeId));
params.addQueryStringParameter("offset", String.valueOf(offset));
params.addQueryStringParameter("count", String.valueOf(count));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_GET_COMMENTS, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
return;
}
PageResult page = FastjsonUtil.deserialize(
map.get("data").toString(), PageResult.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("pageResult", page);
message.what = Constants.SUCCESS;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例15
@Override
public void getJokeById(final ApiCallBack apiCallBack, Integer jokeId) {
HttpUtils http = new HttpUtils();
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
http.configDefaultHttpCacheExpiry(0);
RequestParams params = new RequestParams();
params.addQueryStringParameter("jokeId", String.valueOf(jokeId));
http.send(HttpRequest.HttpMethod.GET,
RcpUri.INTERFACE_URI_GET_JOKE, params,
new RequestCallBack<String>() {
@SuppressWarnings("rawtypes")
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if(code == Constants.SUCCESS) {
Log.e(TAG, "getJokeById success");
Joke joke = FastjsonUtil.deserialize(
map.get("data").toString(), Joke.class);
apiCallBack.onSuccess(joke);
} else {
Log.e(TAG, "getJokeById fail, fail msg is " + map.get("msg"));
apiCallBack.onFailure(String.valueOf(code));
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "getJokeById error", error);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
apiCallBack.onError(error, msg);
}
}
});
}
示例16
@Override
public void onFailure(HttpException error, String msg) {
HttpHandler<File> handler = downloadInfo.getHandler();
if (handler != null) {
downloadInfo.setState(handler.getState());
}
try {
db.saveOrUpdate(downloadInfo);
} catch (DbException e) {
LogUtils.e(e.getMessage(), e);
}
if (baseCallBack != null) {
baseCallBack.onFailure(error, msg);
}
}
示例17
@Override
public void onFailure(HttpException error, String msg) {
HttpHandler<File> handler = downloadInfo.getHandler();
if (handler != null) {
downloadInfo.setState(handler.getState());
}
try {
db.saveOrUpdate(downloadInfo);
} catch (DbException e) {
LogUtils.e(e.getMessage(), e);
}
if (baseCallBack != null) {
baseCallBack.onFailure(error, msg);
}
}
示例18
private void getOnePull() {
SharedPreferences sharedPref = this.getSharedPreferences("userdata",Context.MODE_PRIVATE);
RequestParams params = new RequestParams();
params.addQueryStringParameter("uid", sharedPref.getInt("uid", -1) + "");
SharedPreferences sharedPref1 = this.getSharedPreferences("appdata",Context.MODE_PRIVATE);
params.addHeader("Cookie","JSESSIONID="+sharedPref1.getString("SessionId", ""));
HttpUtils http = new HttpUtils();
http.send(HttpRequest.HttpMethod.GET,
declare.getHost_url() + "remind/unread",
params,
new RequestCallBack<String>() {
@Override
public void onStart() {
Log.i(TAG ,"Pull==>onStart" ) ;
}
@Override
public void onLoading(long total, long current, boolean isUploading) {
}
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
readingParse(responseInfo.result);
}
@Override
public void onFailure(HttpException error, String msg) {
Log.i(TAG ,"Pull==>error==>" + msg ) ;
}
});
}
示例19
public void test5(){
//RequestParams params = new RequestParams();
//params.addHeader("name", "value");
//params.addQueryStringParameter("name", "value");
HttpUtils http = new HttpUtils();
http.send(HttpRequest.HttpMethod.GET,
"http://www.baidu.com",
//params,
new RequestCallBack<String>() {
@Override
public void onStart() {
Log.i("Http" ,"onStart" ) ;
}
@Override
public void onLoading(long total, long current, boolean isUploading) {
}
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
Log.i("Http" , "onSuccess" + responseInfo.result ) ;
}
@Override
public void onFailure(HttpException error, String msg) {
Log.i("Http" ,"error==>" + msg ) ;
}
});
}
示例20
public void test4(){
RequestParams params = new RequestParams();
params.addQueryStringParameter("uname", "中文");
HttpUtils http = new HttpUtils();
http.send(HttpRequest.HttpMethod.POST,
"http://192.168.1.104:8080/ALLGO_SERVER/login",
params,
new RequestCallBack<String>() {
@Override
public void onStart() {
Log.i("Http" ,"onStart" ) ;
}
@Override
public void onLoading(long total, long current, boolean isUploading) {
}
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
Log.i("Http" , "onSuccess" + responseInfo.result ) ;
}
@Override
public void onFailure(HttpException error, String msg) {
Log.i("Http" ,"error==>" + msg ) ;
}
});
}
示例21
/**
* @param url
*/
private void loadImgList(String url) {
new HttpUtils().send(HttpRequest.HttpMethod.GET, url,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
adapter.addSrc(getImgSrcList(responseInfo.result));
adapter.notifyDataSetChanged();//通知listview更新数据
}
@Override
public void onFailure(HttpException error, String msg) {
}
});
}
示例22
@OnClick(R.id.start)
public void start(View view) {
if (handler == null || handler.isCancelled()) {
handler = http.download(URL,
Environment.getExternalStorageDirectory().getAbsolutePath() + "/test.apk",
true, // 如果目标文件存在，接着未完成的部分继续下载。服务器不支持RANGE时将从新下载。
false, // 如果从请求返回信息中获取到文件名，下载完成后自动重命名。
new RequestCallBack<File>() {
@Override
public void onLoading(long total, long current,
boolean isUploading) {
super.onLoading(total, current, isUploading);
progressBar.setMax((int) total);
progressBar.setProgress((int) current);
}
@Override
public void onSuccess(ResponseInfo<File> responseInfo) {
Toast.makeText(getActivity(), "下载成功", Toast.LENGTH_SHORT).show();
progressBar.setProgress(0);
start.setText("开始");
}
@Override
public void onFailure(HttpException error, String msg) {
Toast.makeText(getActivity(), "下载失败" + msg, Toast.LENGTH_SHORT).show();
start.setText("开始");
}
});
start.setText("暂停");
}
else {
handler.cancel();
start.setText("开始");
}
}
示例23
@Override
protected Void doInBackground(Object... params) {
if (this.state == State.CANCELLED || params == null || params.length == 0) return null;
//主要是判断是否是下载文件
if (params.length > 3) {
fileSavePath = String.valueOf(params[1]);
isDownloadingFile = fileSavePath != null;
autoResume = (Boolean) params[2];
autoRename = (Boolean) params[3];
}
try {
if (this.state == State.CANCELLED) return null;
// init request & requestUrl
request = (HttpRequestBase) params[0];
requestUrl = request.getURI().toString();
if (callback != null) {
callback.setRequestUrl(requestUrl);
}
this.publishProgress(UPDATE_START); //回调， 开始
lastUpdateTime = SystemClock.uptimeMillis();
ResponseInfo<T> responseInfo = sendRequest(request);
if (responseInfo != null) {
this.publishProgress(UPDATE_SUCCESS, responseInfo); //回调， 成功
return null;
}
} catch (HttpException e) {
this.publishProgress(UPDATE_FAILURE, e, e.getMessage()); //回调， 失败
}
return null;
}
示例24
@Override
@SuppressWarnings("unchecked")
protected void onProgressUpdate(Object... values) {
if (this.state == State.CANCELLED || values == null || values.length == 0 || callback == null) return;
switch ((Integer) values[0]) {
case UPDATE_START:
this.state = State.STARTED;
callback.onStart();
break;
case UPDATE_LOADING:
if (values.length != 3) return;
this.state = State.LOADING;
callback.onLoading(
Long.valueOf(String.valueOf(values[1])),
Long.valueOf(String.valueOf(values[2])),
isUploading);
break;
case UPDATE_FAILURE:
if (values.length != 3) return;
this.state = State.FAILURE;
callback.onFailure((HttpException) values[1], (String) values[2]);
break;
case UPDATE_SUCCESS:
if (values.length != 2) return;
this.state = State.SUCCESS;
callback.onSuccess((ResponseInfo<T>) values[1]);
break;
default:
break;
}
}
示例25
@Override
public void onReceive(final Context context, Intent intent) {
// Log.i("tag", "BillResultReceiver");
// String money = intent.getStringExtra(Constans.BILL_MONEY);
// String mark = intent.getStringExtra(Constans.BILL_MARK);
// String type = intent.getStringExtra(Constans.BILL_TYPE);
// String billNo = intent.getStringExtra(Constans.BILL_NO);
// PushParam pushParam = new PushParam();
// pushParam.setMark(mark);
// pushParam.setMoney(money);
// pushParam.setBillNo(billNo);
// pushParam.setType(type);
// Log.i("tag", "BillResultReceiver: mark:"+mark+"money:"+money+"billno:"+no+"type:"+type);
final String tradeno = intent.getStringExtra("tradeno");
String cookie = intent.getStringExtra("cookie");
String url = "https://tradeeportlet.alipay.com/wireless/tradeDetail.htm?tradeNo=" + tradeno + "&source=channel&_from_url=https%3A%2F%2Frender.alipay.com%2Fp%2Fz%2Fmerchant-mgnt%2Fsimple-order._h_t_m_l_%3Fsource%3Dmdb_card";
HttpUtils localHttpUtils = new HttpUtils(15000);
localHttpUtils.configResponseTextCharset("GBK");
RequestParams localRequestParams = new RequestParams();
localRequestParams.addHeader("Cookie", cookie);
localHttpUtils.send(HttpRequest.HttpMethod.GET, url, localRequestParams, new RequestCallBack() {
@Override
public void onSuccess(ResponseInfo responseInfo) {
Log.i("tag", "onMessageEvent:" + responseInfo.result);
Object localObject = Jsoup.parse((String) responseInfo.result).getElementsByClass("trade-info-value");
if (((Elements) localObject).size() >= 5) {
String paramAnonymousResponseInfo = ((Elements) localObject).get(0).ownText();
String xx = ((Elements) localObject).get(1).ownText();
String xxx = ((Elements) localObject).get(2).ownText();
localObject = ((Elements) localObject).get(3).ownText();
PayHelperUtils.sendmsg(context,"付款成功alipay:订单号:"+ tradeno + "金额：" + paramAnonymousResponseInfo + "备注：" + (String) localObject);
Log.i("tag", "收到支付宝订单,订单号：" + tradeno + "金额：" + paramAnonymousResponseInfo + "备注：" + (String) localObject+"xx:"+xx+"xxx:"+xxx);
PushParam pushParam = new PushParam();
pushParam.setMark((String) localObject);
pushParam.setMoney(paramAnonymousResponseInfo);
pushParam.setBillNo(tradeno);
pushParam.setType("alipay");
pushParam.setState(1);
DBManager dbManager=new DBManager(context);
dbManager.updatePay(pushParam);
// Api.PUSH_ORDER_RESULT(context, pushParam, String.class, 1);
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.i("tag", "服务器异常1");
}
});
}
示例26
@Override
public void addTencentUser(final Handler handler, String openId, String portraitUrl, String nickName,
int sex) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("openId", openId);
params.addQueryStringParameter("portraitUrl", portraitUrl);
try {
params.addQueryStringParameter("nickName", URLEncoder.encode(nickName, "UTF-8"));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
params.addQueryStringParameter("sex", String.valueOf(sex));
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_ADD_TENCENT_USER, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
Log.e(TAG, "save user failure");
return;
}
Log.e(TAG, "save user success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("user", user);
message.what = Constants.SUCCESS;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "save user failure", error);
handler.sendEmptyMessage(Constants.FAILURE);
}
});
}
示例27
@Override
public void addSinaUser(final Handler handler, String uid, String portraitUrl,
String nickName) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("uid", uid);
params.addQueryStringParameter("portraitUrl", portraitUrl);
try {
params.addQueryStringParameter("nickName", URLEncoder.encode(nickName, "UTF-8"));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_ADD_SINA_USER, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
if(handler != null) {
handler.sendEmptyMessage(Constants.FAILURE_2);
}
Log.e(TAG, "save user failure");
return;
}
Log.e(TAG, "save user success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
if(handler != null) {
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("user", user);
message.what = Constants.SUCCESS_2;
message.setData(bundle);
handler.sendMessage(message);
} else {
App.currentUser = user;
App.getInstance().getSpUtil().putObject("user", user);
}
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "save user failure", error);
if(handler != null) {
handler.sendEmptyMessage(Constants.FAILURE_2);
}
}
});
}
示例28
@Override
public void regist(final Handler handler, String email, String password) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("userName", email);
params.addQueryStringParameter("password", password);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_REGIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE_1);
Log.e(TAG, "regist failure");
if(code == 502) { //用户名存在
ToastUtils.showMessage(mContext, R.string.phone_exists);
}
if(code == 504) { //注册失败
ToastUtils.showMessage(mContext, R.string.regist_fail);
}
return;
}
Log.e(TAG, "regist success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("user", user);
message.what = Constants.SUCCESS_1;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "regist failure", error);
handler.sendEmptyMessage(Constants.FAILURE_1);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
ToastUtils.showMessage(mContext, R.string.regist_fail);
}
}
});
}
示例29
@Override
public void regist(final ApiCallBack apiCallBack, String email, String password) {
HttpUtils http = new HttpUtils();
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("userName", email);
params.addQueryStringParameter("password", password);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_REGIST, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
apiCallBack.onFailure(String.valueOf(map.get("code")));
Log.e(TAG, "regist failure");
if(code == 502) { //用户名存在
ToastUtils.showMessage(mContext, R.string.phone_exists);
}
if(code == 504) { //注册失败
ToastUtils.showMessage(mContext, R.string.regist_fail);
}
return;
}
Log.e(TAG, "regist success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
apiCallBack.onSuccess(user);
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "regist failure", error);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
apiCallBack.onError(error, msg);
}
}
});
}
示例30
@Override
public void login(final Handler handler, String email, String password) {
HttpUtils http = new HttpUtils();
http.configDefaultHttpCacheExpiry(1000 * 60 * 10); //缓存超期时间10分钟
http.configTimeout(Constants.REQUEST_TIME_OUT); //设置超时时间
RequestParams params = new RequestParams();
params.addQueryStringParameter("userName", email);
params.addQueryStringParameter("password", password);
http.send(HttpRequest.HttpMethod.POST,
RcpUri.INTERFACE_URI_LOGIN, params,
new RequestCallBack<String>() {
@Override
public void onSuccess(ResponseInfo<String> responseInfo) {
String rs = responseInfo.result;
Map map = FastjsonUtil.json2Map(rs);
int code = Integer.parseInt(String.valueOf(map.get("code")));
if (code != 200) {
//请求失败
handler.sendEmptyMessage(Constants.FAILURE);
Log.e(TAG, "login failure");
if(code == 503) { //用户名不存在
ToastUtils.showMessage(mContext, R.string.no_account);
return;
}
if(code == 504) { //登录密码错误
ToastUtils.showMessage(mContext, R.string.password_error);
return;
}
ToastUtils.showMessage(mContext, R.string.login_fail);
}
Log.e(TAG, "login success");
User user = FastjsonUtil.deserialize(
map.get("data").toString(), User.class);
Message message = new Message();
Bundle bundle = new Bundle();
bundle.putSerializable("user", user);
message.what = Constants.SUCCESS;
message.setData(bundle);
handler.sendMessage(message);
}
@Override
public void onFailure(HttpException error, String msg) {
Log.e(TAG, "login failure", error);
handler.sendEmptyMessage(Constants.FAILURE);
if(!HttpUtil.isNetworkAvailable(mContext)) {
ToastUtils.showMessage(mContext, R.string.no_net);
} else {
ToastUtils.showMessage(mContext, R.string.login_fail);
}
}
});
}
