Retrofit 2+Rxjava 2について
11772 ワード
ここ数年、Retrofitは燎原の火のようにAndroid界を席巻した.Retrofitがわからなかったら、出かけるのが恥ずかしい..近いくつのプロジェクトはすべてRetrofitを使っていないため、仕方なくアマチュアの时间は自分でちょっとかき回すことしかできなくて、书くのがよくない地方、また惜しみなく教えてもらいます.retrofitを統合するにはappのbild.gradleにライブラリを追加してから、次のことができます.
json解析を統合する必要がある場合は、ライブラリを追加する必要があります.
rxjavaを統合する必要がある場合は、ライブラリを追加する必要があります.
ライブラリの追加が完了しました.次に、要求インタフェースを定義する必要があります.
このインタフェースは私がデータを集約して申請したテストインタフェースで、私はそれを2つの状況に分けます:rajavaを使用して、rxjavaを使用しません.通常の使用では、Retrofitがカプセル化されます.ここでは簡単にカプセル化します.
万事そろったので、今からActivityでRetrofitをテストします.xmlファイル:
プロジェクトを実行し、返されたjson文字列を正常に取得します.GsonFormatプラグインで取得したjson文字列を使用して、jsonを解析するエンティティークラスを作成します.エンティティークラス:
次に、rxjavaを使用して、データを要求します(解析したデータを自動的に返します):
プログラムを実行し、リクエスト結果を正常に取得します.
コードをかき回してしばらく一段落して、休みます..
ソースのダウンロードアドレス:https://github.com/shench5612390/Retrofit2WithRxjava2_Demo/tree/master
compile 'com.squareup.retrofit2:retrofit:2.3.0'
json解析を統合する必要がある場合は、ライブラリを追加する必要があります.
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
rxjavaを統合する必要がある場合は、ライブラリを追加する必要があります.
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
ライブラリの追加が完了しました.次に、要求インタフェースを定義する必要があります.
public interface TestService {
/**
* rxjava
* @return
*/
@POST(AppConstance.NEWS_URL)
Observable getNewsWithRxJava(@Query("key") String key, @Query("type") String type);
/**
* rxjava
* @return
*/
@POST(AppConstance.NEWS_URL)
Call getNewsWithoutRxJava(@Query("key") String key, @Query("type") String type);
}
このインタフェースは私がデータを集約して申請したテストインタフェースで、私はそれを2つの状況に分けます:rajavaを使用して、rxjavaを使用しません.通常の使用では、Retrofitがカプセル化されます.ここでは簡単にカプセル化します.
public class RetrofitUtil {
private volatile static RetrofitUtil sInstance;
private Retrofit mRetrofit;
private TestService mTestService;
private RetrofitUtil(){
mRetrofit = new Retrofit.Builder()
.baseUrl(AppConstance.APP_URL)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
mTestService = mRetrofit.create(TestService.class);
}
public static RetrofitUtil getInstance(){
if (sInstance == null){
synchronized(RetrofitUtil.class){
if (sInstance == null){
sInstance = new RetrofitUtil();
}
}
}
return sInstance;
}
public TestService getTestService(){
return mTestService;
}
}
万事そろったので、今からActivityでRetrofitをテストします.xmlファイル:
在Activity中请求数据，首先，不使用rajava：
findViewById(R.id.btn_get_news_without_rx_java).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
long time1 = System.currentTimeMillis();
Call call = RetrofitUtil.getInstance().getTestService()
.getNewsWithoutRxJava("8bf17cf1c321723f060d5dc5c4da871a", "top");
long time2 = System.currentTimeMillis();
Log.e("MainActivity", " ：" + (time2 - time1) + "ms");
call.enqueue(new Callback() {
@Override
public void onResponse(Call call, Response response) {
try {
String result = response.body().string();
Toast.makeText(MainActivity.this, result, Toast.LENGTH_SHORT).show();
Log.e("MainActivity", "Thread.currentThread():" + Thread.currentThread());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call call, Throwable t) {
Toast.makeText(MainActivity.this, t.toString(), Toast.LENGTH_SHORT).show();
}
});
}
});
プロジェクトを実行し、返されたjson文字列を正常に取得します.GsonFormatプラグインで取得したjson文字列を使用して、jsonを解析するエンティティークラスを作成します.エンティティークラス:
public class NewsBean {
private String reason;
private ResultBean result;
private int error_code;
@Override
public String toString() {
return "NewsBean{" +
"reason='" + reason + '\'' +
", result=" + result +
", error_code=" + error_code +
'}';
}
public String getReason() {
return reason;
}
public void setReason(String reason) {
this.reason = reason;
}
public ResultBean getResult() {
return result;
}
public void setResult(ResultBean result) {
this.result = result;
}
public int getError_code() {
return error_code;
}
public void setError_code(int error_code) {
this.error_code = error_code;
}
public static class ResultBean {
private String stat;
private List data;
@Override
public String toString() {
return "ResultBean{" +
"stat='" + stat + '\'' +
", data=" + data +
'}';
}
public String getStat() {
return stat;
}
public void setStat(String stat) {
this.stat = stat;
}
public List getData() {
return data;
}
public void setData(List data) {
this.data = data;
}
public static class DataBean {
private String uniquekey;
private String title;
private String date;
private String category;
private String author_name;
private String url;
private String thumbnail_pic_s;
private String thumbnail_pic_s02;
private String thumbnail_pic_s03;
@Override
public String toString() {
return "DataBean{" +
"uniquekey='" + uniquekey + '\'' +
", title='" + title + '\'' +
", date='" + date + '\'' +
", category='" + category + '\'' +
", author_name='" + author_name + '\'' +
", url='" + url + '\'' +
", thumbnail_pic_s='" + thumbnail_pic_s + '\'' +
", thumbnail_pic_s02='" + thumbnail_pic_s02 + '\'' +
", thumbnail_pic_s03='" + thumbnail_pic_s03 + '\'' +
'}';
}
public String getUniquekey() {
return uniquekey;
}
public void setUniquekey(String uniquekey) {
this.uniquekey = uniquekey;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getDate() {
return date;
}
public void setDate(String date) {
this.date = date;
}
public String getCategory() {
return category;
}
public void setCategory(String category) {
this.category = category;
}
public String getAuthor_name() {
return author_name;
}
public void setAuthor_name(String author_name) {
this.author_name = author_name;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getThumbnail_pic_s() {
return thumbnail_pic_s;
}
public void setThumbnail_pic_s(String thumbnail_pic_s) {
this.thumbnail_pic_s = thumbnail_pic_s;
}
public String getThumbnail_pic_s02() {
return thumbnail_pic_s02;
}
public void setThumbnail_pic_s02(String thumbnail_pic_s02) {
this.thumbnail_pic_s02 = thumbnail_pic_s02;
}
public String getThumbnail_pic_s03() {
return thumbnail_pic_s03;
}
public void setThumbnail_pic_s03(String thumbnail_pic_s03) {
this.thumbnail_pic_s03 = thumbnail_pic_s03;
}
}
}
}
次に、rxjavaを使用して、データを要求します(解析したデータを自動的に返します):
findViewById(R.id.btn_get_news_with_rx_java).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
RetrofitUtil.getInstance().getTestService()
.getNewsWithRxJava("8bf17cf1c321723f060d5dc5c4da871a", "top")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer() {
private Disposable mDisposable;
@Override
public void onSubscribe(Disposable d) {
mDisposable = d;
}
@Override
public void onNext(NewsBean value) {
Toast.makeText(MainActivity.this, value.toString(), Toast.LENGTH_SHORT).show();
mDisposable.dispose();//
}
@Override
public void onError(Throwable e) {
Toast.makeText(MainActivity.this, e.toString(), Toast.LENGTH_SHORT).show();
mDisposable.dispose();//
}
@Override
public void onComplete() {
}
});
}
});
プログラムを実行し、リクエスト結果を正常に取得します.
コードをかき回してしばらく一段落して、休みます..
ソースのダウンロードアドレス:https://github.com/shench5612390/Retrofit2WithRxjava2_Demo/tree/master