1. Switch network request addresses. For example, the project has the partition function. Different partitions correspond to different server addresses
2. The format of the interface returned by the server is different. Some interfaces return THE JSON format, while others return String format
3. How can I add fixed parameters, such as version number and channel information, to the URL address
4. How do I add dynamic parameters to a URL address
5. Whether to add logs for network requests
6. Whether to add header(sessionId)
7. Network requests can be configured to display network loading animations
8. Encapsulating Observalbe’s data processing steps can dynamically change the process of data processing
9. Encapsulate error handling to distinguish network errors from application-layer response errors.

In the three-way relationship, Retrofit is primarily responsible for interfacing network requests, handing the actual network requests and responses to OkHttp, while RxJava plays the role of data processing after the data response in the network framework. Take a simple analogy: suppose the user needs to fly from Shanghai to Zhongguancun in Beijing for business. He needs to check in, take a plane, and go to Zhongguancun after arriving in Beijing. Check-in is handled by Retrofit, the actual transportation is done by aircraft (Okhttp), and the customer arrives (data return) to select the vehicle (RtHttp) to zhongguancun.

First, let’s look at the encapsulated network request usage:

Rthttp.with (this) // Set context.setShowWaitingDialog (true) // Set to display the network loading animation SetObservable (MobileApi. The response (map, ProtocolUtils PROTOCOL_MSG_ID_LOGIN)) / / MobileApi. The response returns a Observalbe . Subscriber(new ApiSubscriber() {// Set subscriber, ApiSubscriber encapsulates subscriber; @override public void onNext(JSONObject result) {// only implement onNext method // specific business logic}});Copy the code

Let’s look at creating an Observable:

public class MobileApi extends BaseApi{ public static NetworkApi networkApi; public static Observable obserable; Public static NetworkApi getNetworkApi() {// Create NetworkApi if(NetworkApi ==null){NetworkApi = new RtHttp.NetworkApiBuilder().addSession() // add sessionid.addParameter () // add fixed.build(); } return networkApi; } public static Observable getObserable(Observable observable) { obserable = new ObserableBuilder(observable) .addapiException () // Add apiExcetion filter.build (); return obserable; } public static Observable response(HashMap map, int protocolId) { RequestBody body = toBody(map); return getObserable(getNetworkApi().response(protocolId, body)); }}Copy the code

The getNetworkApi() method can create a specific NetworkApi, and getObserable can add specific processing after the data is returned.

public abstract class BaseApi {

    public static RequestBody toBody(HashMap map) {
        Gson gson = new Gson();
        ImiRequestBean requestBean= new ImiRequestBean();
        requestBean.setRequeststamp(ProtocolUtils.getTimestamp());
        requestBean.setData(map);
        return RequestBody.create(okhttp3.MediaType.parse("application/json; charset=utf-8"), gson.toJson(requestBean));
    }

    public static RequestBody toBody(JSONObject jsonObject) {
        return RequestBody.create(okhttp3.MediaType.parse("application/json; charset=utf-8"), (jsonObject).toString());
    }

    public static class ObserableBuilder{

        private Observable observable;
        private boolean apiException;
        private boolean toJSONJbject;
        private boolean isWeb;
        private Scheduler subscribeScheduler;
        private Scheduler obscerveScheduler;

        public void setObscerveScheduler(Scheduler obscerveScheduler) {
            this.obscerveScheduler = obscerveScheduler;
        }

        public void setSubscribeScheduler(Scheduler subscribeScheduler) {
            this.subscribeScheduler = subscribeScheduler;
        }

        public ObserableBuilder(Observable o) {
            this.observable = o;
        }

        public ObserableBuilder addApiException(){
            apiException = true;
            return this;
        }
        public ObserableBuilder addToJSONObject(){
            toJSONJbject = true;
            return this;
        }

        public ObserableBuilder isWeb() {
            isWeb = true;
            return this;
        }

        public Observable build(){
            if(isWeb){
                observable = observable.map(new StringToJSONObjectFun1());
            }
            if(apiException){
                observable = observable.flatMap(new ApiThrowExcepitionFun1());
            }
            if(toJSONJbject){
                observable = observable.map(new ObjectToJSONObjectFun1());
            }
            if(subscribeScheduler!=null){
                observable = observable.subscribeOn(subscribeScheduler);
            }else {
                observable = observable.subscribeOn(Schedulers.io());
            }
            if(obscerveScheduler!=null){
                observable = observable.observeOn(obscerveScheduler);
            }else{
                observable = observable.observeOn(AndroidSchedulers.mainThread());
            }
            return observable;
        }
    }
}
Copy the code

The BaseApi provides methods for toBody and supports converting JSONObject and HashMap into RequestBody. ObserableBuilder is used to process the Observalbe object returned by NetworkApi. Different ObservalBes can be returned using ObserableBuilder. By default, the data request is set in the child thread, and after processing, the OnNext method is returned using the main thread.

ApiSubscriber encapsulates whether to display loading animations and the default handling of onError ().

public abstract class ApiSubscriber extends Subscriber { private Context mCtx; private WaitingDialog waitingDialog; Private Boolean isShowWaitDialog; public void setShowWaitDialog(boolean showWaitDialog) { isShowWaitDialog = showWaitDialog; } @Override public void onStart() { super.onStart(); if(isShowWaitDialog){ showWaitDialog(); } } public void setmCtx(Context mCtx) { this.mCtx = mCtx; } @Override public void onCompleted() { if(isShowWaitDialog){ dismissDialog(); @override public void onError(Throwable e) {if(isShowWaitDialog){ dismissDialog(); } Throwable throwable = e; if(Log.isDebuggable()){ Log.i(RtHttp.TAG,throwable.getMessage().toString()); } /** * while (throwable.getCause()! = null){ e = throwable; throwable = throwable.getCause(); } if(e instanceof HttpException){// If (e instanceof HttpException){ if(TextUtils.isEmpty(httpException.getMessage())){ ToastUtil.showToast(mCtx, R.string.imi_toast_common_net_error); }else { String errorMsg = httpException.getMessage(); if(TextUtils.isEmpty(errorMsg)){ ToastUtil.showToast(mCtx, R.string.imi_toast_common_net_error); }else { ToastUtil.showToast(mCtx, errorMsg); }}}else if(e instanceof ApiException){onResultError((ApiException) e); } else if (e instanceof JsonParseException | | e instanceof JSONException | | e instanceof ParseException) {/ / parsing exceptions ToastUtil.showToast(mCtx, R.string.imi_toast_common_parse_error); }else if(e instanceof UnknownHostException){ ToastUtil.showToast(mCtx, R.string.imi_toast_common_server_error); }else if(e instanceof SocketTimeoutException) { ToastUtil.showToast(mCtx, R.string.imi_toast_common_net_timeout); }else { e.printStackTrace(); ToastUtil.showToast(mCtx, R.string.imi_toast_common_net_error); }} /** * Server returned error * @param ex */ protected void onResultError(ApiException ex){switch (ex. GetCode ()){// server returned code default processing case 10021: ToastUtil.showToast(mCtx, R.string.imi_login_input_mail_error); break; case 10431: ToastUtil.showToast(mCtx, R.string.imi_const_tip_charge); break; default: String msg = ex.getMessage(); if(TextUtils.isEmpty(msg)){ ToastUtil.showToast(mCtx, R.string.imi_toast_common_net_error); }else { ToastUtil.showToast(mCtx, msg); } } } private void dismissDialog(){ if(waitingDialog! =null) { if(waitingDialog.isShowing()) { waitingDialog.dismiss(); } } } private void showWaitDialog(){ if (waitingDialog == null) { waitingDialog = new WaitingDialog(mCtx); waitingDialog.setDialogWindowStyle(); waitingDialog.setCanceledOnTouchOutside(false); } waitingDialog.show(); }}Copy the code

public class ResponseInfo { private int code; private String message; private T data; private String responsestamp; public String getResponsestamp() { return responsestamp; } public void setResponsestamp(String responsestamp) { this.responsestamp = responsestamp; } public int getCode() { return code; } public void setCode(int code) { this.code = code; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public T getData() { return data; } public void setData(T data) { this.data = data; }}Copy the code

public class ParameterInterceptor implements Interceptor{ @Override public Response intercept(Chain chain) throws IOException { Request request = chain.request(); // HttpUrl HttpUrl = request.url().newBuilder() // Use addQueryParameter() to add parameters to the URL .addQueryParameter("userId", CommonData.getUid()+"") .build(); request = request.newBuilder().url(httpUrl).build(); return chain.proceed(request); }}Copy the code

public class HeaderInterceptor implements Interceptor{ private Context context; public HeaderInterceptor(Context context) { this.context = context; } @Override public Response intercept(Chain chain) throws IOException { Request original = chain.request(); Request.Builder requestBuilder = original.newBuilder() .header("sessionId", CommonData.getUserInfo(context).sessionId); Request = requestBuilder.build(); return chain.proceed(request); }}Copy the code

The network request returns the following log:

RtHttp: -------------------- begin-------------------- POST acid-> userId->306448537 network code->200 url->http://*******/user/loadInitData? UserId = 306448537 & userSecretKey = ckj5k3vrxao * * * ekblcru5v3r time - > 160.708437 request headers - > request - > Body - > {" data ": {" getTime" : 1, "prize" : [{" id ": 4," name ":" sports car, worth 8000 gold beans ", "num" : "x1"}, {9, "id" : "name" : "birthday cake. ","num":"x1"},{"id":11,"name":" volcano of love ", Worth 80000 gold beans, "" num" : "x1"}, {" id ": 15," name ":" 68888 gold beans ", "num" : "68888"}, {" id ": 63," name ":" cool border, speak different! ", "num" : "x1"}, {" id ": 25," name ":" the chance of lucky stone, five minutes of ascension ", "num" : "x1"}, {" id ": 28," name ":" 1888 sunshine, Worth 944 gold beans, "" num" : "1888"}, {" id ": 30," name ":" bicycle, worth 80000 gold beans ", "num" : "x1"}, {" id ": 59," name ":" red rose, Worth 1000 gold beans, "" num" : "10"}, {" id ": 34," name ":" super beautiful treasure box, worth 700000 gold beans ", "num" : "x1"}, {" id ": 36," name ":" flower elves, 520, The goddess of love, "" num" : "x520"}, {" id ": 38," name ":" lucky star, can greatly improve within 30 minutes ", "num" : "x1"}, {" id ": 40," name ":" a diamond necklace, ","num":"x3"},{"id":42,"name":" Worth 2400 gold beans, "" num" : "x3"}], "resetTime" : 6, "userId" : 306448537}, "MSG" : "OK", "result" : 1})Copy the code

The above is the encapsulated code. By using the Builder pattern, you can create different Networkapi instances to meet the requirements of the project and better respond to the changing requirements.