鍍金池/ 教程/ Java/ 構架總覽
異步 TCP、UDP 及 HTTP
微批處理
編解碼器與緩沖區(qū)
組合多個服務調用
環(huán)境與調度者
環(huán)形緩沖區(qū)處理者
Stream 數據持久化
函數式功能
reactor-stream
概述
背壓和溢出
核心處理者
數據路由
響應式數據流
什么是 Reactor?
支持響應式背壓
微服務
組合操作
使用 Stream 和 Promise(約定) 協(xié)調任務
Reactor 介紹
分區(qū)
發(fā)布訂閱模型
錯誤處理
分析
核心概述
創(chuàng)建非阻塞服務
使用緩沖區(qū)
請求應答模式
關于該項目
理解線程模型
reactor-核心
響應式擴展
Streams 的基礎知識
構架總覽
Rx 之外的其它 API
注冊表
使用窗口
使用前提

構架總覽

http://wiki.jikexueyuan.com/project/reactor-2.0/images/1.png" alt="" />

圖 1. Reactor 2.0 主要模塊

Reactor 代碼庫拆分成多個子模塊,便于選擇所需功能,不受其他功能代碼塊干擾。

下面舉例說明,為實現異步目標,響應式技術和 Reactor 模塊該如何搭配:

  • Spring XD + Reactor-Net (Core/Stream): 使用 Reactor 作為 Sink/Source IO 驅動。
  • Grails | Spring + Reactor-Stream (Core): 用 Stream 和 Promise 做后臺處理。
  • Spring Data + Reactor-Bus (Core): 發(fā)射數據庫事件 (保存/刪除/…?)。
  • Spring Integration Java DSL + Reactor Stream (Core): Spring 集成的微批量信息通道。
  • RxJavaReactiveStreams + RxJava + Reactor-Core: 融合富結構與高效異步 IO 處理
  • RxJavaReactiveStreams + RxJava + Reactor-Net (Core/Stream): 用 RxJava 做數據輸入,異步 IO 驅動做傳輸。

http://wiki.jikexueyuan.com/project/reactor-2.0/images/2.png" alt="" />

圖2. Reactor 模塊相互依賴關系快速概覽

上一篇:核心概述下一篇:響應式擴展