4 生產(chǎn)者與消費(fèi)者之間的調(diào)解 下一個(gè)示例將涉及將事件廣播到消費(fèi)服務(wù)。到目前為止，我們已經(jīng)將日志事件寫(xiě)入磁盤(pán)——一個(gè)含有所有事件的日志文件谬晕，以及警...

3 使用Graph DSL實(shí)現(xiàn)扇入扇出 到目前為止，我們只研究了一個(gè)輸入和一個(gè)輸出的線(xiàn)性處理携取。Akka-stream提供了用于描述扇入和扇出的圖...

1 基本流處理 讓我們首先看看使用akka-stream處理流的真正含義攒钳。圖1展示了在某個(gè)處理節(jié)點(diǎn)上，元素是一個(gè)個(gè)如何被處理的雷滋。一次處理一個(gè)元素...