Akka實(shí)戰(zhàn)：快速構(gòu)建高可用分布式應(yīng)用

Contents 目錄
前言
第1章　認(rèn)識(shí)Akka1
1.1　Akka簡(jiǎn)介1
1.1.1　技術(shù)背景1
1.1.2　Akka是什么3
1.2　Akka應(yīng)用場(chǎng)景4
1.3　Akka架構(gòu)體系4
1.3.1　Actor模型4
1.3.2　體系結(jié)構(gòu)4
1.4　本章小結(jié)7
第2章　走進(jìn)Actor8
2.1　Actor組件8
2.1.1　Akka中的Actor8
2.1.2　ActorSystem與監(jiān)管9
2.1.3　生命周期監(jiān)控9
2.1.4　引用與路徑10
2.2　Akka環(huán)境搭建10
2.2.1　環(huán)境準(zhǔn)備11
2.2.2　使用Lightbend Activator平臺(tái)12
2.3　創(chuàng)建一個(gè)Actor14
2.3.1　定義Actor14
2.3.2　創(chuàng)建Actor實(shí)例14
2.3.3　工廠模式---Props/Creator15
2.4　發(fā)送-接收消息16
2.4.1　tell方法16
2.4.2　ask方法17
2.4.3　消息轉(zhuǎn)發(fā)18
2.5　查找一個(gè)Actor18
2.6　消息不可變21
2.7　Actor行為切換21
2.8　Actor生命周期25
2.9　停掉一個(gè)Actor26
2.10　監(jiān)督與容錯(cuò)處理29
2.11　Circuit Breaker（熔斷）33
2.12　配置相關(guān)35
2.13　本章小結(jié)36
第3章　線程調(diào)度38
3.1　什么是Dispatcher？38
3.2　Executor選擇39
3.3　配置Dispatcher39
3.4　使用Dispatcher41
3.5　PinnedDispatcher41
3.6　本章小結(jié)42
第4章　郵箱43
4.1　消息處理順序43
4.2　默認(rèn)郵箱配置44
4.3　內(nèi)置郵箱45
4.3.1　內(nèi)置郵箱說明45
4.3.2　自定義優(yōu)先級(jí)45
4.3.3　控制指令優(yōu)先48
4.4　Actor使用郵箱的多種方式49
4.4.1　配置Actor郵箱49
4.4.2　配置dispatcher郵箱49
4.4.3　實(shí)現(xiàn)RequiresMessageQueue接口50
4.5　自定義郵箱類型50
4.6　本章小結(jié)52
第5章　消息路由53
5.1　Router和Routee53
5.2　路由器及路由邏輯53
5.3　路由Actor56
5.3.1　Pool方式56
5.3.2　Group方式58
5.4　常見路由類型59
5.4.1　廣播-Broadcast60
5.4.2　快響應(yīng)-ScatterGatherFirstCompleted61
5.4.3　隨機(jī)-快響應(yīng)-TailChopping62
5.4.4　創(chuàng)建可修改容量的池62
5.5　特殊消息處理63
5.5.1　Broadcast消息64
5.5.2　PoisonPill消息64
5.5.3　其他管理類消息64
5.6　本章小結(jié)65
第6章　實(shí)用工具67
6.1　定時(shí)調(diào)度—Scheduler67
6.2　處理并發(fā)結(jié)果—Future68
6.2.1　Future常規(guī)用法68
6.2.2　函數(shù)式Future70
6.3　事件總線72
6.3.1　實(shí)現(xiàn)事件總線72
6.3.2　事件流處理74
6.4　日志處理75
6.4.1　基礎(chǔ)配置76
6.4.2　使用slf4j76
6.5　Akka擴(kuò)展78
6.5.1　TypedActor初探78
6.5.2　自定義擴(kuò)展81
6.5.3　集成Spring83
6.6　Akka I/O87
6.6.1　TCP服務(wù)87
6.6.2　UDP服務(wù)90
6.7　Akka Streams91
6.7.1　Streams組件91
6.7.2　組合Source、Sink94
6.7.3　案例：日志處理95
6.7.4　錯(cuò)誤處理99
6.7.5　關(guān)聯(lián)Actor101
6.8　本章小結(jié)102
第7章　遠(yuǎn)程103
7.1　遠(yuǎn)程介紹103
7.1.1　Java RPC103
7.1.2　Akka遠(yuǎn)程106
7.2　創(chuàng)建遠(yuǎn)程ActorSystem107
7.3　Actor遠(yuǎn)程訪問108
7.4　創(chuàng)建遠(yuǎn)程Actor109
7.5　遠(yuǎn)程路由器110
7.6　遠(yuǎn)程事件113
7.7　序列化114
7.7.1　Protobuf框架114
7.7.2　序列化API115
7.8　本章小結(jié)116
第8章　集群117
8.1　Akka集群概述117
8.1.1　種子節(jié)點(diǎn)118
8.1.2　領(lǐng)導(dǎo)節(jié)點(diǎn)118
8.1.3　節(jié)點(diǎn)狀態(tài)及生命周期118
8.1.4　故障檢測(cè)119
8.2　創(chuàng)建Akka集群119
8.2.1　代碼及集群配置119
8.2.2　啟動(dòng)集群122
8.2.3　加入集群123
8.2.4　akka-cluster集群工具123
8.3　集群示例—實(shí)現(xiàn)文章單詞統(tǒng)計(jì)125
8.3.1　示例分析125
8.3.2　代碼實(shí)現(xiàn)127
8.4　使用路由133
8.4.1　Group路由133
8.4.2　Pool路由133
8.5　集群指標(biāo)136
8.5.1　指標(biāo)收集136
8.5.2　基于指標(biāo)的負(fù)載均衡138
8.6　集群?jiǎn)卫?39
8.7　集群客戶端140
8.7.1　集群客戶端概述140
8.7.2　使用 ClusterClient141
8.7.3　事件監(jiān)聽142
8.8　集群分片143
8.8.1　分片概念143
8.8.2　持久化Actor144
8.8.3　分片示例148
8.9　本章小結(jié)155
第9章　HTTP服務(wù)156
9.1　HTTP協(xié)議156
9.1.1　header信息157
9.1.2　狀態(tài)碼159
9.2　Akka HTTP159
9.2.1　配置依賴159
9.2.2　HTTP服務(wù)端160
9.2.3　請(qǐng)求和響應(yīng)160
9.2.4　HTTP客戶端163
9.2.5　使用Routing DSL163
9.2.6　常用Directive165
9.3　Akka WebSocket166
9.3.1　WebSocket協(xié)議167
9.3.2　Akka WebSocket167
9.3.3　WebSocket應(yīng)用之聊天室169
9.4　本章小結(jié)176
第10章　微服務(wù)全家桶之Lagom177
10.1　Lagom簡(jiǎn)介177
10.2　Lagom初探178
10.3　搭建Lagom服務(wù)181
10.3.1　項(xiàng)目結(jié)構(gòu)181
10.3.2　編寫Lagom服務(wù)182
10.4　持久化實(shí)體186
10.4.1　持久化簡(jiǎn)介186
10.4.2　PersistentEntity API187
10.4.3　持久化示例187
10.4.4　MySQL支持191
10.5　Lagom部署（SandBox）192
10.5.1　安裝ConductR SandBox192
10.5.2　部署Maven項(xiàng)目195
10.6　本章小結(jié)199