1. 配置build.gradle

compile 'com.squareup.retrofit2:retrofit:2.1.0'    compile 'com.squareup.retrofit2:converter-gson:2.1.0'    compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'    compile 'io.reactivex:rxjava:1.1.3'    compile 'io.reactivex:rxandroid:1.1.0'

2. 后台服务代码（Python）

只为测试，写得比较简单.使用的是bottle轻量级服务框架

设置了一个记数器，每次请求，返回的数都将加1

import jsonfrom bottle import route, run @route('/app/v1/game/new')def new_game():    new_game.counter += 1    return json.dumps(["liuzhiliang" + str(new_game.counter)])if __name__ == '__main__':    # 定义记数器    new_game.counter = 0    # 运行服务    run(host='0.0.0.0', port=8421)

3. 设置接口

设置两种接口类型，一种是Call,使用retrofit2自带的处理，一种是rx.Observable，使用RxJAVA调用方式。需要注意的是，他们调的是同一个接口！

package com.example.jerome.chess;import java.util.List;import retrofit2.Call;import retrofit2.http.GET;import rx.Observable;/** * Created by jerome on 16/8/25. */public interface GameApi {    @GET("/app/v1/game/new")    Observable> newGame();    @GET("/app/v1/game/new")    Call> newGame1();}

4. 获取接口实现

数据统一使用Gson来转换。

public  static   T createService(String baseUrl, Class cls){        Retrofit retrofit = new Retrofit.Builder()                .baseUrl(baseUrl)                .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) //rxjava 时添加                .addConverterFactory(GsonConverterFactory.create())                .build();        return  retrofit.create(cls);    }

调用生成代码

GameApi service = createService(baseUrl, GameApi.class);

5. Call调用方式封装

public static  void RunCall(GameApi service){        service.newGame1().enqueue(                new Callback>(){                    @Override                    public void onResponse(Call> call, Response> response) {                        for(String a : response.body())                            System.out.println("Call: " +a);                    }                    @Override                    public void onFailure(Call> call, Throwable t) {                        System.out.println("1 error: " + t.getMessage());                    }                }        );    }

6. RxJAVA调用方式封装

public static  void RunRxJava(GameApi service){        service.newGame()        .subscribeOn(Schedulers.io())        .subscribe(new Subscriber>() {            @Override            public void onCompleted() {                System.out.println("onCompleted: ");            }            @Override            public void onError(Throwable e) {                System.out.println("onError:" + e.getMessage());            }            @Override            public void onNext(List strings) {                for (String a : strings)                    System.out.println("RXJAVA: " + a);            }        });    }

7. 测试函数

public static void main(String[] args){        String baseUrl = "http://127.0.0.1:8421/";        GameApi service = createService(baseUrl, GameApi.class);        for(int i = 0; i < 5; i++)            RunCall(service);        for(int i = 0; i < 5; i++)            RunRxJava(service);    }

8. 程序输出

Call: liuzhiliang5Call: liuzhiliang2Call: liuzhiliang1Call: liuzhiliang4RXJAVA: liuzhiliang6Call: liuzhiliang3onCompleted: RXJAVA: liuzhiliang7onCompleted: RXJAVA: liuzhiliang8onCompleted: RXJAVA: liuzhiliang9onCompleted: RXJAVA: liuzhiliang10onCompleted: Process finished with exit code 0

retrofit2+RxJava简单使用

1. 配置build.gradle

2. 后台服务代码（Python）

3. 设置接口

4. 获取接口实现

5. Call调用方式封装

6. RxJAVA调用方式封装

7. 测试函数

8. 程序输出

更多相关文章

随机推荐