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

Stream 數(shù)據(jù)持久化

并不是所有的數(shù)據(jù)都要待在內(nèi)存里,Reactor 已經(jīng)開(kāi)始整合(可選依賴)Java Chronicle。

return Streams.merge(
  userService.filteredFind("Rick"),
  userService.filteredFind("Morty")
)
.buffer()
.retryWhen( errors ->
  errors
  .zipWith(Streams.range(1,3), t -> t.getT2())
  .flatMap( tries -> Streams.timer(tries) )
)
.consume(System.out::println);

表 15,安全的持久化信號(hào)

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