響應(yīng)式(Reactive)編程其實(shí)我沒(méi)有太多的經(jīng)驗(yàn)，趁著這段期間的學(xué)習(xí)理解來(lái)做些整理，對(duì)於Actor Model 的實(shí)現(xiàn)在Scala 語(yǔ)言上已經(jīng)有著很成熟的Akka Framework，我預(yù)期後續(xù)將以Akka 作為這一系列的主要的範(fàn)式的實(shí)踐。
題外話(huà)，關(guān)於Actor Model/Reactive的實(shí)作選擇很多，當(dāng)前有個(gè)也很紅的Golang，甚至RxJava也是 ~
原生的Akka framework 是以Scala實(shí)作的，但我希望能夠以較為熟悉的語(yǔ)言平臺(tái)來(lái)進(jìn)行試煉，改用Java進(jìn)行專(zhuān)案配置，相關(guān)的配置baby steps 參考這裡(github markdown)。
在開(kāi)始之前，我先搜集了一下關(guān)於Actor Model 的最佳實(shí)踐：
1. Actor的實(shí)踐，最主要是透過(guò)避免資源競(jìng)爭(zhēng)的情況，而達(dá)成能夠解決高併發(fā)的情境，在發(fā)送的訊息主體上都要求不該傳送可變的訊息內(nèi)容(其實(shí)，就像是發(fā)生的事實(shí)不可逆一樣)。
2. 如果一但你傳遞的訊息是可變動(dòng)的，那你勢(shì)必要回頭去解決傳統(tǒng)Java在Concurrency 上遇到的那些缺點(diǎn)，譬如競(jìng)爭(zhēng)所“資源釋放等等。
3. Actor持有狀態(tài)與行為，並且不直接的開(kāi)放讓外部的系統(tǒng)或其他actor 來(lái)直接改變它，這可確保每一個(gè)Actor 的最小影響範(fàn)圍以及他的可監(jiān)控性。
4. 在最上層的Actor應(yīng)該善盡到error handle的責(zé)任，不能讓他底下的子actor 或 delegate出去的task 產(chǎn)生錯(cuò)誤時(shí)直接就就回拋System level去。
5. 如果有blocking 的呼叫，譬如說(shuō)是rdbms connection, messaging api?, 建議把這段呼叫封裝到Future的操作上，在 Akka 的 建議當(dāng)中特別提到Blocking needs Careful Management#blocking problem。
話(huà)不多說(shuō)了，來(lái)看一下實(shí)際的代碼
Akka framework提供了多種的套件管理工具機(jī)制來(lái)建構(gòu)應(yīng)用程式，我選擇了以gradle 來(lái)建構(gòu)java application，雖然官方是以Gradle來(lái)建構(gòu)Scala專(zhuān)案，但為了避免一次開(kāi)太多炸彈讓我走不下去，我還是先選熟悉的Java專(zhuān)案。
範(fàn)例專(zhuān)案放在GitHub?:https://github.com/humank/reactive
Actor的實(shí)踐，可以從繼承一個(gè)AbstractActor 開(kāi)始，他唯一需要你定義實(shí)踐的 就是當(dāng)你收到事件訊息時(shí)，你應(yīng)該做哪些事情：把 createReceive()給實(shí)現(xiàn)即可。
在實(shí)現(xiàn)receive message時(shí)，預(yù)設(shè)Akka framework是有兩個(gè)設(shè)計(jì)原則：
你應(yīng)該對(duì)你的Actor負(fù)責(zé)，對(duì)於每一個(gè)訊息類(lèi)型都設(shè)計(jì)她應(yīng)該有的對(duì)應(yīng)的處理做法。
如果有任何的訊息類(lèi)型不在你的Receive handler裡頭可以被處理的話(huà)，那麼Akka framework會(huì)把這些unHandled message 視為DeadLetters，統(tǒng)一轉(zhuǎn)交給ActorSystem去(具體實(shí)現(xiàn)還待後續(xù))。
在撰寫(xiě)Actor 的時(shí)候，發(fā)現(xiàn)到Actor除了有AbstractActor之外還有個(gè)AbstractLoggingActor !
顧名思義，是提供了一個(gè)原生具有l(wèi)ogging 機(jī)制的Actor，一開(kāi)始很好奇想知道這個(gè)loggingActor跟一般的有什麼不同，參考範(fàn)例如下：
仔細(xì)一看代碼line 27，有個(gè)log() method，一開(kāi)始以為是打錯(cuò)把log.info() 打成log().info()，但實(shí)際上並非如此，深入追蹤代碼一下：
原來(lái)他是以Scala trait提供預(yù)設(shè)的log函式來(lái)處理相關(guān)log，這樣你就無(wú)需自己在引入常見(jiàn)的Akka LogAdapter logger做記錄。
下一回，就來(lái)探討一下Actor 的Lifecycle in Akka framework?!
