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