Retrofit和Rxjava結合使用

1.新增依賴：

compile 'com.squareup.retrofit2:retrofit:2.1.0'
compile 'com.google.code.gson:gson:2.8.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'

2.Retrofit的使用：

1）.編寫API服務程式碼

package com.micky.retrofitrxandroiddagger2.data.api;

import com.micky.retrofitrxandroiddagger2.data.api.response.GetIpInfoResponse;

import retrofit.Call;
import retrofit.http.GET;
import retrofit.http.Query;
import rx.Observable;

/**
 * @Project retrofitrxandroiddagger2
 * @Packate com.micky.retrofitrxandroiddagger2.data.api
 * @Description
 * @Author Micky Liu
 * @Email 
 
[email protected]
 * @Date 2015-12-21 17:22
 * @Version 1.0
 */
public interface ApiService {
    @GET("service/getIpInfo.php")
    Call<MyMessage> getIpInfo(@Body FprmBody body);
}

2).使用GsonFormat定義接收資料的Bean類

public class MyMessage {

    /**
     * reason : 成功的返回
     * result : {"code":100000,"text":"答不答就看我心情啦。"}
     * error_code : 0
     */

    private String reason;
    private ResultBean result;
    private int error_code;

    public String getReason() {
        return reason;
    }

    public void setReason(String reason) {
        this.reason = reason;
    }

    public ResultBean getResult() {
        return result;
    }
 

3).網路請求資料

Retrofit retrofit = new Retrofit.Builder()
            .baseUrl("http://op.juhe.cn/robot/index/")
            .client(new OkHttpClient())
            .addConverterFactory(GsonConverterFactory.create())
            .build();
    FormBody body = new FormBody.Builder()
            .add("info","%E6%88%91%E6%98%AF%E8%B0%81&")
            .add("dtype","&loc=&userid=&")
            .add("key","f5d2667dff1bfc58786a06c04c8429af").build();

    netAPI= retrofit.create(NetAPI.class);
    netAPI.Message(body).enqueue(new Callback<MyMessage>() {
        @Override
        public void onResponse(Call<MyMessage> call, Response<MyMessage> response) {
            
        }

        @Override
        public void onFailure(Call<MyMessage> call, Throwable t) {

        }
    });
 

3.Retrofit和Rxjava結合使用

1).首先在初始化Retrofit中加入addCallAdapterFactory(RxjavaCallAdapterFactory.create())

Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("http://op.juhe.cn/robot/index/")
                    .client(new OkHttpClient())
                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                    .addConverterFactory(GsonConverterFactory.create())
                    .build();

2).API類中Call變為Observable

Observable<MyMessage> Message(@Body FormBody body);

3).具體程式碼

Retrofit retrofit = new Retrofit.Builder()
                    .baseUrl("http://op.juhe.cn/robot/index/")
                    .client(new OkHttpClient())
                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                    .addConverterFactory(GsonConverterFactory.create())
                    .build();
            FormBody body = new FormBody.Builder()
                    .add("info","%E6%88%91%E6%98%AF%E8%B0%81&")
                    .add("dtype","&loc=&userid=&")
                    .add("key","f5d2667dff1bfc58786a06c04c8429af").build();

            netAPI= retrofit.create(NetAPI.class);
            netAPI.Message(body).subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Observer<MyMessage>() {
                        @Override
                        public void onSubscribe(@NonNull Disposable d) {
                            Log.e(TAG,"onsubscribe");
                        }

                        @Override
                        public void onNext(@NonNull MyMessage myMessage) {
                            Log.e(TAG,"onNext");
                            tx.setText(myMessage.getResult().getText());
                        }

                        @Override
                        public void onError(@NonNull Throwable e) {
                            Log.e(TAG,"onError");
                        }

                        @Override
                        public void onComplete() {
                            Log.e(TAG,"onComplete");
                        }
                    });
        }
    })

不同之處在於加入三個方法：

subscribeOn(Schedulers.io):指定Observable的工作, 在我們的例子中Observable的工作即傳送請求, 在io執行緒做, 指定了被觀察者的處理執行緒;

observeOn(AndroidSchedulers.mainThread()):指定最後onNext()回撥在主執行緒, 即指定了通知後續觀察者的執行緒.

subscribe():新增一個訂閱者, 即它的觀察者.當請求返回後, 回到主執行緒, 更新UI.