java rxjava

<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>

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; @Slf4jpublic 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);    }}