当钢铁侠变得更敏捷，Rxjava(翻译)

发表于 2015-08-23

原文：When Iron Man becomes reactive, RxJava

一个像Rxjava这样的ReactiveX框架，可以帮助你轻松处理在不同的线程上运行的任务。在android上，这经常是一个棘手的问题。

这篇文章也关注operators如何让开发任务更高效，Reactive Extensions提供很多很多operators让你的生活更容易。
惯例，所有的代码都放在了Github,欢迎评论，issue或拍砖！

上一篇我们讲了Dagger2，接下来我们会看到更少的耦合和更好的扩展性。

RetroLambda

有时候，在java大型项目里，或者在大型框架里，像android这种，很难去使用java8的特性，比如Lambda表达式.Retrolambda就是用来解决这个问题的。

1 2	dependencies { classpath 'me.tatarka:gradle-retrolambda:3.1.0'

 apply plugin: 'me.tatarka.retrolambda'

    android { 

        ...

        compileOptions {
            sourceCompatibility JavaVersion.VERSION_1_8
            targetCompatibility JavaVersion.VERSION_1_8
        }
    }
}

RetroLambda使你写更少的样板代码，同样让你的代码更清晰易懂。看这个例子：

不用RetroLambda

Observable.just("Hello, world!")
    .subscribe(new Action1<String>() {
        @Override
        public void call(String s) {
              System.out.println(s);
        }
    });

用了RetroLambda

1
2
3

Observable.just("Hello, world!") .subscribe(
    s -> System.out.println(s)
);

在复仇者联盟的例子里

mCharacterSubscription = mGetCharacterInformationUsecase
    .execute().subscribe(
        character -> onAvengerReceived(character),
        error     -> manageError(error)
    );

mComicsSubscription = mGetCharacterComicsUsecase
    .execute().subscribe(
        comics -> Observable.from(comics).subscribe(
            comic -> onComicReceived(comic)),
        error  -> manageError(throwable)
    );

ReactiveX

ReactiveX的主要原则是观察者模式，迭代器模式和函数式编程。

ReactiveX也用来异步编程，实际上使用它你可以非常容易的实现异步任务。

ReactiveX，异步客户端

ReactiveX的一大作用就是你可以用它写一个完整的异步api或客户端，然后在实现时决定是使用异步还是线程还是同步。

所以我们使用observable API而不是阻塞的API.

public interface Usecase<T> {

    Observable<T> execute();
}

public interface Repository {

    Observable<Character> getCharacter (final int characterId);

    Observable<List<Comic>> getCharacterComics (final int characterId);
}

什么是RxJava

RxJava是Netflix开发的一个Reactive Extensions的实现。

Observables&Observers

一个Observable(被观察者)发出一个或者多个对象，这些对象被订阅了Observable的Observer(观察者)消费或接收。

Observer必须向Observable注册，当Observer注册之后，就创建了一个Subscription对象，这个对象用来从Observableunsubscribe(取消订阅),这对于Activity和Fragment里的onStop或者onPause是非常有用的。比如：

1 2	mCharacterSubscription = mGetCharacterInformationUsecase .execute().subscribe( ... );

@Override
public void onStop() {

    if (!mCharacterSubscription.isUnsubscribed())
        mCharacterSubscription.unsubscribe();

    if (!mComicsSubscription.isUnsubscribed())
        mComicsSubscription.unsubscribe();
}

无论何时Observer向Observable注册，都要实现三个方法：

onNext(T)接收Observale发出的对象
onError(Exception)当发生错误时调用这个方法
onCompleted()当Observable完成发出对象时调用这个方法

通信组件

让我们看一看怎么使用GetCharacterInformationUsecase用例。所有的用例都实现接口Usercase<T>:

public interface Usecase<T> {

    Observable<T> execute();
}

当这个用例运行的时候，它返回一个Observable对象，这对于链接observable&operators非常有用，我们一会会看到这些operators的强大力量。

当我们运行GetCharacterInformationUsecase,我们告诉repository去发送一个数据请求：

@Override
public Observable<Character> execute() {

    return mRepository.getCharacter(mCharacterId);
        // .awesomeRxStuff();
}

我们的AvengerDetailPresenter会是这个用例的Observer，它订阅Observable发出的事件。我们用subscribe来实现订阅，把Observer和Observable连接起来。
onNext和onError方法用来管理操作的结果。onCompleted方法在本例中没有实现因为不必要。

mCharacterSubscription = mGetCharacterInformationUsecase
    .execute().subscribe(
        character   -> onAvengerReceived(character),
        error       -> manageError(error));

Retrofit&RxJava

Square开发的Retrofit支持Observable类型，所以请求可以被Observer观察和被operator转换。

你必须知道在哪儿调用它，Retrofit在你的Observable的线程上执行请求，所以如果你从UI线程调用它就会产生错误。让我们谈一谈Schedulers.

Schedulers（调度器）

你可以用不同的线程，一个Thread Executor，或者预设的Schedulers,比如，对于输入和输出操作有Schedulers.io().

@Override
    public Observable<Character> execute() {

        return mRepository.getCharacter(mCharacterId)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread());
    }

这个例子证明了Rx为管理多线程带来的方便，在android开发中，多线程经常是个麻烦的事情。

Operators(操作者)

Operators是ReactiveX的重中之重，用来操纵，转换或者连接由Observable发出的对象。
想一下，一个角色的漫画列表，漫画有特定的年份，而我们想显示某一年的漫画。ReactiveX来帮我们了！

我们使用operator filter。

public Observable<Comic> filterByYear(String year) {

    if (mComics != null) {
        return Observable.from(mComics).filter(
            comic -> {
                for (ComicDate comicDate : comic.getDates())
                    if (comicDate.getDate().startsWith(year))
                        return true;

                return false;
        });

    }

    return null;
}

错误处理

Rx operators可以帮我们节省时间提高生产力的另一个例子就是，它的error handling operators.

想一想，如果一个用户这在使用网络请求，但是不巧他正在地铁隧道里，这是网络连接会受影响。

当我们收到一个Retrofit发出的SocketTimeoutException，我们可以使用operator retry。

retry会接收一个断言，如果我们返回true，那么Rx就再次发出一个Observable让Retrofit在为我们请求一次。

如果'SocketTimeoutExceptions达到了最大次数，就会执行onError去处理错误了。

@Override
public Observable<List<Comic>> getCharacterComics(int characterId) {

    final String comicsFormat   = "comic";
    final String comicsType     = "comic";

    return mMarvelApi.getCharacterComics(
        characterId, comicsFormat, comicsType)
            .retry((attemps, error) -> 
                error instanceof SocketTimeoutException && 
                attemps < MAX_ATTEMPS);
}

当复仇者联盟遇上Dagger2，rxjava和Retrofit(翻译)

By 巴拉森

发表于 2015-08-22

原文：When the Avengers meet Dagger2, RxJava and Retrofit in a clean way

最近，很多文章，框架和android社区的讨论都谈到了测试和软件架构，就像上一次所提到的，我们关注如何让程序更健壮而不是如何开发更多特性功能。这表示android框架和现在的android社区正在走向成熟。

今天，如果你是一个android开发者但还不知道这几个词：Dagger2,Rxjava和Retrofit，你就要错过一些东西了。本系列会关注如何把这些框架结合起来使用从而实现更清晰的架构。

我本来想只写一篇文章的，但是看到这些框架有这么多的内容，我决定写一个系列，至少三篇文章。

惯例，所有的代码都放到了GitHub上，欢迎建议和拍砖，抱歉我可能没有太多时间去回复所有问题。

avengers

依赖注入&Dagger2

理解这个框架的工作方式会花一些时间，所以我会尽量说清楚。

Dagger2建立在依赖注入模式的基础上。

看下面的代码段：

// Thor is awesome. He has a hammer!
    public class Thor extends Avenger {
        private final AvengerWeapon myAmazingHammer;

        public Thor (AvengerWeapon anAmazingHammer) {
            myAmazingHammer = anAmazingHammer;
        }

        public void doAmazingThorWork () {
            myAmazingHammer.hitSomeone();
        }
    }

索尔需要一个AvengerWeapon去打架，依赖注入的基本思想是与其索尔自己造一个AvengerWeapon，不如通过他的构造方法传给他。如果索尔自己造一个锤子就会增加耦合。

AvengerWeapon可以是一个接口，会根据我们的逻辑以多种方式实现和注入。

在android中，因为框架设计的缘故，要进入类的构造方法并不总是这么容易，比如Activity和Fragment。

这就是依赖注入器发挥好处的时候了，比如Dagger和Guice。

使用Dagger2我们可以把上面的代码转换成这样：

// Thor is awesome. He has a hammer!
    public class Thor extends Avenger {
        @Inject AvengerWeapon myAmazingHammer;

        public void doAmazingThorWork () {
            myAmazingHammer.hitSomeone();
        }
    }

我们没有直接进入索尔的构造方法，注入器，用少量的代码负责构造索尔的锤子

public class ThorHammer extends AvengerWeapon () {

        @Inject public AvengerWeapon() {

            initGodHammer();
        }
    }

@Inject注解告诉Dagger2应该用哪一个构造方法去构造索尔的锤子。

Dagger2

Dagger2是谷歌实现的，是Square开发的Dagger的分支。
首先必须配置注解的处理器，即android-apt插件。
build.gradle(在project的根目录)

dependencies {
        ...
        classpath 'com.neenbedankt.gradle.plugins:android-apt:1.4'
    }

build.gradle(在你的android module)

apply plugin: 'com.neenbedankt.android-apt'

    dependencies {
        ...
        apt 'com.google.dagger:dagger-compiler:2.0'
    }

Components，modules&Avengers

modules就是提供依赖的，components就是注入这些依赖的。
例子：

@Module
public class AppModule {
    private final AvengersApplication mAvengersApplication;

    public AppModule(AvengersApplication avengersApplication) {
        this.mAvengersApplication = avengersApplication;
    }

    @Provides @Singleton 
    AvengersApplication provideAvengersAppContext () { 
        return mAvengersApplication; 
    }

    @Provides @Singleton 
    Repository provideDataRepository (RestRepository restRepository) { 
        return restRepository; 
    }
}

这是main module，我们感兴趣的是它提供的context，存在于应用的整个生命周期，和一个repository,用来获取信息。
很简单，对吧？
通过@Provides注解，我们告诉Dagger2怎么去构造所需的依赖。否则，对于一个特定的依赖，如果我们不指明一个provider，那么Dagger2会去寻找被@Inject标注的构造方法。
components使用modules去注入依赖，看这个module的component:

@Singleton @Component(modules = AppModule.class)
public interface AppComponent {

    AvengersApplication app();
    Repository dataRepository();
}

这个module并不会被任何activity和fragment调用，而是被一个更复杂的module使用，来提供所需的依赖。
这是依赖树状图:
tree

@Module
public class AvengersModule {

    @Provides @Activity
    List<Character> provideAvengers() {

        List<Character> avengers = new ArrayList<>(6);

        avengers.add(new Character(
            "Iron Man", R.drawable.thumb_iron_man, 1009368));

        avengers.add(new Character(
            "Thor", R.drawable.thumb_thor, 1009664));

        avengers.add(new Character(
            "Captain America", R.drawable.thumb_cap,1009220));

        avengers.add(new Character(
            "Black Widow", R.drawable.thumb_nat, 1009189));

        avengers.add(new Character(
            "Hawkeye", R.drawable.thumb_hawkeye, 1009338));

        avengers.add(new Character(
            "Hulk", R.drawable.thumb_hulk, 1009351));

        return avengers;
    }
}

这个module用来向一个特定的activity注入依赖，实际就是那个负责绘制复仇者联盟列表的activity.

@Activity 
@Component(
    dependencies = AppComponent.class, 
    modules = {
        AvengersModule.class, 
        ActivityModule.class
    }
)
public interface AvengersComponent extends ActivityComponent {

    void inject (AvengersListActivity activity);
    List<Character> avengers();
}

这儿有一个新方法：void inject (AvengersListActivity activity)，这个方法在AvengerListActivity被调用了之后，依赖就可以被消费了。

结合所有

我们的AvengersApplication类，负责向其他component提供appcomponent，注意，它并不注入任何依赖，只是提供component.
AvengersApplication.java

public class AvengersApplication extends Application {

    private AppComponent mAppComponent;

    @Override
    public void onCreate() {

        super.onCreate();
        initializeInjector();
    }

    private void initializeInjector() {

        mAppComponent = DaggerAppComponent.builder()
            .appModule(new AppModule(this))
            .build();
    }

    public AppComponent getAppComponent() {

        return mAppComponent;
    }
}

AvengersListActivity.java

public class AvengersListActivity extends Activity 
    implements AvengersView {

    @InjectView(R.id.activity_avengers_recycler) 
    RecyclerView mAvengersRecycler;

    @InjectView(R.id.activity_avengers_toolbar) 
    Toolbar mAvengersToolbar;

    @Inject 
    AvengersListPresenter mAvengersListPresenter;

    @Override
    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_avengers_list);
        ButterKnife.inject(this);

        initializeToolbar();
        initializeRecyclerView();
        initializeDependencyInjector();
        initializePresenter();
    }

    private void initializeDependencyInjector() {

        AvengersApplication avengersApplication = 
            (AvengersApplication) getApplication();

        DaggerAvengersComponent.builder()
            .avengersModule(new AvengersModule())
            .activityModule(new ActivityModule(this))
            .appComponent(avengersApplication.getAppComponent())
            .build().inject(this);
    }

presenter被初始化，使用了Dagger2提供的avengers

public class AvengersListPresenter implements Presenter, RecyclerClickListener {

    private final List<Character> mAvengersList;
    private final Context mContext;
    private AvengersView mAvengersView;
    private Intent mIntent;

    @Inject public AvengersListPresenter (List<Character> avengers, Context context) {

        mAvengersList = avengers;
        mContext = context;
    }

presenter的构造方法有一个@Inject注解，所以Dagger2会自动解决需要传的参数。
Dagger2知道怎么构造这些参数，因为在module里有@Provides方法。

android databinding简单心得

By 巴拉森

发表于 2015-08-21

介绍

谷歌最近推出了databinding技术，可以在layout文件就是xml中直接绑定数据，不用像以前那样先findViewById()再setText()了。其实这个技术微软的开发平台上早就有了，确实很方便的说。

准备

android studio 1.3.0-beta1或更高版本
在gradle里添加databinding

dependencies {
       classpath "com.android.tools.build:gradle:1.2.3"
       classpath "com.android.databinding:dataBinder:1.0-rc0"
   }

1 2	apply plugin: ‘com.android.application' apply plugin: 'com.android.databinding'

layout文件

根元素必须是layout,然后是一个data元素，一个普通的view元素。比如：

<?xml version="1.0" encoding="utf-8"?>
<layout xmlns:android="http://schemas.android.com/apk/res/android">
   <data>
       <variable name="user" type="com.example.User"/>
   </data>
   <LinearLayout
       android:orientation="vertical"
       android:layout_width="match_parent"
       android:layout_height="match_parent">
       <TextView android:layout_width="wrap_content"
           android:layout_height="wrap_content"
           android:text="@{user.firstName}"/>
       <TextView android:layout_width="wrap_content"
           android:layout_height="wrap_content"
           android:text="@{user.lastName}"/>
   </LinearLayout>
</layout>

data里面是绑定的数据user,android:text="@{user.firstName}"就是把TextView的text属性绑定user的firstName属性，很方便吧！

data对象

这个简单，比如User:

public class User {
   private String firstName;
   private String lastName;
}

别忘了加上getter和setter，很关键！

binding对象

做完了上面的，就会自动生成一个Binding类，名字是根据layout文件的名字起的。比如，上面那个layout文件叫做activity_main.xml,那么就会自动生成一个ActivityMainBinding类，这个类持有User和layout里的所有属性。我创建一个binding对象并给它设置数据，它就自动把数据绑定到layout里了。比如：

@Override
protected void onCreate(Bundle savedInstanceState) {
   super.onCreate(savedInstanceState);
   ActivityMainBinding binding = DataBindingUtil.setContentView(this, R.layout.main_activity);
   User user = new User("Test", "User");
   binding.setUser(user);
}

如果是在RecyclerView的Adapter里，可以这样：

1	ListItemBinding binding = DataBindingUtil.inflate(layoutInflater, R.layout.list_item, viewGroup, false);

深入layout文件

layout文件里支持表达式，比如：

<TextView
   android:text="@{user.lastName}"
   android:layout_width="wrap_content"
   android:layout_height="wrap_content"
   android:visibility="@{user.isAdult ? View.VISIBLE : View.GONE}"/>

但是你用到了View类，必须import，就像在java文件里那样。比如：

1
2
3

<data>
    <import type="android.view.View"/>
</data>

现在android studio对databinding的支持还不完善，可能写xml的时候很多地方会没有智能提示。。。
具体指南请参考：databinding中文指南（翻译)

巴拉森-小鸟哔哔-裂魂人！滴博客

老jay迷(●'◡'●)