關於grpc,在前面的scalaPB討論里已經做了詳細的介紹:google gRPC是一種全新的RPC框架,在開源前一直是google內部使用的集成工具。gRPC支持通過http/2實現protob ...
實際上很早就寫了一系列關於akka streams的博客。但那個時候純粹是為了了解akka而去學習的,主要是從了解akka streams的原理為出發點。因為akka streams是akka系列工具的基礎,如:akka http, persistence query等都是基於akka streams的,其實沒有真正把akka streams用起來。這段時間所遇到的一些需求也是通過集合來解決的。 ...
2020-09-07 08:19 0 749 推薦指數:
關於grpc,在前面的scalaPB討論里已經做了詳細的介紹:google gRPC是一種全新的RPC框架,在開源前一直是google內部使用的集成工具。gRPC支持通過http/2實現protob ...
今天我們來講解akka-streams,這應該算akka框架下實現的一個很高級的工具。之前在學習akka streams的時候,我是覺得雲里霧里的,感覺非常復雜,而且又難學,不過隨着對akka源碼的深入,才逐漸明白它到底是怎么一回事。下面介紹主要摘自akka官網,但會融入我的理解,以及部分源碼 ...
從源代碼深入Stream / 學習的時候,官方文檔是最重要的. 及其重要的內容我們不僅要知道stream用,要知道為什么這么用,還要知道底層是怎么去實現的. --個人注釋:從此看出,雖然新的jdk版本對開發人員提供了很大的遍歷,但是從底層角度來說,實現確實是非常復雜的. --對外 ...
AKKA簡介 什么是AKKA Akka是一個由Scala編寫的,能兼容Sacala和JAVA的,用於編寫高可用和高伸縮性的Actor模型框架.它基於了事件驅動的並發處理模式,性能非常的高,並且有很高的可用性.大大的簡化了我們在應用系統中開發並發處理的過程.它在各個領域都有很好的表現. 使用 ...
akka是一種支持高並發的java框架,在thingsboard中akka作為一種工具,actor是akka執行的基本單元,比線程更輕量級,在actor之前投遞消息應該滿足不可變性。 在thingsboard中,控制設備過程中,可能又不止一台設備發送消息,這時需要用akka框架中的actor來使 ...
在現實應用中akka-stream往往需要集成其它的外部系統形成完整的應用。這些外部系統可能是akka系列系統或者其它類型的系統。所以,akka-stream必須提供一些函數和方法來實現與各種不同類型系統的信息交換。在這篇討論里我們就介紹幾種通用的信息交換方法和函數 ...
上期說道:http/2還屬於一種不算普及的技術協議,可能目前只適合用於內部系統集成,現在開始大面積介入可能為時尚早。不過有些項目需求不等人,需要使用這項技術,所以研究了一下akka-grpc,寫了一篇介紹。本想到此為止,繼續其它項目。想想這樣做法有點不負責任,像是草草收場。畢竟用 ...
本博客討論一下akka在秒殺場景下的應用,提出自己的見解,只做拋磚引玉,大神勿噴。秒殺活動涉及到前中后台各個階段,為了說明問題,我們簡化場景,只研究akka在后台如何處理秒殺業務。 秒殺活動 所謂的秒殺活動,簡單點來說,就是把某個稀缺商品或促銷商品,掛到頁面,供大量客戶搶購。這里有 ...