天天看點

封裝Retrofit2+OkHttp3+RxJava網絡請求

現在Android 市面上很火的當然是 Retrofit+RxJava + OkHttp, 功能強大,簡單易用,是以選用這套方案來改造網絡庫。

簡介:

Retrofit: Retrofit是Square 公司開發的一款正對Android 網絡請求的架構。底層基于OkHttp 實作,OkHttp 已經得到了google 官方的認可。Retrofit官網

OkHttp: 也是Square 開源的網絡請求庫

RxJava:RxJava 在 GitHub 首頁上的自我介紹是 “a library for composing asynchronous and event-based programs using observable sequences for the Java VM”(一個在 Java VM 上使用可觀測的序列來組成異步的、基于事件的程式的庫)。這就是 RxJava ,概括得非常精準。總之就是讓異步操作變得非常簡單。

各自的職責:Retrofit 負責請求的資料和請求的結果,使用接口的方式呈現,OkHttp 負責請求的過程,RxJava 負責異步,各種線程之間的切換。

RxJava + Retrofit + okHttp 已成為目前Android 網絡請求最流行的方式。

一、添加依賴庫

//RxJava
    compile 'io.reactivex:rxjava:1.1.3'
    //RxAndroid
    compile 'io.reactivex:rxandroid:1.1.0'
    //retrofit
    compile 'com.squareup.retrofit2:retrofit:2.0.0'
    //retrofit依賴Gson
    compile 'com.squareup.retrofit2:converter-gson:2.0.0'
    //OkHttp
    compile 'com.squareup.okhttp3:okhttp:3.2.0'
    //retrofit依賴RxJava
    compile 'com.squareup.retrofit2:adapter-rxjava:2.0.0'
           

二、生成接口執行個體的管理類

public class RetrofitServiceManager {
    private static final int DEFAULT_CONNECT_TIME = 10;
    private static final int DEFAULT_WRITE_TIME = 30;
    private static final int DEFAULT_READ_TIME = 30;
    private final OkHttpClient okHttpClient;
    private static final String REQUEST_PATH = "https://api.douban.com/v2/movie/";
    private final Retrofit retrofit;

    private RetrofitServiceManager() {

        okHttpClient = new OkHttpClient.Builder()
                .connectTimeout(DEFAULT_CONNECT_TIME, TimeUnit.SECONDS)//連接配接逾時時間
                .writeTimeout(DEFAULT_WRITE_TIME, TimeUnit.SECONDS)//設定寫操作逾時時間
                .readTimeout(DEFAULT_READ_TIME, TimeUnit.SECONDS)//設定讀操作逾時時間
                .build();

        retrofit = new Retrofit.Builder()
                .client(okHttpClient)//設定使用okhttp網絡請求
                .baseUrl(REQUEST_PATH)//設定伺服器路徑
                .addConverterFactory(GsonConverterFactory.create())//添加轉化庫,預設是Gson
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())//添加回調庫,采用RxJava
                .build();

    }

    private static class SingletonHolder {
        private static final RetrofitServiceManager INSTANCE = new RetrofitServiceManager();
    }

    /*
    * 擷取RetrofitServiceManager
    **/
    public static RetrofitServiceManager getInstance() {
        return SingletonHolder.INSTANCE;
    }

    public <T> T create(Class<T> service) {
        return retrofit.create(service);
    }
}
           

從Retrofit更新到2.0之後,就使用了build設計模式(生産者模式),将一個複雜的建構與其表示相分離。

同樣更新到okhttp3後,也使用build設計模式。

okhttp參數說明:
	cookieJar(new CookiesManager()): 設定一個自動管理cookies的管理器
	addInterceptor(new MyIntercepter()):添加攔截器
	addNetworkInterceptor(new
	CookiesInterceptor(MyApplication.getInstance().getApplicationContext())):添加網絡連接配接器
	connectTimeout(30, TimeUnit.SECONDS):請求逾時時間 
	writeTimeout(30,TimeUnit.SECONDS):寫入逾時時間 
	readTimeout(30, TimeUnit.SECONDS):讀取逾時時間
           

三、建立接口類

public interface MovieService {
        //擷取豆瓣前20的榜單
        @GET("top250")
        Observable<movieTopReq> getMovicTop(@Query("start") int start, @Query("count") int count);
    }
           

接口已經建立出來了,Retrofit是用注解來完成設定的,要通路的url,請求方式,請求頭。

常用的注解:

@GET GET請求方式

@POST POST請求方式

@Query GET請求參數

@Header用來添加Header請求頭

@FormUrlEncoded post請求頭标示

其他注解請求方式:

@PUT 表示這是一個PUT請求

@DELETE 表示這是一個DELETE請求

@HEAD 表示這是一個HEAD請求

@OPTIONS 表示這是一個OPTION請求

@PATCH 表示這是一個PAT請求

四、建立實作接口來友善調用

public class HttpEngine {

    private static MovieService movieService = RetrofitServiceManager.getInstance().create(MovieService.class);

    /*
    * 擷取豆瓣電影榜單
    * **/
    public static void getDuoBanTop(int start, int count, Observer<movieTopReq> observer) {
        setSubscribe(movieService.getMovicTop(start, count), observer);
    }

    private static <T> void setSubscribe(Observable<T> observable, Observer<T> observer) {
        observable.subscribeOn(Schedulers.io())
                .subscribeOn(Schedulers.newThread())//子線程通路網絡
                .observeOn(AndroidSchedulers.mainThread())//回調到主線程
                .subscribe(observer);
    }
}
           

把網絡接口統一放到一個接口類中,讓Retrofit建立實作接口來友善調用。setSubscribe方法其實就是插入觀察者。

五、activity調用

public class MainActivity extends AppCompatActivity {

    private RecyclerView recyclerView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        initData();
    }

    private void initData() {
	    //調用封裝好的retrofit請求方法
        HttpEngine.getDuoBanTop(0, 20, new Observer<movieTopReq>() {
            @Override
            public void onCompleted() {
				//完成
            }

            @Override
            public void onError(Throwable e) {
	            //失敗
                Log.i("retrofit==111=", "請求錯誤:"+e.getMessage());
            }

            @Override
            public void onNext(movieTopReq movieTopReq) {
	            //成功
                Log.i("retrofit==222=", movieTopReq.getTitle()+"---"+movieTopReq.getCount()
                        +"---"+movieTopReq.getStart()+"---"+movieTopReq.getTotal()+"---"+movieTopReq.getSubjects());
            }
        });
    }
}
           

需要Demo的童鞋公衆号回複:"Retrofit"即可擷取

小編整理了一份Android電子書籍,需要的童鞋關注底部公衆号(longxuanzhigu)回複:“e_books” 即可擷取哦!

封裝Retrofit2+OkHttp3+RxJava網絡請求

以下是個人公衆号(longxuanzhigu),之後釋出的文章會同步到該公衆号,友善交流學習Android知識及分享個人愛好文章:

封裝Retrofit2+OkHttp3+RxJava網絡請求