RxJava和Retrofit2.0的结合使用

深藏阁楼爱情的钟 2023-10-16 22:46 27阅读 0赞

## RxJava和Retrofit2.0的结合使用 ##

如果还不了解Retrofit2.0，可以先看 [Retrofit2.0的使用][Retrofit2.0]  
如果对RxJava还不了解，可以先看 [RxJava初体验][RxJava] 和 [RxJava之多线程、链式调用、Lambda表达式][RxJava_Lambda]

### 添加依赖 ###

compile 'com.squareup.retrofit:retrofit:2.0.0-beta2'
    compile 'com.squareup.retrofit:converter-gson:2.0.0-beta2'
    compile 'com.squareup.retrofit:adapter-rxjava:2.0.0-beta2'
    compile 'io.reactivex:rxjava:1.1.0'
    compile 'io.reactivex:rxandroid:1.1.0'

#### 添加权限 ####

<uses-permission android:name="android.permission.INTERNET" />

### 使用的API接口平台 ###

[全国天气查询][Link 1]

#### 返回的数据实例 ####

{"error_code":0,"reason":"成功","result":{"sk":{"temp":"8","wind_direction":"西北风","wind_strength":"2级","humidity":"94","time":"20:38"},"today":{"city":"杭州","date_y":"2015年12月20日","week":"星期日","temperature":"6~12","weather":"小雨","fa":"07","fb":"02","wind":"东风 微风","dressing_index":"较冷","dressing_advice":"建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。","uv_index":"最弱","comfort_index":"--","wash_index":"不宜","travel_index":"较不宜","exercise_index":"较不宜","drying_index":"--"},"future":[{"temperature":"8~12","weather":"多云","fa":"01","fb":"02","wind":"无持续风向 微风","week":"星期一","date":"20151221"},{"temperature":"9~12","weather":"中雨","fa":"08","fb":"08","wind":"东风 微风","week":"星期二","date":"20151222"},{"temperature":"9~11","weather":"小雨","fa":"07","fb":"07","wind":"东北风 微风","week":"星期三","date":"20151223"},{"temperature":"5~11","weather":"小雨","fa":"07","fb":"07","wind":"北风 微风","week":"星期四","date":"20151224"},{"temperature":"2~9","weather":"阴","fa":"02","fb":"01","wind":"西北风 微风","week":"星期五","date":"20151225"},{"temperature":"1~9","weather":"晴","fa":"00","fb":"01","wind":"东北风 微风","week":"星期六","date":"20151226"}]}}

### 新建Weather类 ###

对应于之前的Json数据

public class Weather {
    
    /**
     * error_code : 0
     * reason : 成功
     * result : {"sk":{"temp":"8","wind_direction":"西北风","wind_strength":"2级","humidity":"94","time":"20:38"},"today":{"city":"杭州","date_y":"2015年12月20日","week":"星期日","temperature":"6~12","weather":"小雨","fa":"07","fb":"02","wind":"东风 微风","dressing_index":"较冷","dressing_advice":"建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。","uv_index":"最弱","comfort_index":"--","wash_index":"不宜","travel_index":"较不宜","exercise_index":"较不宜","drying_index":"--"},"future":[{"temperature":"8~12","weather":"多云","fa":"01","fb":"02","wind":"无持续风向 微风","week":"星期一","date":"20151221"},{"temperature":"9~12","weather":"中雨","fa":"08","fb":"08","wind":"东风 微风","week":"星期二","date":"20151222"},{"temperature":"9~11","weather":"小雨","fa":"07","fb":"07","wind":"东北风 微风","week":"星期三","date":"20151223"},{"temperature":"5~11","weather":"小雨","fa":"07","fb":"07","wind":"北风 微风","week":"星期四","date":"20151224"},{"temperature":"2~9","weather":"阴","fa":"02","fb":"01","wind":"西北风 微风","week":"星期五","date":"20151225"},{"temperature":"1~9","weather":"晴","fa":"00","fb":"01","wind":"东北风 微风","week":"星期六","date":"20151226"}]}
     */
    
    private int error_code;
    private String reason;
    /**
     * sk : {"temp":"8","wind_direction":"西北风","wind_strength":"2级","humidity":"94","time":"20:38"}
     * today : {"city":"杭州","date_y":"2015年12月20日","week":"星期日","temperature":"6~12","weather":"小雨","fa":"07","fb":"02","wind":"东风 微风","dressing_index":"较冷","dressing_advice":"建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。","uv_index":"最弱","comfort_index":"--","wash_index":"不宜","travel_index":"较不宜","exercise_index":"较不宜","drying_index":"--"}
     * future : [{"temperature":"8~12","weather":"多云","fa":"01","fb":"02","wind":"无持续风向 微风","week":"星期一","date":"20151221"},{"temperature":"9~12","weather":"中雨","fa":"08","fb":"08","wind":"东风 微风","week":"星期二","date":"20151222"},{"temperature":"9~11","weather":"小雨","fa":"07","fb":"07","wind":"东北风 微风","week":"星期三","date":"20151223"},{"temperature":"5~11","weather":"小雨","fa":"07","fb":"07","wind":"北风 微风","week":"星期四","date":"20151224"},{"temperature":"2~9","weather":"阴","fa":"02","fb":"01","wind":"西北风 微风","week":"星期五","date":"20151225"},{"temperature":"1~9","weather":"晴","fa":"00","fb":"01","wind":"东北风 微风","week":"星期六","date":"20151226"}]
     */
    
    private ResultEntity result;
    
    public void setError_code(int error_code) {
        this.error_code = error_code;
    }
    
    public void setReason(String reason) {
        this.reason = reason;
    }
    
    public void setResult(ResultEntity result) {
        this.result = result;
    }
    
    public int getError_code() {
        return error_code;
    }
    
    public String getReason() {
        return reason;
    }
    
    public ResultEntity getResult() {
        return result;
    }
    
    public static class ResultEntity {
        /**
         * temp : 8
         * wind_direction : 西北风
         * wind_strength : 2级
         * humidity : 94
         * time : 20:38
         */
    
        private SkEntity sk;
        /**
         * city : 杭州
         * date_y : 2015年12月20日
         * week : 星期日
         * temperature : 6~12
         * weather : 小雨
         * fa : 07
         * fb : 02
         * wind : 东风 微风
         * dressing_index : 较冷
         * dressing_advice : 建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。
         * uv_index : 最弱
         * comfort_index : --
         * wash_index : 不宜
         * travel_index : 较不宜
         * exercise_index : 较不宜
         * drying_index : --
         */
    
        private TodayEntity today;
        /**
         * temperature : 8~12
         * weather : 多云
         * fa : 01
         * fb : 02
         * wind : 无持续风向 微风
         * week : 星期一
         * date : 20151221
         */
    
        private List<FutureEntity> future;
    
        public void setSk(SkEntity sk) {
            this.sk = sk;
        }
    
        public void setToday(TodayEntity today) {
            this.today = today;
        }
    
        public void setFuture(List<FutureEntity> future) {
            this.future = future;
        }
    
        public SkEntity getSk() {
            return sk;
        }
    
        public TodayEntity getToday() {
            return today;
        }
    
        public List<FutureEntity> getFuture() {
            return future;
        }
    
        public static class SkEntity {
            private String temp;
            private String wind_direction;
            private String wind_strength;
            private String humidity;
            private String time;
    
            public void setTemp(String temp) {
                this.temp = temp;
            }
    
            public void setWind_direction(String wind_direction) {
                this.wind_direction = wind_direction;
            }
    
            public void setWind_strength(String wind_strength) {
                this.wind_strength = wind_strength;
            }
    
            public void setHumidity(String humidity) {
                this.humidity = humidity;
            }
    
            public void setTime(String time) {
                this.time = time;
            }
    
            public String getTemp() {
                return temp;
            }
    
            public String getWind_direction() {
                return wind_direction;
            }
    
            public String getWind_strength() {
                return wind_strength;
            }
    
            public String getHumidity() {
                return humidity;
            }
    
            public String getTime() {
                return time;
            }
        }
    
        public static class TodayEntity {
            private String city;
            private String date_y;
            private String week;
            private String temperature;
            private String weather;
            private String fa;
            private String fb;
            private String wind;
            private String dressing_index;
            private String dressing_advice;
            private String uv_index;
            private String comfort_index;
            private String wash_index;
            private String travel_index;
            private String exercise_index;
            private String drying_index;
    
            public void setCity(String city) {
                this.city = city;
            }
    
            public void setDate_y(String date_y) {
                this.date_y = date_y;
            }
    
            public void setWeek(String week) {
                this.week = week;
            }
    
            public void setTemperature(String temperature) {
                this.temperature = temperature;
            }
    
            public void setWeather(String weather) {
                this.weather = weather;
            }
    
            public void setFa(String fa) {
                this.fa = fa;
            }
    
            public void setFb(String fb) {
                this.fb = fb;
            }
    
            public void setWind(String wind) {
                this.wind = wind;
            }
    
            public void setDressing_index(String dressing_index) {
                this.dressing_index = dressing_index;
            }
    
            public void setDressing_advice(String dressing_advice) {
                this.dressing_advice = dressing_advice;
            }
    
            public void setUv_index(String uv_index) {
                this.uv_index = uv_index;
            }
    
            public void setComfort_index(String comfort_index) {
                this.comfort_index = comfort_index;
            }
    
            public void setWash_index(String wash_index) {
                this.wash_index = wash_index;
            }
    
            public void setTravel_index(String travel_index) {
                this.travel_index = travel_index;
            }
    
            public void setExercise_index(String exercise_index) {
                this.exercise_index = exercise_index;
            }
    
            public void setDrying_index(String drying_index) {
                this.drying_index = drying_index;
            }
    
            public String getCity() {
                return city;
            }
    
            public String getDate_y() {
                return date_y;
            }
    
            public String getWeek() {
                return week;
            }
    
            public String getTemperature() {
                return temperature;
            }
    
            public String getWeather() {
                return weather;
            }
    
            public String getFa() {
                return fa;
            }
    
            public String getFb() {
                return fb;
            }
    
            public String getWind() {
                return wind;
            }
    
            public String getDressing_index() {
                return dressing_index;
            }
    
            public String getDressing_advice() {
                return dressing_advice;
            }
    
            public String getUv_index() {
                return uv_index;
            }
    
            public String getComfort_index() {
                return comfort_index;
            }
    
            public String getWash_index() {
                return wash_index;
            }
    
            public String getTravel_index() {
                return travel_index;
            }
    
            public String getExercise_index() {
                return exercise_index;
            }
    
            public String getDrying_index() {
                return drying_index;
            }
        }
    
        public static class FutureEntity {
            private String temperature;
            private String weather;
            private String fa;
            private String fb;
            private String wind;
            private String week;
            private String date;
    
            public void setTemperature(String temperature) {
                this.temperature = temperature;
            }
    
            public void setWeather(String weather) {
                this.weather = weather;
            }
    
            public void setFa(String fa) {
                this.fa = fa;
            }
    
            public void setFb(String fb) {
                this.fb = fb;
            }
    
            public void setWind(String wind) {
                this.wind = wind;
            }
    
            public void setWeek(String week) {
                this.week = week;
            }
    
            public void setDate(String date) {
                this.date = date;
            }
    
            public String getTemperature() {
                return temperature;
            }
    
            public String getWeather() {
                return weather;
            }
    
            public String getFa() {
                return fa;
            }
    
            public String getFb() {
                return fb;
            }
    
            public String getWind() {
                return wind;
            }
    
            public String getWeek() {
                return week;
            }
    
            public String getDate() {
                return date;
            }
        }
    }

### 新建接口 ###

public interface APIService {
        /**
         * retrofit 支持 rxjava 整合
         * 这种方法适用于新接口
         */
        @GET("weather")
        Observable<Weather> getWeatherData(@Query("cityname") String cityname, @Query("key") String apiKey);
    }

### 使用 ###

Retrofit retrofit = new Retrofit.Builder().baseUrl(http://apis.haoservice.com/)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .build();
    
        APIService service = retrofit.create(APIService.class);
        Observable<Weather> observable = service.getWeatherData("杭州", apiKey);
        observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Weather>() {
                    @Override
                    public void onCompleted() {
                        Log.i("zhk-MainActivity", "onCompleted: ");
                        Toast.makeText(getApplicationContext(),
                                "Completed",
                                Toast.LENGTH_SHORT)
                                .show();
                    }
    
                    @Override
                    public void onError(Throwable e) {
                        Log.e("zhk-MainActivity", "onError: ", e);
                        Toast.makeText(getApplicationContext(),
                                "Error:" + e.getMessage(),
                                Toast.LENGTH_SHORT)
                                .show();
                    }
    
                    @Override
                    public void onNext(Weather weather) {
                        Weather.ResultEntity.TodayEntity todayEntiry = weather.getResult().getToday();
                        Log.i("zhk-MainActivity", "onNext: 城市:" + todayEntiry.getCity() + " 温度:" + todayEntiry.getTemperature());
                        Toast.makeText(MainActivity.this, "城市:" + todayEntiry.getCity() + " 温度:" + todayEntiry.getTemperature(), Toast.LENGTH_SHORT).show();
                    }
                });

### 输出结果 ###

zhk-MainActivity: onNext: 城市:杭州 温度:6~12
    zhk-MainActivity: onCompleted:

> [相关源码][Link 2]
> 
> 参考文章  
> [http://www.2cto.com/kf/201512/452153.html][http_www.2cto.com_kf_201512_452153.html]  
> [http://www.tuicool.com/articles/26jUZjv][http_www.tuicool.com_articles_26jUZjv]  
> [http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2015/0915/3460.html][http_www.jcodecraeer.com_a_anzhuokaifa_androidkaifa_2015_0915_3460.html]

[Retrofit2.0]: http://blog.csdn.net/ethanco/article/details/50366719
[RxJava]: http://blog.csdn.net/ethanco/article/details/49718775
[RxJava_Lambda]: http://blog.csdn.net/EthanCo/article/details/49766283
[Link 1]: http://www.haoservice.com/docs/6
[Link 2]: http://download.csdn.net/detail/ethanco/9369634
[http_www.2cto.com_kf_201512_452153.html]: http://www.2cto.com/kf/201512/452153.html
[http_www.tuicool.com_articles_26jUZjv]: http://www.tuicool.com/articles/26jUZjv
[http_www.jcodecraeer.com_a_anzhuokaifa_androidkaifa_2015_0915_3460.html]: http://www.jcodecraeer.com/a/anzhuokaifa/androidkaifa/2015/0915/3460.html