标签：封装 String v1 static small type public
package kk.com.android_wdsc.utils.netutils;
import android.content.Context;
import android.content.SharedPreferences;
import android.util.Log;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import kk.com.android_wdsc.httpservice.BaseService;
import kk.com.android_wdsc.utils.mutils.LogeUtils;
import kk.com.android_wdsc.utils.mutils.MyApplication;
import okhttp3.OkHttpClient;
import okhttp3.ResponseBody;
import okhttp3.logging.HttpLoggingInterceptor;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
public class RetrofitUtils {
/*请求码*/
private String INTENRNAL_SERVER_ERROR ="服务器执行请求的时候出错了 ";
private String UNAVAILABLE ="服务器超负载或正停机维护，无法处理请求 ";
private String BAD_REQUEST ="请求报文存在语法错误或参数错误";
private String UNAUTHORIZED ="HTTP认证信息或者是认证失败了 ";
private String FORBIDDEN ="请求资源的访问被服务器拒绝了";
private String NOTFOUND ="服务器找不到你请求的资源";
//http://172.17.8.100/small/user/v1/login
private String baseUrl = "http://mobile.bwstudent.com/";
private Map<String,String> headMap = new HashMap<>();
private OkHttpClient client;
private static RetrofitUtils retrofitUtils;
private Retrofit retrofit;
private SharedPreferences preferences;
/*加入有多个baseUrl,可以动态修改*/
public RetrofitUtils setBaseUrl(String baseUrl){
this.baseUrl = baseUrl;
return this;
}
public static RetrofitUtils getInstance(){
if (retrofitUtils == null){
retrofitUtils = new RetrofitUtils();
}
return retrofitUtils;
}
/*设置统一请求头参数Map<String,String> headMap*/
public RetrofitUtils head(boolean b){
String userId = MyApplication.getContext().getSharedPreferences("User", Context.MODE_PRIVATE).getString("userId", null);
String sessionId = MyApplication.getContext().getSharedPreferences("User", Context.MODE_PRIVATE).getString("sessionId", null);
if (b){
headMap.put("userId",userId);
headMap.put("sessionId",sessionId);
}else {
headMap.clear();
}
return this;
}
/*
* 创建实列
* */
public RetrofitUtils get(int type,String url,Map<String,String> map,CallBack callBack){
loggingInterceptor(map);
Observable<ResponseBody> ob = getService().get(url,headMap,map);
subscribeSend(type,ob,callBack);
return this;
}
public RetrofitUtils post(int type,String url,Map<String,String> map,CallBack callBack){
loggingInterceptor(map);
Observable<ResponseBody> ob = getService().post(url,headMap, map);
subscribeSend(type,ob ,callBack);
return this;
}
public RetrofitUtils put(int type,String url,Map<String,String> map,CallBack callBack){
loggingInterceptor(map);
Observable<ResponseBody> ob = getService().put(url,headMap, map);
subscribeSend(type,ob ,callBack);
return this;
}
public RetrofitUtils delete(int type,String url,Map<String,String> map,CallBack callBack){
loggingInterceptor(map);
Observable<ResponseBody> ob = getService().delete(url,headMap, map);
subscribeSend(type,ob,callBack);
return this;
}
//拦截器
private void loggingInterceptor(Map<String,String> map) {
if (map == null){
map = new HashMap<>();
}
HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
client = new OkHttpClient.Builder()
.addInterceptor(loggingInterceptor)
.readTimeout(5,TimeUnit.SECONDS)
.connectTimeout(5,TimeUnit.SECONDS)
.writeTimeout(5,TimeUnit.SECONDS)
.build();
}
//订阅
private void subscribeSend(final int type, final Observable<ResponseBody> ob, final CallBack callBack) {
ob.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new ObserverIml<ResponseBody>() {
@Override
public void onNext(ResponseBody responseBody) {
try {
String data = responseBody.string();
callBack.onSuccess(type,data);
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void one rror(Throwable e) {
String message = e.getMessage();
switch (e.getMessage()){
case "HTTP 503 ":
callBack.onFail(type,UNAVAILABLE);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
case "HTTP 500 ":
callBack.onFail(type,INTENRNAL_SERVER_ERROR);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
case "HTTP 404 ":
callBack.onFail(type,NOTFOUND);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
case "HTTP 403 ":
callBack.onFail(type,FORBIDDEN);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
case "HTTP 401 ":
callBack.onFail(type,UNAUTHORIZED);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
case "HTTP 400 ":
callBack.onFail(type,BAD_REQUEST);
LogeUtils.e("["+message+"]"+"["+UNAVAILABLE+"]");
break;
default:
callBack.onFail(type,e.getMessage()+":其他异常");
}
}
});
}
private BaseService getService() {
retrofit = new Retrofit.Builder()
.baseUrl(baseUrl)
.client(client)
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
BaseService baseService = retrofit.create(BaseService.class);
return baseService;
}
//返回JavaBean
public interface CallBack<T> {
void onSuccess(int type,String t);
void onFail(int type,String error);
}
}
package kk.com.android_wdsc.httpservice;
/*
*created by 王克强
* on 2019/4/16
*/public class ServiceUser {
/*登录small/user/v1/login*/
public static String logein = "small/user/v1/login";
/*：注册 http://172.17.8.100/small/user/v1/register*/
public static String register = "small/user/v1/register";
/*首页 small/commodity/v1/commodityList*/
public static String commodityList = "small/commodity/v1/commodityList";
/*搜索 small/commodity/v1/findCommodityByKeyword*/
public static String findCommodityByKeyword = "small/commodity/v1/findCommodityByKeyword";
/*banner轮播 small/commodity/v1/bannerShow*/
public static String bannerShow = "small/commodity/v1/bannerShow";
/*二级类目商品 http://172.17.8.100/small/commodity/v1/findCommodityListByLabel*/
public static String findCommodityListByLabel = "small/commodity/v1/findCommodityListByLabel";
/*商品详情 small/commodity/v1/findCommodityDetailsById*/
public static String findCommodityDetailsById = "small/commodity/v1/findCommodityDetailsById";
/*商品评价 http://172.17.8.100/small/commodity/v1/CommodityCommentList*/
public static String CommodityCommentList = "small/commodity/v1/CommodityCommentList";
/*同步购物车 small/order/verify/v1/syncShoppingCart*/
public static String syncShoppingCart = "small/order/verify/v1/syncShoppingCart";
/*我的圈子 small/circle/v1/findCircleList*/
public static String findCircleList = "small/circle/v1/findCircleList";
/*我的资料 small/user/verify/v1/getUserById*/
public static String getUserById = "small/user/verify/v1/getUserById";
/*我的足迹 small/commodity/verify/v1/browseList*/
public static String browseList = "small/commodity/verify/v1/browseList";
/*我的钱包 small/user/verify/v1/findUserWallet*/
public static String findUserWallet = "small/user/verify/v1/findUserWallet";
/*我的收货地址 small/user/verify/v1/receiveAddressList*/
public static String receiveAddressList = "small/user/verify/v1/receiveAddressList";
/*新增收货地址 small/user/verify/v1/addReceiveAddress*/
public static String addReceiveAddress = "small/user/verify/v1/addReceiveAddress";
/*设置默认收货地址 small/user/verify/v1/setDefaultReceiveAddress*/
public static String setDefaultReceiveAddress = "small/user/verify/v1/setDefaultReceiveAddress";
/*修改收货信息 small/user/verify/v1/changeReceiveAddress*/
public static String changeReceiveAddress = "small/user/verify/v1/changeReceiveAddress";
}
标签：封装,String,v1,static,small,type,public 来源： https://blog.csdn.net/wangshuo_/article/details/89597397
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。