java rxjava

java rxjava是什么？让我们一起来了解一下吧！

java rxjava是java程序中的响应式编程。所谓响应式编程，是指一种基于异步数据流概念的编程模式Rxjava的完整英文名称是reactivexjava，它是一个数据库，作用是支持需要异步控制的地方。与handler相比，rxjava更具备简洁性。

rxjava有以下几个独特点：

1. <1mb jar

2. 轻量级框架

3. 可以在java 8 lambda运行

4. 可以在java 6+&android 2.3+运行

5. 同步或者异步都可以

实战演练，具体步骤如下：

package top.onefine.rxjava;
 
import lombok.extern.slf4j.Slf4j;
import rx.Observable;
import rx.Subscriber;
 
@Slf4j
public class HelloWorld {
 
    public static void main(String[] args) {
        // 1. 创建被观察者
        Observable observable = Observable.create(subscriber -> {
            subscriber.onNext("Hello world.");
            throw new NullPointerException("Throw a Exception...");
//            subscriber.onCompleted();
        });
 
        // 2. 创建观察者
        Subscriber subscriber = new Subscriber() {
 
            @Override
            public void onCompleted() {
                log.info("onCompleted...");
            }
 
            @Override
            public void onError(Throwable e) {
                log.info("onError...");
            }
 
            @Override
            public void onNext(String s) {
                log.info("onNext: {}", s);
            }
        };
 
        // 3. 订阅事件
        observable.subscribe(subscriber);
    }
}

以上就是小编今天的分享了，希望可以帮助到大家。