說在前面 本人能力有限，望高手勿噴。
golang
golang語言又叫g(shù)o語言始赎，是google公司為了適應(yīng)高并發(fā)，兼顧開發(fā)效率而開發(fā)的一門語言仔燕。go語言的語法非常簡單造垛，適合做服務(wù)器端開發(fā)。所以我準(zhǔn)備采用golang來做web后臺(tái)晰搀。因?yàn)楸竟?jié)重點(diǎn)不是講解go語言五辽。所以會(huì)比較簡單的介紹一下。
RxJava
RxJava也使用了很久外恕，一直想記錄一些使用過程杆逗，但是由于時(shí)間問題，一直沒有寫鳞疲。RxJava是一種鏈接風(fēng)格的編程體驗(yàn)罪郊，保證你使用后一定會(huì)非常喜歡。之前一直使用的是RxJava1 不過2016年11月份官方出了RxJava2尚洽，而且版本1也不會(huì)在更新維護(hù)了悔橄，所以我這里會(huì)使用版本2 。
Retrofit
Retrofit是一個(gè)網(wǎng)絡(luò)請(qǐng)求框架腺毫，是對(duì)okhttp框架的再次封裝癣疟。提供跟良好的使用體驗(yàn)。我這里采用的是retrofit2潮酒。
服務(wù)器端
服務(wù)器端我使用了go語言的一個(gè)框架 gin ,這個(gè)框架是兩個(gè)外國人寫的開源框架睛挚，用來寫api非常方便。
package main
import (
"blog/src/enity"
"fmt"
"github.com/gin-gonic/gin"
)
func main() {
gin.SetMode(gin.ReleaseMode)
router := gin.Default()
router.POST("/", func(c *gin.Context) {
start := c.PostForm("start")
count := c.PostForm("count")
fmt.Println("start: ", start, " count:", count)
c.JSON(200, gin.H{
"code": "201",
"msg": "success",
"data": gin.H{
"name": "aa",
"age": 25,
"address": "成都",
"sex": 1},
})
})
router.Run(":8000")
}
該服務(wù)器端的接口非常簡單急黎，就是獲取一個(gè)json數(shù)據(jù)扎狱。
APP端
引入依賴
//rxjava2 和rxAndroid
compile 'io.reactivex.rxjava2:rxjava:2.1.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
//retrofit2
compile 'com.squareup.retrofit2:retrofit:2.3.0'
// 自動(dòng)解析json數(shù)據(jù)為實(shí)體的包
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
//retrofit支持轉(zhuǎn)換為Rxjava的包
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
//okhttp
compile 'com.squareup.okhttp3:okhttp:3.3.0'
compile 'com.squareup.okio:okio:1.8.0'
compile 'com.google.code.gson:gson:2.8.1'
rxjava中有一個(gè) Observer類型這個(gè)就是一個(gè)觀察者侧到，也就是一個(gè)處理數(shù)據(jù)的類。還有一個(gè)是Observable類委乌，這個(gè)類是被觀察者類床牧，改類就是產(chǎn)生數(shù)據(jù)的類荣回。在apiservice接口類中遭贸，方法getUser()返回的就是一個(gè)被觀察者，改類型使用了泛型心软，也就是我們可以自動(dòng)解析json數(shù)據(jù)為我們的實(shí)體對(duì)象壕吹。
新建一個(gè) apiservice接口類
public interface ApiService {
@Multipart
@POST("/")
Observable<BaseResponseDto<User>> getUser(@Part("start") int start, @Part("count") int count);
}
我們使用了result api風(fēng)格的接口，一般我們接口返回json數(shù)據(jù)格式為删铃。
{
code: "200",
msg: "success",
data: {
}
}
所以我們可以對(duì)這個(gè)數(shù)據(jù)進(jìn)行封裝耳贬。
public class BaseResponseDto<T> {
private String code;
private String msg;
private T data;
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String mag) {
this.msg = mag;
}
public T getData() {
return data;
}
public void setData(T data) {
this.data = data;
}
@Override
public String toString() {
return "BaseResponseDto{" +
"code='" + code + '\'' +
", mag='" + msg + '\'' +
", data=" + data +
'}';
}
}
在app端請(qǐng)求網(wǎng)絡(luò)數(shù)據(jù)時(shí)我們總會(huì)處理各種異常問題，比如網(wǎng)絡(luò)異常猎唁，json解析異常等咒劲，為了少些異常處理代碼，我們需要對(duì)這一部分進(jìn)行封裝诫隅。我們使用的是RxJava所以我們需要對(duì)觀察者進(jìn)行封裝腐魂。
public abstract class DefaultObserver<T extends BaseResponseDto> implements Observer<T> {
private static String TAG="DefaultObserver";
private Context context;
private BaseViewImpl baseView;
private String message="";
private Disposable disposable;
public DefaultObserver(Context context){
this.context=context;
}
public DefaultObserver(Context context,BaseViewImpl baseView){
this.baseView=baseView;
this.context=context;
}
public DefaultObserver(Context context,BaseViewImpl baseView,String message){
this.baseView=baseView;
this.message=message;
this.context=context;
}
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.i(TAG,"======onSubscribe======");
disposable=d;
if(null!=baseView){
baseView.addDisposable(d);
baseView.showProgressDialog(message);
}
}
@Override
public void onNext(@NonNull T response) {
Log.i(TAG,"======onNext======");
mainThread();
if(null!=baseView){
baseView.removeDisposable(disposable);
baseView.dismissProgressDialog();
}else {
disposable.dispose();
}
if(response.getCode().equals("200")){
onSuccess(response);
}else{
onFail(response);
}
}
@Override
public void onError(@NonNull Throwable e) {
Log.i(TAG,"======onError======"+e.getMessage());
if(null !=baseView){
baseView.removeDisposable(disposable);
baseView.dismissProgressDialog();
}else {
disposable.dispose();
}
if (e instanceof HttpException) { // HTTP錯(cuò)誤
ToastUtil.showShort(context,"http錯(cuò)誤");
} else if (e instanceof ConnectException
|| e instanceof UnknownHostException) { // 連接錯(cuò)誤
ToastUtil.showShort(context,"連接錯(cuò)誤");
} else if (e instanceof InterruptedIOException) { // 連接超時(shí)
ToastUtil.showShort(context,"連接超時(shí)");
} else if (e instanceof JsonParseException
|| e instanceof JSONException
|| e instanceof ParseException) { // 解析錯(cuò)誤
ToastUtil.showShort(context,"解析錯(cuò)誤");
} else if(e instanceof IOException){
ToastUtil.showShort(context,"IO錯(cuò)誤");
}else {
ToastUtil.showShort(context,"未知錯(cuò)誤");
}
}
@Override
public void onComplete() {
}
/**
* 請(qǐng)求成功
* @param response
*/
abstract public void onSuccess(T response);
/**
* 請(qǐng)求成功后返回的數(shù)據(jù)錯(cuò)誤
* @param response
*/
public void onFail(T response){
ToastUtil.showShort(context,response.getMsg());
}
}
這樣封裝后我們只需要子類實(shí)現(xiàn) onSuccess()方法就可以了，我們只關(guān)注成功獲取數(shù)據(jù)逐纬。如果想自己根據(jù)失敗進(jìn)行相關(guān)的操作也可以復(fù)寫onFail()方法蛔屹。
最后我們需要把之前封裝的這幾個(gè)類弄到一個(gè)網(wǎng)絡(luò)請(qǐng)求類中，方便外面統(tǒng)一調(diào)用豁生。使用創(chuàng)建了一個(gè)Htpp類兔毒。
public class Http {
private static final String TAG="Http";
private static final String BASE_URL="http://127.0.0.1:8000/";
private static final int DEFAULT_TIMEOUT=5;
private static Retrofit retrofit;
private ApiService apiService;
private Http(){
Gson gson = new GsonBuilder()
.setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ")
.create();//使用 gson coverter，統(tǒng)一日期請(qǐng)求格式
OkHttpClient.Builder builder=new OkHttpClient.Builder()
.addInterceptor(new LoggingInterceptor())
.connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS);
retrofit=new Retrofit.Builder()
.baseUrl(BASE_URL)
.client(builder.build())
.addConverterFactory(GsonConverterFactory.create(gson))
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
apiService=retrofit.create(ApiService.class);
}
private static class SignleHolder{
private static final Http INSTANCE=new Http();
}
public static Http getInstance(){
return SignleHolder.INSTANCE;
}
private class LoggingInterceptor implements Interceptor{
@Override
public Response intercept(Chain chain) throws IOException {
Request request=chain.request();
Log.i(TAG,String.format("\n request: %s on %s \n %s %s",request.url(),chain.connection(),request.headers(),request.body().contentType()));
Response response=chain.proceed(request);
Log.i(TAG,String.format("\n response: %s \n body: %s \n",response.request().url(),""));
return response;
}
}
public void getUser(DefaultObserver<BaseResponseDto<User>> observer){
apiService.getUser(0,10)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer);
}
}
這樣封裝后 外部就可以直接使用htpp類進(jìn)行調(diào)用甸箱。
public void testDefaultRxJava(){
Http.getInstance().getUser(new DefaultObserver<BaseResponseDto<User>>(MainActivity.this,this) {
@Override
public void onSuccess(BaseResponseDto<User> response) {
Log.i(TAG,"=====onSuccess======"+response.toString());
}
@Override
public void onFail(BaseResponseDto<User> response) {
super.onFail(response);
}
});
}
這樣就輕松實(shí)現(xiàn)了RxJava2+Retrofit2 的封裝育叁。
