本文源碼地址：https://github.com/HelloNanKe/Joke
先看一下Rxjava和Retrofit相關的依賴
compile'io.reactivex.rxjava2:rxjava:2.0.7'
compile'io.reactivex.rxjava2:rxandroid:2.0.1'
compile'com.squareup.retrofit2:retrofit:2.2.0'
compile'com.squareup.retrofit2:converter-gson:2.2.0'
compile'com.squareup.retrofit2:adapter-rxjava2:2.2.0'
本文以來福島的一個笑話api為例，在這里想他們表示感謝
api為：http://api.laifudao.com/open/xiaohua.json
返回的數(shù)據(jù),沒有數(shù)據(jù)頭抽减，且返回的內(nèi)容中夾雜著HTML標簽
先看代碼吧：
public interfaceApiService {
/**
* 來福笑話接口
*@return List<>
*/
@GET("xiaohua.json")
Observable<List<MyJoke>> getData();
}
在這里需要注意的是允青，與Retrofit相比不再是Call<List<MyJoke>>,而是使用了Rxjava的Observable<List<MyJoke>> getData();
這里MyJoke使用GsonFormat自動生成的一個實體類。
接下來就是對網(wǎng)絡請求進行一下簡單的封裝了
HttpMethods.java文件
package com.example.nanke.joke;
import com.example.nanke.joke.JavaBean.MyJoke;
import java.util.List;
import java.util.concurrent.TimeUnit;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import okhttp3.OkHttpClient;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
/**
* Created by zt on 2017/3/10.
*/
public class HttpMethods {
private static final String BASE_URL = "http://api.laifudao.com/open/";
private static final int TIME_OUT=4;
private Retrofit retrofit;
private ApiService apiService;
private HttpMethods() {
/**
* 構造函數(shù)私有化
* 并在構造函數(shù)中進行retrofit的初始化
*/
OkHttpClient client=new OkHttpClient();
client.newBuilder().connectTimeout(TIME_OUT, TimeUnit.SECONDS);
/**
* 由于retrofit底層的實現(xiàn)是通過okhttp實現(xiàn)的卵沉，所以可以通過okHttp來設置一些連接參數(shù)
* 如超時等
*/
retrofit = new Retrofit.Builder()
.baseUrl(BASE_URL)
.client(client)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
apiService=retrofit.create(ApiService.class);
}
private static class sinalInstance {
public static final HttpMethods instance = new HttpMethods();
}
public static HttpMethods getInstance(){
return sinalInstance.instance;
}
public void getJoke(Observer<List<MyJoke>> observer){
apiService.getData()
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer);
}
}
在HttpMethods中颠锉，將構造函數(shù)私有化是為了實現(xiàn)單例，并向外提供了一個請求數(shù)據(jù)的方法 getJoke;該方法的參數(shù)是一個觀察者史汗，接著看一下MainActivity.java文件
package com.example.nanke.joke;
import android.os.Handler;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.util.Log;
import com.cjj.MaterialRefreshLayout;
import com.cjj.MaterialRefreshListener;
import com.example.nanke.joke.JavaBean.MyJoke;
import java.util.ArrayList;
import java.util.List;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
public class MainActivity extends AppCompatActivity {
private RecyclerView recyclerView;
private List<MyJoke> jokes = new ArrayList<>();
private MyAdpter adpter;
private MaterialRefreshLayout materialRefreshLayout;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
recyclerView = (RecyclerView) findViewById(R.id.recycler_View);
materialRefreshLayout = (MaterialRefreshLayout) findViewById(R.id.refresh);
getData();
materialRefreshLayout.setMaterialRefreshListener(new MaterialRefreshListener() {
@Override
public void onRefresh(final MaterialRefreshLayout materialRefreshLayout) {
new Handler().postDelayed(new Runnable() {
@Override
public void run() {
getData();
adpter.refreshData(jokes);
materialRefreshLayout.finishRefresh();
}
}, 2000);
}
});
}
public void getData() {
HttpMethods.getInstance().getJoke(new Observer<List<MyJoke>>() {
Disposable d;
@Override
public void onSubscribe(Disposable d) {
this.d = d;
}
@Override
public void onNext(List<MyJoke> myJokes) {
jokes = myJokes;
adpter = new MyAdpter(myJokes);
LinearLayoutManager layoutManager = new LinearLayoutManager(MainActivity.this);
recyclerView.setLayoutManager(layoutManager);
recyclerView.setAdapter(adpter);
adpter.notifyDataSetChanged();
Log.d("MAIN", "獲取數(shù)據(jù)完成" + myJokes.size());
}
@Override
public void onError(Throwable e) {
Log.d("MAIN", "error" + e.toString());
d.dispose();
}
@Override
public void onComplete() {
Log.d("MAIN", "onComplete");
d.dispose();
}
});
}
}
重點請看下面這個方法(請忽略那蹩腳的下拉刷新）
public void getData() {
HttpMethods.getInstance().getJoke(new Observer<List<MyJoke>>() {
Disposable d;
@Override
public void onSubscribe(Disposable d) {
this.d = d;
}
@Override
public void onNext(List<MyJoke> myJokes) {
jokes = myJokes;
adpter = new MyAdpter(myJokes);
LinearLayoutManager layoutManager = new LinearLayoutManager(MainActivity.this);
recyclerView.setLayoutManager(layoutManager);
recyclerView.setAdapter(adpter);
adpter.notifyDataSetChanged();
Log.d("MAIN", "獲取數(shù)據(jù)完成" + myJokes.size());
}
@Override
public void onError(Throwable e) {
Log.d("MAIN", "error" + e.toString());
d.dispose();
}
@Override
public void onComplete() {
Log.d("MAIN", "onComplete");
d.dispose();
}
});
}
該方法是運行在主線程中的,所以再也不需要Handler什么的了琼掠，非常方便。
最后再看一下布局文件和效果圖吧
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:id="@+id/activity_main"
android:layout_width="match_parent"
android:layout_height="match_parent"
tools:context="com.example.nanke.joke.MainActivity">
<com.cjj.MaterialRefreshLayout
xmlns:android="http://schemas.android.com/apk/res/android"
android:id="@+id/refresh"
android:layout_width="match_parent"
android:layout_height="match_parent"
>
<android.support.v7.widget.RecyclerView
android:id="@+id/recycler_View"
android:layout_width="match_parent"
android:layout_height="match_parent">
</android.support.v7.widget.RecyclerView>
</com.cjj.MaterialRefreshLayout>
</RelativeLayout>
效果圖
screenG.gif
源碼地址：https://github.com/HelloNanKe/Joke
咦停撞，還差一點,包含HTML標簽的文本處理
Spanned sp = Html.fromHtml( joke.getContent() );
holder.content.setText(sp);
