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);
????}
}

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