RxJava+Retrofit 網絡請求時使用自定義攔截器Interceptor 處理多個baseUrl

在項目開發(fā)中,使用RxJava+Retrofit 網絡請求一般會遇到多個baseUrl,如果僅僅通過Retrofit 的方法設置一個baseUrl是達不到效果的。

new Retrofit.Builder()
                .baseUrl(baseUrl)
                .addConverterFactory(ScalarsConverterFactory.create())
                .addConverterFactory(FormConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create(HJson.getGson()))
                .client(UOkHttp.getInstance().okHttpClient)
                .build();

此時需要自定義一個攔截器,處理不同的baseUrl,繼承okhttp3(Retrofit底層使用的還是okhttp)中提供的Interceptor接口,實現(xiàn)intercept方法,在其中獲取Request和headers,判斷其中的數(shù)據(jù)并處理。

public class HhmOkInterceptor implements Interceptor {
    @Override
    public Response intercept(Chain chain) throws IOException {
        //獲取request
        Request request = chain.request();
        //獲取request的創(chuàng)建者builder
        Request.Builder builder = request.newBuilder();
        //從request中獲取headers,通過給定的鍵url_name
        List<String> headerValues = request.headers("base_url");
        if (headerValues != null && headerValues.size() > 0) {
            //如果有這個header,先將配置的header刪除,因此header僅用作app和okhttp之間使用
            builder.removeHeader("base_url");
            //匹配獲得新的BaseUrl
            String headerValue = headerValues.get(0);
            HttpUrl newBaseUrl;
            if ("one".equals(headerValue)) {
                newBaseUrl = HttpUrl.parse(API.BASE_URL_ONE);
            } else if ("two".equals(headerValue)) {
                newBaseUrl = HttpUrl.parse(API.BASE_URL_TWO);
            } else if("three".equals(headerValue)){
                newBaseUrl = HttpUrl.parse(API.BASE_URL_THREE);
            } else if("test".equals(headerValue)){
                newBaseUrl = HttpUrl.parse(API.BASE_URL_TEST);
            }
            else{
                //還是原來的地址
                newBaseUrl = HttpUrl.parse(API.BASE_URL);
            }
            //從request中獲取原有的HttpUrl實例oldHttpUrl
            HttpUrl oldHttpUrl = request.url();
            //重建新的HttpUrl,修改需要修改的url部分
            HttpUrl newFullUrl = oldHttpUrl
                    .newBuilder()
                    .scheme(newBaseUrl.scheme())
                    .host(newBaseUrl.host())
                    .port(newBaseUrl.port())
                    .build();
            //重建這個request,通過builder.url(newFullUrl).build();
            //然后返回一個response至此結束修改
            return chain.proceed(builder.url(newFullUrl).build());
        } else {
            return chain.proceed(request);
        }
    }
}

在OkHttp對象中添加該攔截器對象。

new OkHttpClient.Builder()
.addInterceptor(new HhmOkInterceptor())//添加上面的url攔截器
.build();

在Retrofit請求接口中添加注解,如果不添加Headers注解的默認使用baseUrl,添加該注解的則使用注解對應的baseUrl。比如下面第一個請求注解對應的baseUrl為API.BASE_URL_ONE,第二個請求對應的baseUrl為API.BASE_URL。

@Headers({"base_url:one"})//添加注解,更換baseUrl
@POST(ApiMethods.getData)
Observable<BaseResponse> getData(@Body BaseParams params);


@POST(ApiMethods.userLogin)
Observable<LoginResponse> getUserLogin(@Body LoginParams params);
最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容