RxJava开发精要8 – 与REST无缝结合-RxJava和Retrofit

• 原文出自《RxJava Essentials》
• 原文做者 : Ivan Morgillo
• 译文出自 : 开发技术前线 www.devtf.cn
• 转载声明: 本译文已受权开发者头条享有独家转载权，未经容许，不得转载!
• 译者 : yuxingxin
• 项目地址 : RxJava-Essentials-CN

在上一章中，咱们学习了如何使用调度器在不一样于UI线程的线程上操做。咱们学习了如何高效的运行I/O任务而不用阻塞UI以及如何运行耗时的计算任务而不耗损应用性能。在最后一章中，咱们将建立一个最终版的真实世界的例子，用Retrofit映射到远程的API,异步的查询数据，从而不费力的创造一个丰富的UI。

项目目标

咱们将在已存在的例子中建立一个新的Activity。这个Activity将会使用StackExchange API从stackoverflow检索最活跃的10位用户。使用这个信息，App将会展现一个用户的头像，姓名，名望数以及住址列表。对于每一位用户，app将会使用其居住城市和OpenWeatherMap API 来检索当地的天气预报，并展现一个小的天气图标。基于从StackOverflow检索的信息，app对列表的每一位用户将会提供一个onClick事件，它将会打开他们在我的信息中指定的我的网站或者打开Stack Overflow的我的主页。

Retrofit

Retrofit是Square公司专为Android和Java设计的一个类型安全的REST客户端。它帮助你很容易的和任何REST API交互，它完美的集成R小Java：全部的JSON响应对象都被映射成原始的Java对象，而且全部的网络调用都基于Rxjava Observable这些对象。

使用API文档，咱们能够定义咱们从服务器接收的JSON响应数据。为了很容易的将JSON响应数据映射为咱们的Java代码，咱们将使用jsonschema2pojo(http://www.jsonschema2pojo.org)，这个灵活的服务将会生成咱们所须要映射JSON响应数据的全部Java类。

当咱们把全部的Java model准备好后，咱们就能够开始创建Retrofit。Retrofi使用标准的Java接口来映射API路由。例如例子中，咱们将使用来自API的一个路由，下面是咱们Retrofit的接口：

 

 

1 2 3 4 5

public interface StackExchangeService {     @GET("2.2users?order=desc&sort=reputation&site=stackoverflow")     Observable<User sResponse> getMostPopularSOusers(@Query("pagesize") int howmany); }

 

interface接口只包含一个方法，即getMostPopularSOusers。这个方法用整型howmany做为一个参数并返回UserResponse的Observable。

当咱们有了interface，咱们能够建立RestAdapter类，为了更清楚的组织咱们的代码，咱们建立一个SeApiManager函数提供一种更适当的方式来和StackExchange API交互。

 

 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19

public class SeApiManager {     private final StackExchangeService mStackExchangeService;       public SeApiManager() {         RestAdapter restAdapter = new RestAdapter.Builder()             .setEndpoint("https://api.stackexchange.com")             .setLogLevel(RestAdapter.LogLevel.BASIC)             .build();         mStackExchangeService = restAdapter.create(StackExchangeService.class); }   public Observable<List<User>> getMostPopularSOusers(int howmany) {     return mStackExchangeService     .getMostPopularSOusers(howmany)     .map(UsersResponse::getUsers)     .subscribeOn(Schedulers.io())     .observeOn(AndroidSchedulers.mainThread()); }

 

为了简化例子，咱们再也不将这个类设计为它本应该设计为的单例。使用依赖注入解决方案，如Dagger2将会使代码质量更高。

建立RestAdapter类，咱们为API客户端创建了几个重要的点。这个例子中，咱们设置endpoint和log level。因为这个例子URL只是硬编码，使用外部资源来像这样存储数据很重要。避免在代码中硬编码字符串是一个好的实践。

Retrofit把RestAdapter类和咱们的API接口绑定在一块儿后就建立结束。它返回给咱们一个对象用来查询API。咱们能够选择直接暴露这个对象，或者以某种方式封装依次来限制访问它。在这个例子中，咱们封装它并只暴露getMostPopularSOusers方法。这个方法执行查询，让Retrofit解析JSON响应数据。得到用户列表，并返回给订阅者。正如你看到的，使用Retrofit、RxJava和Retrolambda，咱们几乎没有模板代码：它很是紧凑而且可读性也高。

如今，咱们已经有一个API管理者来暴露一个响应式的方法，它从远程API获取到数据并给I/O调度器，解析映射最后提供给咱们的消费者一个简洁的用户列表。

App架构

咱们不使用任何MVC，MVP，或者MVVM模式。由于那不是这本书的目的，所以咱们的Activity类将包含咱们须要建立和展现用户列表的全部逻辑。

建立Activity类

咱们将在onCreate()方法里建立SwipeRefreshLayout和RecyclerView；咱们有一个refreshList()方法来处理用户列表的获取和展现，showRefreshing()方法来管理进度条和RecyclerView的显示。

咱们的refreshList()函数看起来以下：

 

 

1 2 3 4 5 6 7 8 9 10 11 12

private void refreshList() {     showRefresh(true);     mSeApiManager.getMostPopularSOusers(10)         .subscribe(users -> {             showRefresh(false);             mAdapter.updateUsers(users);         }, error -> {             App.L.error(error.toString());             showRefresh(false);         }); }

 

咱们显示了进度条，从StackExchange API 管理器观测用户列表。一旦获取到列表数据，咱们开始展现它并更新Adapter的内容并让RecyclerView显示为可见。

建立RecyclerView Adapter

咱们从REST API获取到数据后，咱们须要把它绑定View上，并用一个适配器填充列表。咱们的RecyclerView适配器是标准的。它继承于RecyclerView.Adapter并指定它本身的ViewHolder：

 

 

1 2 3 4 5 6 7 8 9 10 11

public static class ViewHolder extends RecyclerView.ViewHolder {     @InjectView(R.id.name) TextView name;     @InjectView(R.id.city) TextView city;     @InjectView(R.id.reputation) TextView reputation;     @InjectView(R.id.user_image) ImageView user_image;     public ViewHolder(View view) {         super(view);         ButterKnife.inject(this, view);     } }

 

咱们一旦收到来自API管理器的数据，咱们能够设置界面上全部的标签：name,city和reputation。

为了展现用户的头像，咱们将使用Sergey Tarasevich (https://github.com/nostra13/Android-Universal- ImageLoader)写的Universal Image Loader。UIL是很是有名的而且被测试出很好用的图片管理库。咱们也可使用Square公司的Picasso，Glide或者Facebook公司的Fresco。这只是根据你本身的爱好。重要的是无须重复造轮子：库可以方便开发者的生活并让他们更快速实现目标。

在咱们的适配器中，咱们能够这样：

 

 

1 2 3 4 5 6

@Override public void onBindViewHolder(SoAdapter.ViewHolder holder, int position) {     User user = mUsers.get(position);     holder.setUser(user); }

 

在ViewHolder，咱们能够这样：

 

 

1 2 3 4 5 6 7 8

public void setUser(User user) {     name.setText(user.getDisplayName());     city.setText(user.getLocation());     reputation.setText(String.valueOf(user.getReputation()));       ImageLoader.getInstance().displayImage(user.getProfileImage(), user_image); }

 

此时，咱们能够容许代码得到一个用户列表，正以下图所示：

检索天气预报

咱们加大难度，将当地城市的天气加入列表中。OpenWeatherMap是一个灵活的web service公共API，咱们能够查询检索许多有用的预报信息。

和往常同样，咱们将使用Retrofit映射到API而后经过RxJava来访问它。至于StackExchange API，咱们将建立interface，RestAdapter和一个灵活的管理器：

 

 

1 2 3 4 5

public interface OpenWeatherMapService {     @GET("data2.5/weather")     Observable<WeatherResponse> getForecastByCity(@Query("q") String city); }

 

这个方法用城市名字做为参数提供当地的预报信息。咱们像下面这样将接口和RestAdapter类绑定在一块儿：

 

 

1 2 3 4 5 6

RestAdapter restAdapter = new RestAdapter.Builder()         .setEndpoint("http://api.openweathermap.org")         .setLogLevel(RestAdapter.LogLevel.BASIC)         .build(); mOpenWeatherMapService = restAdapter.create(OpenWeatherMapService.class);

 

像之前同样，咱们只需设置API端口和log级别：咱们只须要立马作的两件事情。

OpenWeatherMapApiManager类将提供下面的方法：

 

 

1 2 3 4 5 6

public Observable<WeatherResponse> getForecastByCity(String city) {     return mOpenWeatherMapService.getForecastByCity(city)     .subscribeOn(Schedulers.io())     .observeOn(AndroidSchedulers.mainThread()); }

 

如今，咱们有了用户列表，咱们能够根据城市名来查询OpenWeatherMap来接收天气预报信息。下一步是修改咱们的ViewHolder类来为每位用户检索和使用天气预报信息从而根据状态来展现天气图标。

咱们使用这些工具方法先验证用户主页信息并得到一个合法的城市名字：

 

 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

private boolean isCityValid(String location) {     int separatorPosition = getSeparatorPosition(location);     return !"".equals(location) && separatorPosition > -1; }   private int getSeparatorPosition(String location) {     int separatorPosition = -1;     if (location != null) {         separatorPosition = location.indexOf(",");     }     return separatorPosition; }   private String getCity(String location, int position) {     if (location != null) {         return location.substring(0, position);     } else {         return "";     } }

 

借助一个有效的城市名，咱们能够用下面命令来得到咱们所须要天气的全部数据：

 

 

1 2	OpenWeatherMapApiManager.getInstance().getForecastByCity(city)

 

用天气响应的结果，咱们能够得到天气图标的URL：

 

 

1 2	getWeatherIconUrl(weatherResponse);

 

用图标URL，咱们能够检索到图标自己：

 

 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26

private Observable<Bitmap> loadBitmap(String url) {     return Observable.create(subscriber -> {         ImageLoader.getInstance().displayImage(url,city_image, new ImageLoadingListener() {             @Override             public void onLoadingStarted(String imageUri, View view) {             }               @Override             public void onLoadingFailed(String imageUri, View view, FailReason failReason) {                 subscriber.onError(failReason.getCause());             }               @Override             public void onLoadingComplete(String imageUri, View view, Bitmap loadedImage) {                 subscriber.onNext(loadedImage);                 subscriber.onCompleted();             }               @Override             public void onLoadingCancelled(String imageUri, View view) {                 subscriber.onError(new Throwable("Image loading cancelled"));             }          });     }); }

 

这个loadBitmap()返回的Observable能够连接前面一个，而且最后咱们能够为这个任务返回一个单独的Observable：

 

 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29

if (isCityValid(location)) {     String city = getCity(location, separatorPosition);     OpenWeatherMapApiManager.getInstance().getForecastByCity(city)         .filter(response -> response != null)         .filter(response -> response.getWeather().size() > 0)         .flatMap(response -> {             String url = getWeatherIconUrl(response);             return loadBitmap(url);         })     .subscribeOn(Schedulers.io())     .observeOn(AndroidSchedulers.mainThread())     .subscribe(new Observer<Bitmap>() {           @Override         public void onCompleted() {         }           @Override         public void onError(Throwable e) {             App.L.error(e.toString());         }           @Override         public void onNext(Bitmap icon) {             city_image.setImageBitmap(icon);         }     }); }

 

运行代码，咱们能够在下面列表中为每一个用户得到新的天气图标：

打开网站

使用用户主页包含的信息，咱们将会建立一个onClick监听器来导航到用户web页面，若是有，或者是Stack Overflow我的主页。

为了实现它，咱们简单实现Activity类的接口，用来在适配器触发Android的onClick事件。

咱们的Adapter ViewHolder指定这个接口：

 

 

1 2 3 4

public interface OpenProfileListener {     public void open(String url); }

 

Activity实现它：

 

 

1 2 3 4 5 6 7 8 9 10 11

[https://github.com/yuxingxin/RxJava-Essentials-CN/raw/master.] implements SoAdapter.ViewHolder.OpenProfileListener { [https://github.com/yuxingxin/RxJava-Essentials-CN/raw/master.]     mAdapter.setOpenProfileListener(this); [https://github.com/yuxingxin/RxJava-Essentials-CN/raw/master.]   @Override public void open(String url) {     Intent i = new Intent(Intent.ACTION_VIEW);     i.setData(Uri.parse(url));     startActivity(i); }

 

Activity收到URL并用外部Android浏览器打开它。咱们的ViewHolder负责在用户列表的每一个卡片上建立OnClickListener并检查咱们是打开Stack Overflow用户主页仍是外部我的站：

 

 

1 2 3 4 5 6 7 8 9 10 11

mView.setOnClickListener(view -> {     if (mProfileListener != null) {         String url = user.getWebsiteUrl();         if (url != null && !url.equals("") && !url.contains("search")) {             mProfileListener.open(url);         } else {             mProfileListener.open(user.getLink());         }     } )}；

 

一旦咱们点击了，咱们将直接重定向到预期的网站。在Android上，咱们能够用RxAndroid的一种特殊形式（ViewObservable）以更加响应式的方式实现一样的结果。

 

 

1 2 3 4 5 6 7 8 9 10 11 12

ViewObservable.clicks(mView)     .subscribe(onClickEvent -> {     if (mProfileListener != null) {         String url = user.getWebsiteUrl();         if (url != null && !url.equals("") && !url.contains("search")) {             mProfileListener.open(url);         } else {             mProfileListener.open(user.getLink());         }     } });

 

上面两块代码片断是等价的，你能够选择你最喜欢的那一种方式。

总结

咱们的旅程结束了。你已经准备好将你的Java应用带到一个新的代码质量水平。你能够享受一个新的编码模式并用更流畅的思惟方式接触你的平常编码生活。RxJava提供这样一种机会来以面向时间的方式考虑数据：全部事情都是持续可变的，数据在更新，事件在触发，而后你能够建立基于这些事件响应的，灵活的，运行流畅的App。

刚开始切换到RxJava看起来难而且耗时，可是咱们经历了如何用响应式的方式有效地处理平常问题。如今你能够把你的旧代码迁移到RxJava上:给这些同步getters一种新的响应式生活。

RxJava是一个正在不断发展和扩大的世界。还有许多方法咱们尚未去探索。有些方法甚至尚未，由于RxJava，你能够建立你本身的操做符并把他们推得更远。

Android是一个好玩的地方，可是它也有局限性。做为一个Android开发者，你能够用RxJava和RxAndroid克服它们中许多部分。咱们用AndroidScheduler只简单提了下RxAndroid,除了在最后一章，你了解了ViewObservable。RxAndroid给了你许多：例如，WidgetObservable，LifecycleObservable。如今要更多的推进它取决于你了。

记得可观测序列就像一条河：它们是流动的。你能够“过滤”一条河，你能够“转换”一条河，你能够将两条河合并成一个，而后它仍旧时流动的。最后，它将成为你想要的那条河。