使用RxJava+Retrofit+MVP+Glide开发一个简单的新闻客户端

好久没有更新博客了，有点懒。。之前在网上看到很多有趣又高效的开源库，于是就想着写一个简单的项目来运用这些开源库，恰巧看见聚合数据上有个新闻头条的API，所以就尝试写了一下。先上效果图：

在这个小项目中，使用RxJava和Retrofit网络请求框架来实现异步数据的获取是比较重要的环节。 关于RxJava和Retrofit的使用可以参考：http://gank.io/post/56e80c2c677659311bed9841

首先，需要封装好网络请求逻辑：

public class Api { private Retrofit retrofit; private static ApiService apiService; private Api() { OkHttpClient client = new OkHttpClient.Builder() .connectTimeout(10, TimeUnit.SECONDS) .build(); retrofit = new Retrofit.Builder() .baseUrl(AppConfig.baseUrl) .addConverterFactory(GsonConverterFactory.create()) //添加Rx适配 .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .client(client) .build(); apiService = retrofit.create(ApiService.class); } public static ApiService getDefault() { if (apiService == null) { synchronized (Api.class) { if (apiService == null) { new Api(); } } } return Api.apiService; } } public interface ApiService { //获取新闻请求，返回Observable对象 @GET("index") Observable<News> getNews(@Query("type") String type, @Query("key") String apiKey); }

网络请求封装好了，由于整体采用了MVP架构，所以在Model层需要异步请求数据：

public class NewsModel implements NewsContract.Model { @Override public Observable<List<Data>> getChannelList(String type) { return Api.getDefault() .getNews(type, AppConfig.apiKey) .map(news -> news.getResult().getData()) .compose(RxSchedulers.io_main()); //对Observable进行转换，用于切换执行异步任务的线程 } }

整个项目设计中也同时实现了简单的事件总线RxBus，用于发送用户定义的Event：

public class RxBus { private static RxBus rxBus; private RxBus() { } public static RxBus getInstance() { if (rxBus == null) { synchronized (RxBus.class) { if (rxBus == null) { rxBus = new RxBus(); } } } return rxBus; } public final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create()); public final Vector<Subscription> subscriptions = new Vector<>(); //发送事件 public void send(Object o) { _bus.onNext(o); } //取出事件 public Observable<Object> toObserverable() { return _bus; } //添加订阅 public void addSubscription(Subscription s) { subscriptions.add(s); } //取消所有的订阅 public void unSubscribeAll() { for (Subscription s : subscriptions) { if (!s.isUnsubscribed()) { s.unsubscribe(); } } } }

更多细节也可以参考：http://git.oschina.net/QiHuangQi/News