準(zhǔn)備

    compile 'com.squareup.retrofit2:retrofit:2.0.0-beta3'
    compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta3' //已經(jīng)包含了gson
    compile 'com.squareup.retrofit2:adapter-rxjava:2.0.0-beta4'
    compile 'io.reactivex:rxjava:1.1.0'
    compile 'io.reactivex:rxandroid:1.1.0'
    compile 'com.squareup.okio:okio:1.6.0'
    compile 'com.squareup.okhttp3:okhttp:3.2.0'
    compile 'com.squareup.okhttp3:logging-interceptor:3.2.0' // 看log需要

關(guān)鍵代碼

1.定義api接口

public interface CodeHubService {

    @GET("/v2/showcases")
    Observable<ArrayList<ShowCase>> getShowCaseList();
}

2.創(chuàng)建Retrofit

private Retrofit mRetrofit;
HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
            @Override
            public void log(String message) {
                Log.d("CodeHubServiceManager", message);
            }
        });
//        自定義gson解析(List不需要也能自己解析)
//        Type showCaseType = new TypeToken<ArrayList<ShowCase>>(){}.getType();
//        Gson gson = new GsonBuilder().registerTypeAdapter(showCaseType,
//                new JsonDeserializer<ArrayList<ShowCase>>() {
//                    @Override
//                    public ArrayList<ShowCase> deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context) throws JsonParseException {
//                        return new Gson().fromJson(json, typeOfT);
//                    }
//                }).create();

loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
        OkHttpClient okHttpClient = new OkHttpClient.Builder()
                .addInterceptor(loggingInterceptor) // 攔截器
                .connectTimeout(20, TimeUnit.SECONDS)
                .build();

mRetrofit = new Retrofit.Builder()
                .baseUrl("http://trending.codehub-app.com")
                .client(okHttpClient)  // okHttpClient實(shí)例,不調(diào)用使用默認(rèn)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();

3. 調(diào)用api接口,獲取Observable,并進(jìn)行相關(guān)設(shè)置,調(diào)用subscribe

private CodeHubService mCodeHubService;

mCodeHubService = mRetrofit.create(CodeHubService.class);

Observable<ArrayList<ShowCase>> showCaseObservable = codeHubService.getShowCaseList()
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .unsubscribeOn(Schedulers.io()); // 此處注意,***On每個(gè)調(diào)用返回的都是新的Observable

showCaseObservable .subscribe(new Subscriber<ArrayList<ShowCase>>() {
                    @Override
                    public void onCompleted() {
                        Toast.makeText(getContext(), "onCompleted", Toast.LENGTH_SHORT).show();
                    }

                    @Override
                    public void onError(Throwable e) {
                        Toast.makeText(getContext(), "onError " + e.getMessage(), Toast.LENGTH_SHORT).show();
                    }

                    @Override
                    public void onNext(ArrayList<ShowCase> showCases) {
                        Toast.makeText(getContext(), "showCases size=" + showCases.size(), Toast.LENGTH_SHORT).show();
                        showCaseAdapter.updateData(showCases);
                    }
                });

填坑

1. Observable的subscribeOn,observeOn,unsubscribeOn是返回新的對(duì)象,而不是修改

參考

http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2015/0106/2275.html (Okhttp基本使用)
http://jakewharton.github.io/butterknife/
http://square.github.io/retrofit/