一直不知道如何下手寫技術(shù)相關(guān)的文章泰偿，但好歹也是做技術(shù)的磅叛，總要踏出第一步值骇，各位看官不喜勿噴因苹。
剛好前段時(shí)間被rxJava所吸引，中間斷斷續(xù)續(xù)的學(xué)習(xí)蛤育，雖然算不上精通宛官，但應(yīng)對一般的應(yīng)用場景還是沒問題的，記錄下學(xué)習(xí)過程中的小小心得瓦糕，如果有不對的地方歡迎指正底洗，希望有更多對rxJava感興趣的小伙伴共同學(xué)習(xí)。
由于本人學(xué)習(xí)的是rxJava 1.x版本咕娄，后續(xù)文章都是基于rx 1.x
什么是rxJava
rxJava 1.x的github地址https://github.com/ReactiveX/RxJava/tree/1.x亥揖， 引用原文介紹“RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.”（一個(gè)在 Java VM 上使用可觀測的序列來組成異步的、基于事件的程序的庫）圣勒，相信各位大神都能看懂费变，這是一個(gè)響應(yīng)式編程的庫。rxJava 1.x文檔地址http://reactivex.io/RxJava/1.x/javadoc/rx/Observable.html圣贸，英文好的同學(xué)可以直接閱讀學(xué)習(xí)挚歧。
使用rxJava
舞臺(tái)有了，接下來就差演員了吁峻，使用rxJava一般需要3類角色滑负，Observable，Subscriber锡搜，subscribe橙困。相信做android開發(fā)的同學(xué)對添加監(jiān)聽器毫不陌生瞧掺，如果我們要監(jiān)聽一個(gè)按鈕的點(diǎn)擊事件耕餐，也需要3個(gè)角色，Button 辟狈、OnClickListener 肠缔、setOnClickListener，當(dāng)調(diào)用
Button.setOnClickListener(OnClickListener)時(shí)哼转，OnClickListener 就開始監(jiān)聽Button的點(diǎn)擊事件了明未，同理，這里的Observable相當(dāng)于Button壹蔓，Subscriber相當(dāng)于OnClickListener趟妥，subscribe相當(dāng)于setOnClickListener，它們之間的對應(yīng)關(guān)系如下表：
| 被監(jiān)聽者 | 監(jiān)聽者 | 建立關(guān)系 | |
|---|---|---|---|
| 監(jiān)聽按鈕 | Button | OnClickListener | setOnClickListener |
| rxJava | Observable | Subscriber | subscribe |
Observable
創(chuàng)建Observable一般有兩種最常見的方法：
- 直接發(fā)送一個(gè)對象
調(diào)用Observable的just方法佣蓉，這是一個(gè)靜態(tài)泛型方法披摄，泛型參數(shù)T就是發(fā)送對象
public static <T> Observable<T> just(final T value) {
return ScalarSynchronousObservable.create(value);
}
比如發(fā)送一個(gè)字符串
Observable observable = Observable.just("Hello world!");
- 通過create方法亲雪，傳入一個(gè)OnSubscribe對象
public static <T> Observable<T> create(OnSubscribe<T> f) {
return new Observable<T>(RxJavaHooks.onCreate(f));
}
有的同學(xué)要問了，OnSubscribe是什么鬼疚膊？看源碼
public interface OnSubscribe<T> extends Action1<Subscriber<? super T>> {
// cover for generics insanity
}
public interface Action1<T> extends Action {
void call(T t);
}
這是一個(gè)接口類义辕，繼承自Action1，總之寓盗，生成OnSubscribe需要實(shí)現(xiàn)void call(T t)方法灌砖，下面我們還是發(fā)送一個(gè)字符串
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello World!");
subscriber.onCompleted();
}
});
為了好理解，你可以把call方法里的Subscriber看成是我們的觀察者Subscriber（相當(dāng)于監(jiān)聽按鈕中的OnClickListener）傀蚌，call方法里的Subscriber發(fā)送一個(gè)事件基显，然后由觀察者Subscriber最終接收這個(gè)事件，是不是就很好理解了~~~
Subscriber
觀察者善炫，通過Observable 發(fā)送的事件续镇，最終都由Subscriber處理，這是一個(gè)抽象類销部，實(shí)例化需要實(shí)現(xiàn)3個(gè)方法
Subscriber subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
};
onNext處理Observable 中subscriber.onNext("Hello World!")發(fā)送的對象摸航；
onCompleted表示收到Observable中subscriber.onCompleted()事件；
onError表示在發(fā)送事件或者處理事件中出現(xiàn)異常舅桩；
注意：subscriber無論是收到onError事件還是onCompleted事件酱虎，都表示訂閱關(guān)系結(jié)束，無論Observable是否還在發(fā)送事件擂涛，都不會(huì)再收到消息读串。也就是說onCompleted事件和onError事件不會(huì)同時(shí)發(fā)生。
subscribe
好了撒妈，有了被觀察者和觀察者恢暖，讓他們發(fā)生關(guān)系吧，subscribe就是讓他們確立關(guān)系的紐帶狰右，只有當(dāng)Subscriber通過subscribe方法訂閱Observable后杰捂，才可能收到消息。
observable.subscribe(subscriber);
Hello RxJava
首先在gradle中加入rxjava庫
//rxjava
compile 'io.reactivex:rxjava:1.2.7'
compile 'io.reactivex:rxandroid:1.2.1'
ok讓我們試一下吧棋蚌，點(diǎn)擊按鈕嫁佳，在TextView里顯示Hello RxJava，代碼很簡單
package com.rxdemo.liuqiang.rxjavademo;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import com.rxdemo.liuqiang.rxjavademo.utils.LogUtil;
import rx.Observable;
import rx.Subscriber;
public class MainActivity extends AppCompatActivity implements View.OnClickListener{
private static final String TAG = "rxDemo";
private Button btn_send;
private TextView tv_log;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
btn_send = (Button) findViewById(R.id.btn_send);
tv_log = (TextView) findViewById(R.id.tv_log);
btn_send.setOnClickListener(this);
}
@Override
public void onClick(View view) {
switch (view.getId()) {
case R.id.btn_send:
print("Hello rxJava!");
break;
}
}
private void print(String content){
Observable<String> observable = Observable.just(content);
Observable<String> observable1 = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello rxJava!");
subscriber.onCompleted();
}
});
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
LogUtil.v("onCompleted");
}
@Override
public void onError(Throwable e) {
LogUtil.v("onError" + e.getMessage());
}
@Override
public void onNext(String s) {
LogUtil.v("onNext");
tv_log.setText(s);
}
};
observable.subscribe(subscriber);
}
}
是不是很簡單呢谷暮？
可能有的小伙伴會(huì)問了蒿往，顯示一個(gè)字符串用這么多代碼，這叫好用湿弦？呃瓤漏。。。先別著急噴蔬充，后面再介紹它更多更強(qiáng)大的用法俯在，今天先到這里吧。
