分享 Retrofit+RxJava+MPAndroidChart 未来一周天气气温预测案例

本文主要是介绍分享 Retrofit+RxJava+MPAndroidChart 未来一周天气气温预测案例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前言

上周我写了一篇MPAndroidChart的使用技巧 ,得到了不少人的响应。至少自己写的文章还是有人去看，很是激励。毕竟我在学习Android开发的时候也是一直看着同行前辈们在技术社区上的干货输出，慢慢地进步起来。当在一些技术点上有了自己的一般见解，也应当回馈社区。

感概完了，现在还是言归正传吧。当掌握了一个技术点之后，怎样在项目中运用到这个技术点，还需要自己好好琢磨琢磨一下的。上次在MPAndroidChart的使用技巧案例中，数据都是自己写死的。现在就来看看MPAndroidChart怎样结合后台的传过来的数据展示图表吧。

在这次的案例中，我使用的是近段时间以来很潮很火的Retrofit+RxJava（这两种开发技术堪称一对CP啊！）来对后台进行网络请求。如果对Retrofit使用还不是很熟悉的话，可以看看之前我的写过一篇 Retrofit网络请求框架基础操作。而对于RxJava，我并未进行深入的研究，但可以看看一些大神写的博客，例如这位大头鬼Bruce。（PS：在案例中我对Retrofit请求时做了一些封装，在点击button前，未显示图表，点击button之后，才显示图表）

Talk is cheap,show you the code

导入MPAndroidChart的jar包（这一步可以参考MPAndroidChart的使用技巧）
添加依赖

    compile fileTree(dir: 'libs', include: ['*.jar'])testCompile 'junit:junit:4.12'compile 'com.android.support:appcompat-v7:23.3.0'compile 'com.squareup.okhttp3:okhttp:3.2.0'compile 'com.squareup.retrofit2:retrofit:2.0.1'compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'compile 'com.squareup.retrofit2:adapter-rxjava:2.0.1'compile 'io.reactivex:rxandroid:1.1.0'compile 'io.reactivex:rxjava:1.1.0'compile 'com.orhanobut:logger:1.11'compile project(':JNChartLib')

创建请求接口(使用的接口地址：http://apis.baidu.com/heweather/weather/free )

public interface NetRequest {@GET("/heweather/weather/free?/")Observable<WeatherInfo> getWeatherByRxJava(@Header("apiKey")String apiKey, @Query("city")String city);}

创建网络接口服务的封装类(通过单例模式来获取网络请求接口的对象)

public class RetrofitWrapper {private static RetrofitWrapper instance;private Context mContext;private Retrofit retrofit;private RetrofitWrapper() {Gson gson = new Gson();//创建Retrofit对象retrofit = new Retrofit.Builder().baseUrl(Constant.BASE_URL)//配置转化库，默认是GSON.addConverterFactory(GsonConverterFactory.create(gson))//配置回调库，采用RxJava.addCallAdapterFactory(RxJavaCallAdapterFactory.create()).build();}public static RetrofitWrapper getInstance() {if (instance == null) {synchronized (RetrofitWrapper.class){if (instance==null){instance = new RetrofitWrapper();}}}return instance;}/*** 创建请求接口的对象* @param service* @param <T>* @return*/public <T> T create(final Class<T> service) {return retrofit.create(service);}}

public class WeatherInfoModel {private static  WeatherInfoModel weatherInfoModel;private NetRequest netRequest;public WeatherInfoModel(Context context) {netRequest = (NetRequest) RetrofitWrapper.getInstance().create(NetRequest.class);}public static WeatherInfoModel getInstance(Context context) {if (weatherInfoModel == null) {weatherInfoModel = new WeatherInfoModel(context);}return weatherInfoModel;}/*** 查询天气** @param weatherInfoReq* @return*/public Observable<WeatherInfo> queryWeatherByRxJava(WeatherInfoReq weatherInfoReq) {Observable<WeatherInfo> infoCall = netRequest.getWeatherByRxJava(weatherInfoReq.apiKey, weatherInfoReq.city);return infoCall;}
}

public class MainActivity extends Activity {private Button request;private LineChart chart;private WeatherInfoModel weatherInfoModel;private int i = 0;private ProgressDialog pd;private ArrayList<String> xValues = new ArrayList<>();private ArrayList<Entry> yValues2Max = new ArrayList<Entry>();private ArrayList<Entry> yValues2Min = new ArrayList<Entry>();@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);weatherInfoModel = WeatherInfoModel.getInstance(getApplicationContext());initViews();initParams();initEvent();}/**初始化请求参数*/private WeatherInfoReq initParams() {WeatherInfoReq weatherInfoReq = new WeatherInfoReq();weatherInfoReq.apiKey = Constant.API_KEY;weatherInfoReq.city = Constant.CITY;return weatherInfoReq;}/**初始化控件*/private void initViews() {request = (Button) this.findViewById(R.id.request);chart = (LineChart) this.findViewById(R.id.weatherChart);}private void initEvent() {final Gson gson = new Gson();request.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {//创建访问的API请求weatherInfoModel.queryWeatherByRxJava(initParams()).subscribeOn(Schedulers.io())// 指定观察者在io线程（第一次指定观察者线程有效）.doOnSubscribe(new Action0() {//在启动订阅前（发送事件前）执行的方法@Overridepublic void call() {pd = new ProgressDialog(MainActivity.this);pd.setMessage("请稍后...");pd.show();}}).flatMap(new Func1<WeatherInfo, Observable<WeatherResult>>() {@Overridepublic Observable<WeatherResult> call(WeatherInfo weatherInfo) {return Observable.from(weatherInfo.getHeWeatherDataList());}}).flatMap(new Func1<WeatherResult, Observable<DailyForecast>>() {@Overridepublic Observable<DailyForecast> call(WeatherResult weatherResult) {return Observable.from(weatherResult.getDaily_forecast());}}).observeOn(AndroidSchedulers.mainThread())//指定订阅者在主线程.subscribe(new Subscriber<DailyForecast>() {@Overridepublic void onCompleted() {pd.dismiss();chart.setDescription("广州气温预测");LineChartManager.setLineName("最高温度");LineChartManager.setLineName1("最低温度");LineChartManager.initDoubleLineChart(MainActivity.this, chart, xValues, yValues2Max, yValues2Min);}@Overridepublic void onError(Throwable e) {pd.dismiss();}@Overridepublic void onNext(DailyForecast dailyForecast) {int j = i++;xValues.add(dailyForecast.getDate());yValues2Max.add(new Entry(Float.valueOf(dailyForecast.getTmp().getMaxTem()), j));yValues2Min.add(new Entry(Float.valueOf(dailyForecast.getTmp().getMinTem()), j));}});}});}}

总结

这次的案例代码还是比较简单的，相信大家看起来应该容易明白。如果要说难点，应该就是RxJava的使用上，因为RxJava是响应式编程，这与我们之前编程的思想有点不同，但它的好处就是代码简洁，优雅，随意地变换线程，而且重要的是它的操作符真的非常牛逼，如果你深入去研究的话，都会对着电脑竖起你的大拇指。而这次的图表中，如果大家看了效果图之后，会发现这次y轴上和图表中的数据都带有单位符号，这是我重写了ValueFormatter和YAxisValueFormatter这两个类，具体的写法大家可以看看源码。本文没有贴出一些bean类和常量类，如需请看源码！最后，小弟不才，还望多多指教！