由于刚接触的一个项目中的网络请求，用到了一种我没见过的技术框架，十分令我烦恼，我试着去将关键字在万能搜索中找，发现了是叫做Rxjava，于是找了几篇大神的帖子看了一下， @大头鬼bruce 的 http://blog.csdn.net/lzyzsd/article/details/41833541有4个章节，看过后感觉很不错。下面我讲一下自己的学习程度，跟大家分享一下，自己的理解，有问题可以一起探讨。数据来自《聚合数据》。
我现在有那么一个需求：访问一个获取地区环境污染的接口，让后取得数据进行展示。我之前用的AsyncHttpClient 的框架，不过由于作者不更新了，跟市面上的其他网络框架比起来效果不是很好，现在我用rxjava来和retrofit2来进行。
1首先我先将接口页定义好，
定义一个接口
public interface Net_please {
@GET("cityList?key=xx")
rx.Observable<Message> request();
}
2写一个管理类
public class RetrofitManager {
//
private Retrofit retrofit=null;
private static RetrofitManager retrofitManager;
private RetrofitManager(){
retrofit = new Retrofit.Builder().baseUrl(
"http://pollution.api.juhe.cn/jhapi/pollution/").addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .build(); } //一个单例模式的写法 public static Net_please getInstance() { if (retrofitManager == null) { synchronized (RetrofitManager.class) { if (retrofitManager == null) { retrofitManager = new RetrofitManager(); } } } return retrofitManager.create(Net_please.class); } public <T> T create(final Class<T> service) { return retrofit.create(service); }}3前面是准备工作，我看了好多大神都差不多这么写，没什么好讨论的了，之后就是最重要的运用。我是先放一个button，之后再点击时间RetrofitManager.getInstance().request().observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io()) .flatMap(new Func1<Message, rx.Observable<Date_weather>>() { @Override public rx.Observable<Date_weather> call(Message message) { System.out.println(message.getError_code()+"--"+message.getReason()+"--"+message.getResult()); return rx.Observable.just(message.getResult().get(0)); } }) .subscribe(new Subscriber<Date_weather>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { System.out.println("错误" + e); } @Override public void onNext(Date_weather date_weather) { System.out.println("date_weather:" + date_weather); } });RetrofitManager.getInstance()--是得到那个单例request()是之前定义的一个接口方法observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io())分别表示谁应该在哪个线程里运行。flatMap（）这个是一个操作符，我的理解是将传过来的参数，在这里面做一些处理，之后再传给后面。这样可以使观察者和被观察者不用处理中间数据，可以安心的处理自己的逻辑subscribe（）这个是用来联系观察者和被观察者的中间方法（我这样理解，感觉容易懂。）里面新建一个new Subscriber<Date_weather>()只要将之前得到的那个参数传过来就可以直接用。里面是三个方法，onNext()使主要方法里面处理逻辑。github的demo地址： https://github.com/skl351/test_please.git代码写的很简单，以上只是我个人的一点理解，还有很多没弄懂的，下次弄懂了，再分享给大家。