-
Notifications
You must be signed in to change notification settings - Fork 5
/
akka.txt
2008 lines (1983 loc) · 90.6 KB
/
akka.txt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
第10章Akka的设计理念
10.1Akka框架模型
10.2创建Actor
10.2.1通过实现akka.actor.Actor来创建Actor类
10.2.2使用非缺省构造方法创建 Actor
10.2.3创建匿名Actor
10.3Actor API
10.3.1Actor trait基本接口
10.3.2使用DeathWatch进行生命周期监控
10.3.3Hook函数的调用
10.3.4查找Actor
10.3.5消息的不可变性
10.3.6发送消息
10.3.7转发消息
10.3.8接收消息
10.3.9回应消息
10.3.10终止Actor
10.3.11Become/Unbecome
10.3.12杀死Actor
10.4不同类型的Actor
10.4.1方法派发语义
10.4.2终止有类型Actor
10.5小结
第11章Akka核心组件及核心特性剖析
11.1Dispatchers 和 Routers
11.1.1为Actor指定派发器
11.1.2派发器的类型
11.1.3邮箱
11.1.4Routers
11.1.5路由的使用
11.1.6远程部署router
11.2Supervision和Monitoring
11.2.1Supervision
11.2.2Monitoring
11.3Akka中的事务
11.3.1STM
11.3.2使用STM事务
11.3.3读取Agent事务中的数据
11.3.4更新Agent事务中的数据
11.3.5Actor中的事务
11.3.6创建Transactor
11.4小结
第12章Akka程序设计实践
12.1Akka的配置、日志及部署
12.1.1Akka中配置文件的读写
12.1.2Akka中日志配置
12.1.3Akka部署及应用场景
12.2使用Akka框架实现单词统计
12.3分布式Akka环境搭建
12.4使用Akka微内核部署应用
12.5Akka框架在Spark中的运用
Learning Akka
Credits
About the Author
Acknowledgments
About the Reviewer
www.PacktPub.com
Support files, eBooks, discount offers, and more
Why subscribe?
Free access for Packt account holders
Preface
What this book covers
What you need for this book
Who this book is for
Conventions
Reader feedback
Customer support
Downloading the example code
Downloading the color images of this book
Errata
Piracy
eBooks, discount offers, and more
Questions
1. Starting Life as an Actor
What's in this book?
Chapter overview
What is Akka
Actor Model origins
What's an Actor anyway?
Actors and Message passing
The Evolution of supervision and fault tolerance in Erlang
The Evolution of distribution and location transparency
What we will build
Example 1 – handling distributed state
Example 2 – getting lots of work done
Setting up your environment
Choosing a language
Installing Java – Oracle JDK8
Installing on Windows
Installing on OS X
Installing on Linux or Unix (Universal instructions)
Ensuring Java is configured in your environment
Installing Scala
Installing Typesafe Activator
Windows
Linux/Unix/OS X
OS X
Creating a new project
Installing an IDE
Install IntelliJ CE
Eclipse
Installing Eclipse (Scala-Ide)
Preparing the project for Eclipse
Importing the project into Eclipse
Creating your first Akka application – setting up the SBT project
Adding Akka to build.sbt
A note on getting the right Scala version with %%
Adding other Dependencies from Maven Central
Creating your first Actor
Making the Message first
Java
Scala
Defining Actor response to the Message
Java – AkkademyDb.java
Scala – AkkademyDb.scala
Validating the code with unit tests
Akka Testkit
Java
Scala
Running the test
Homework
Summary
2. Actors and Concurrency
Reactive system design
The 4 reactive tenets
Responsive
Elastic
Resilient
Event-driven/message-driven
Reactive Tenet Correlation
Anatomy of an Actor
Java Actor API
Scala Actor API
Creating an actor
Props
Promises, futures, and event-driven programming models
Blocking versus event-driven APIs
Skills check-point
Having an Actor respond via a future
Java example
Working with Scala futures
Test case
Actor creation
Scala example
Test case
Actor creation
Blocking threads in tests
Understanding futures and promises
Future – expressing failure and latency in types
Preparing for the Java example
Preparing for Scala examples
Note on sleeping
Anatomy of a future
Handling success cases
Executing code with the result
Transforming the result
Transforming the result asynchronously
Handling failure cases
Executing code in the failure case
Recovering from failure
Recovering from failure asynchronously
Composing futures
Chaining operations together
Combining futures
Dealing with lists of futures
Future cheat-sheet
Composing a Distributed System – AkkademyDb and client
Preparing the DB and messages
The messages
Implementing the DB functionality
Enabling remoting
Main
Publishing the messages
Starting the DB
Producing the client
Scaffolding the project
Modifying build.sbt
Building the client
Testing
Homework
General learning
Project homework
Summary
3. Getting the Message Across
Setting the stage with an example problem
Sketching the project
Core functionality
Messaging delivery
Messages should be immutable
Ask message pattern
Designing with Ask
Callbacks execute in another execution context
Timeouts are required
Timeout stacktraces aren't useful
Ask has overhead
Complexity of Actors and Ask
Tell
Designing with Tell
Handling replies with Tell
Scheduling a Tell Timeout
Avoiding Ask with an Anonymous Actor
Forward
Pipe
Homework
General learning
Project homework
Summary
4. Actor Lifecycle – Handling State and Failure
The 8 Fallacies of Distributed Computing
The network is reliable
Latency is zero
Bandwidth is infinite
The network is secure
Network topology doesn't change
There is one administrator
Transport cost is zero
The network is homogeneous
Failure
Isolating failure
Redundancy
Supervision
Supervision hierarchies
Supervision strategies and the drunken sushi chef
Defining supervisor strategies
Actor lifecycle
Messages in restart, stop
Terminating or killing an Actor
Lifecycle monitoring and DeathWatch
Safely restarting
State
Online/Offline state
Transitioning state
Stashing messages between states
Conditional statements
Hotswap: Become/Unbecome
Stash leaks
Finite State Machines (FSM)
Defining states
Defining the state container
Defining behavior in FSMs
Using restarts to transition through states
Homework
Summary
5. Scaling Up
Moore's law
Multicore architecture as a distribution problem
Choosing Futures or Actors for concurrency
Doing work in parallel
Doing work In parallel with futures
Doing work in parallel with Actors
Introducing Routers
Routing logic
Sending Messages to All Actors in a Router Group/Pool
Supervising the Routees in a Router Pool
Working with Dispatchers
Dispatchers explained
Executors
Creating Dispatchers
Deciding Which Dispatcher to use where
Default Dispatcher
Blocking IO dispatcher use with futures
Article parsing dispatcher
Using a configured dispatcher with Actors
Using BalancingPool/BalancingDispatcher
Optimal parallelism
Homework
Summary
6. Successfully Scaling Out – Clustering
Introducing Akka Cluster
One Giant Monolith or Many Micro Services?
Definition of a Cluster
Failure Detection
Gossiping an Eventually Consistent View
CAP Theorem
C – Consistency
A – Availability
P – Partition Tolerance
Compromises in CAP Theorem
CP System – Preferring Consistency
AP System – Preferring Availability
Consistency as a Sliding Scale
Building Systems with Akka Cluster
Creating the Cluster
Configuring the Project
Seed Nodes
Subscribing to Cluster Events
Starting the Cluster
Leaving the Cluster Gracefully
Cluster Member States
Failure Detection
Routing Messages to the Cluster
Producing a Distributed Article Parse Service
Cluster Client for Clustered Services
Setting up the Server Project
Setting up the Client Project
Sharing the Message Class between Client and Server
Sending Messages to the Cluster
Building a Distributed Key Value Store
Disclaimer – Distributed Systems are Hard
Designing the Cluster
Basic Key-Value Store Design
Coordinating Node
Sharding for Linear Scalability
Redundant Nodes
Combining Sharding and Replication
Pre-Sharding And Redistributing Keys to New Nodes
Addressing Remote Actors
Using akka.actor.Identify to Find a Remote Actor
Homework
Summary
7. Handling Mailbox Problems
Overwhelming your weakest link
Ballooning response times
Crashing
Resiliency
Mailboxes
Configuring mailboxes
Selecting a mailbox in deployment configuration
Selecting a mailbox in code
Deciding which mailbox to use
Prioritizing messages in mailboxes
Staying responsive under load
Circuit breakers
Circuit breaker listeners
Circuit breaker examples
Homework
Summary
8. Testing and Design
Example problem
Approaching application design
High-Level design
Designing, building, and testing the Domain model
Specifications
Designing the Domain model
Testing and building the Domain model
Building by specification
Testing actors
Testing Actor behavior and state
Testing Message flow
Using the test Itself as an Actor
Using TestProbes as mock Actors
Testing Advice
Homework
Summary
9. A Journey's End
Other Akka Features and Modules
Logging in Akka
Message Channels and EventBus
Agents
Akka Persistence
Akka I/O
Akka streams and HTTP
Deployment Tools
Monitoring Logs and Events
Next Steps
Writing some Actor Code
Coursera Courses
Summary
Index
第1章 认识Akka
1.1 Akka简介
1.1.1 技术背景
1.1.2 Akka是什么
1.2 Akka应用场景
1.3 Akka架构体系
1.3.1 Actor模型
1.3.2 体系结构
1.4 本章小结
第2章 走进Actor
2.1 Actor组件
2.1.1 Akka中的Actor
2.1.2 ActorSystem与监管
2.1.3 生命周期监控
2.1.4 引用与路径
2.2 Akka环境搭建
2.2.1 环境准备
2.2.2 使用Lightbend Activator平台
2.3 创建一个Actor
2.3.1 定义Actor
2.3.2 创建Actor实例
2.3.3 工厂模式——-Props/Creator
2.4 发送-接收消息
2.4.1 tell方法
2.4.2 ask方法
2.4.3 消息转发
2.5 查找一个Actor
2.6 消息不可变
2.7 Actor行为切换
2.8 Actor生命周期
2.9 停掉一个Actor
2.10 监督与容错处理
2.11 Circuit Breaker（熔断）
2.12 配置相关
2.13 本章小结
第3章 线程调度
3.1 什么是Dispatcher？
3.2 Executor选择
3.3 配置Dispatcher
3.4 使用Dispatcher
3.5 PinnedDispatcher
3.6 本章小结
第4章 邮箱
4.1 消息处理顺序
4.2 默认邮箱配置
4.3 内置邮箱
4.3.1 内置邮箱说明
4.3.2 自定义优先级
4.3.3 控制指令优先
4.4 Actor使用邮箱的多种方式
4.4.1 配置Actor邮箱
4.4.2 配置dispatcher邮箱
4.4.3 实现RequiresMessageQueue接口
4.5 自定义邮箱类型
4.6 本章小结
第5章 消息路由
5.1 Router和Routee
5.2 路由器及路由逻辑
5.3 路由Actor
5.3.1 Pool方式
5.3.2 Group方式
5.4 常见路由类型
5.4.1 广播-Broadcast
5.4.2 最快响应-ScatterGatherFirstCompleted
5.4.3 随机-最快响应-TailChopping
5.4.4 创建可修改容量的池
5.5 特殊消息处理
5.5.1 Broadcast消息
5.5.2 PoisonPill消息
5.5.3 其他管理类消息
5.6 本章小结
第6章 实用工具
6.1 定时调度-Scheduler
6.2 处理并发结果-Future
6.2.1 Future常规用法
6.2.2 函数式Future
6.3 事件总线
6.3.1 实现事件总线
6.3.2 事件流处理
6.4 日志处理
6.4.1 基础配置
6.4.2 使用slf4j
6.5 Akka扩展
6.5.1 TypedActor初探
6.5.2 自定义扩展
6.5.3 集成Spring
6.6 Akka I/O
6.6.1 TCP服务
6.6.2 UDP服务
6.7 Akka Streams
6.7.1 Streams组件
6.7.2 组合Source、Sink
6.7.3 案例：日志处理
6.7.4 错误处理
6.7.5 关联Actor
6.8 本章小结
第7章 远程
7.1 远程介绍
7.1.1 Java RPC
7.1.2 Akka远程
7.2 创建远程ActorSystem
7.3 Actor远程访问
7.4 创建远程Actor
7.5 远程路由器
7.6 远程事件
7.7 序列化
7.7.1 Protobuf框架
7.7.2 序列化API
7.8 本章小结
第8章 集群
8.1 Akka集群概述
8.1.1 种子节点
8.1.2 领导节点
8.1.3 节点状态及生命周期
8.1.4 故障检测
8.2 创建Akka集群
8.2.1 代码及集群配置
8.2.2 启动集群
8.2.3 加入集群
8.2.4 akka-cluster集群工具
8.3 集群示例-实现文章单词统计
8.3.1 示例分析
8.3.2 代码实现
8.4 使用路由
8.4.1 Group路由
8.4.2 Pool路由
8.5 集群指标
8.5.1 指标收集
8.5.2 基于指标的负载均衡
8.6 集群单例
8.7 集群客户端
8.7.1 集群客户端概述
8.7.2 使用 ClusterClient
8.7.3 事件监听
8.8 集群分片
8.8.1 分片概念
8.8.2 持久化Actor
8.8.3 分片示例
8.9 本章小结
第9章 HTTP服务
9.1 HTTP协议
9.1.1 header信息
9.1.2 状态码
9.2 Akka HTTP
9.2.1 配置依赖
9.2.2 HTTP服务端
9.2.3 请求和响应
9.2.4 HTTP客户端
9.2.5 使用Routing DSL
9.2.6 常用Directive
9.3 Akka WebSocket
9.3.1 WebSocket协议
9.3.2 Akka WebSocket
9.3.3 WebSocket应用之聊天室
9.4 本章小结
第10章 微服务全家桶之Lagom
10.1 Lagom简介
10.2 Lagom初探
10.3 搭建Lagom服务
10.3.1 项目结构
10.3.2 编写Lagom服务
10.4 持久化实体
10.4.1 持久化简介
10.4.2 PersistentEntity API
10.4.3 持久化示例
10.4.4 MySQL支持
10.5 Lagom部署（SandBox）
10.5.1 安装ConductR SandBox
10.5.2 部署Maven项目
10.6 本章小结
关于本书IV
第1章 Akka简介1
1.1 什么是Akka？3
1.2 Actor简介4
1.3 两种扩展方法：建立我们的实例4
1.4 传统扩展5
1.4.1 传统扩展和持久性：一切移入数据库6
1.4.2 传统扩展和交互应用：轮询8
1.4.3 传统扩展和交互应用：Web服务9
1.5 用Akka进行扩展10
1.5.1 用Akka扩展和持久化：发送和接收消息11
1.5.2 用Akka扩展和交互应用：消息推送13
1.5.3 用Akka扩展和容错：异步解耦14
1.5.4 Akka方式：发送和接收消息15
1.6 Actor：向上和向外扩展的编程模型16
1.6.1 异步模型16
1.6.2 Actor操作17
1.7 Akka Actor20
1.7.1 ActorSystem20
1.7.2 ActorRef、邮箱和Actor21
1.7.3 分发器21
1.7.4 Actor和网络24
1.8 总结24
第2章 搭建和运行25
2.1 克隆、构建和测试接口25
2.1.1 用sbt进行构建26
2.1.2快进到GoTicks.com REST服务器28
2.2 探索应用中的app32
2.2.1 app结构32
2.2.2 处理销售的Actor：TicketSeller39
2.2.3 BoxOffice Actor40
2.2.4 RestApi43
2.3 部署到云上46
2.3.1 在Heroku上创建app46
2.3.2 在Heroku上部署并运行48
2.4 总结49
第3章 Actor测试驱动开发50
3.1 测试Actor50
3.2 单向消息52
3.2.1 SilentActor实例52
3.2.2 SendingActor实例57
3.2.3 SideEffectingActor实例63
3.3 双向消息66
3.4 总结68
第4章 容错69
4.1 容错是什么（不是什么）？69
4.1.1 普通对象与异常70
4.1.2 Let it crash73
4.2 Actor生命周期76
4.2.1 启动事件77
4.2.2 停止事件78
4.2.3 重启事件78
4.2.4 生命周期综合80
4.2.5 生命周期监控82
4.3 监视83
4.3.1 监视器层次结构83
4.3.2 预定义策略85
4.3.3 自定义策略87
4.4 总结94
第5章 Futures95
5.1 Future的应用实例95
5.2 Future无阻塞99
5.3 Future错误处理106
5.4 Future组合111
5.5 Future组合Actor122
5.6 总结123
第6章 第一个分布式Akka app125
6.1 向外扩展125
6.1.1 通用网络术语125
6.1.2 采用分布式编程模型的原因126
6.2 远程扩展127
6.2.1 把GoTicks.com app改造成分布式应用128
6.2.2 远程REPL活动129
6.2.3 远程查找135
6.2.4 远程部署143
6.2.5 多JVM测试149
6.3 总结156
第7 章 配置、日志和部署158
7.1 配置158
7.1.1 尝试Akka配置158
7.1.2 使用默认值162
7.1.3 Akka配置165
7.1.4 多系统166
7.2 日志168
7.2.1 Akka中的日志记录168
7.2.2 使用日志170
7.2.3 Akka的日志控制171
7.3 部署基于Actor的应用173
7.4 总结178
第8章 Actor的结构模式179
8.1 管道和过滤器179
8.1.1 企业集成模式：管道和过滤器179
8.1.2 Akka中的管道和过滤器180
8.2 企业集成模式：分发-收集模式185
8.2.1 适用性185
8.2.2 Akka处理并行任务187
8.2.3 使用接收者列表实现分发组件188
8.2.4使用聚合器模式实现收集组件189
8.2.5 组合组件实现分发-收集模式198
8.3 企业集成模式：路由表模式199
8.4 总结205
第9章 路由消息207
9.1 企业集成路由模式207
9.2 使用Akka Router实现负载平衡208
9.2.1 Akka Router池211
9.2.2 Akka Router群组217
9.2.3 ConsistentHashing Router225
9.3 用Actor实现路由模式229
9.3.1 基于内容的路由229
9.3.2 基于状态的路由230
9.3.3 Router的实现233
9.4 总结234
第10章 消息通道235
10.1 通道类型235
10.1.1 点对点通道235
10.1.2 发布-订阅通道236
10.2 特殊通道245
10.2.1 死信245
10.2.2 保证投递248
10.3 总结254
第11章 有限状态机和代理256
11.1 使用有限状态机256
11.1.1 有限状态机简介256
11.1.2 创建FSM模型257
11.2 FSM模型的实现258
11.2.1 实现转换259
11.2.2 实现入口动作264
11.2.3 FSM定时器270
11.2.4 FSM的终止273
11.3 使用代理实现共享状态274
11.3.1 使用代理简单地共享状态274
11.3.2 等待状态更新276
11.4 总结277
第12章 系统集成278
12.1 消息终端278
12.1.1 归一化279
12.1.2 规范数据模型280
12.2 使用Apache Camel实现终端282
12.2.1 创建从外部系统接收消息的消费者终端283
12.2.2 实现生产者向外部系统发送消息291
12.3 实现HTTP接口297
12.3.1 HTTP实例298
12.3.2 用Akka-http实现REST终端300
12.4 总结307
第13章 流309
13.1 基本流处理309
13.1.1 使用源和接收器复制文件313
13.1.2 实体化可运行图316
13.1.3 用Flow处理事件321
13.1.4 处理流中的错误324
13.1.5 用BidiFlow创建协议326
13.2 HTTP流330
13.2.1接收HTTP流330
13.2.2 HTTP响应流333
13.2.3 内容类型和协调的自定义编组与解组334
13.3 用Graph DSL进行扇入和扇出340
13.3.1 广播流340
13.3.2 合并流343
13.4 协调生产者和消费者347
13.4.1 使用缓冲区347
13.5 图的速率隔离350
13.5.1 对较慢的消费者，对事件进行汇总351
13.5.2 快速消费者的扩展度量351
13.6 总结352
第14章 集群353
14.1 为什么使用集群？353
14.2 集群成员关系355
14.2.1 加入集群356
14.2.2 离开集群364
14.3 集群作业处理369
14.3.1 启动集群
第1章 初识Actor 1
1．1 本章概述 1
1．2 什么是Akka 1
1．2．1 Actor模型的起源 1
1．2．2 什么是Actor 2
1．2．3 Actor和消息传递 2
1．3 本书示例系统 7
1．3．1 示例1：处理分布式状态 7
1．3．2 示例2：完成更多工作 8
1．4 配置环境 8
1．4．1 选择一门语言 9
1．4．2 安装Java——Oracle JDK8 9
1．4．3 确认Java环境配置 10
1．4．4 安装Scala 10
1．4．5 安装Typesafe Activator 10
1．4．6 新建项目 11
1．4．7 安装IDE 12
1．5 创建第一个Akka应用程序——设置SBT项目 15
1．5．1 将Akka添加至build．sbt 16
1．5．2 创建第一个Actor 17
1．5．3 使用单元测试验证代码 21
1．5．4 运行测试用例 24
1．6 课后作业 25
1．7 小结 26
第2章 Actor与并发 27
2．1 响应式系统设计 27
2．2 响应式四准则 28
2．2．1 灵敏性 28
2．2．2 伸缩性 28
2．2．3 容错性 28
2．2．4 事件驱动/消息驱动 28
2．2．5 响应式准则的相关性 29
2．3 剖析Actor 29
2．3．1 Java Actor API 29
2．3．2 Scala Actor API 32
2．4 Actor的创建 33
2．5 Promise、Future和事件驱动的编程模型 36
2．5．1 阻塞与事件驱动API 36
2．5．2 使用Future进行响应的Actor 40
2．5．3 理解Future和Promise 45
2．5．4 在失败情况下执行代码 49
2．5．5 从失败中恢复 49
2．5．6 异步地从失败中恢复 50
2．5．7 链式操作 51
2．5．8 组合Future 51
2．5．9 处理Future列表 52
2．5．10 Future速查表 53
2．5．11 准备数据库与消息 54
2．5．12 编写客户端 59
2．6 课后作业 62
2．6．1 基本知识 62
2．6．2 项目作业 62
2．7 小结 63
第3章 传递消息 64
3．1 示例问题 64
3．2 消息传递 65
3．2．1 消息是不可变的 66
3．2．2 Ask消息模式 69
3．2．3 Tell 78
3．3 课后作业 88
3．4 小结 88
第4章 Actor的生命周期——处理状态与错误 90
4．1 分布式计算的8个误区 90
4．1．1 网络是可靠的 90
4．1．2 没有延迟 91
4．1．3 带宽是无限的 91
4．1．4 网络是安全的 92
4．1．5 网络拓扑不会改变 92
4．1．6 只有一个管理员 92
4．1．7 网络传输没有开销 93
4．1．8 网络是同构的 93
4．2 错误 93
4．2．1 隔离错误 94
4．2．2 监督 95
4．3 状态 102
4．3．1 在线/离线状态 103
4．3．2 条件语句 104
4．3．3 热交换（Hotswap）：Become/Unbecome 105
4．3．4 通过重启转移状态 113
4．4 课后作业 113
4．5 小结 114
第5章 纵向扩展 115
5．1 摩尔定律 115
5．2 多核架构的分布式问题 116
5．3 选择Future或Actor进行并发编程 117
5．4 并行编程 117
5．4．1 使用Future进行并行编程 118
5．4．2 使用Actor进行并行编程 119
5．5 使用Dispatcher 123
5．5．1 Dispatcher解析 123
5．5．2 Executor 124
5．5．3 创建Dispatcher 124
5．5．4 决定何时使用哪种Dispatcher 126
5．5．5 默认Dispatcher 128
5．5．6 使用Future的阻塞IO Dispatcher 130
5．5．7 用于解析文章的Dispatcher 132
5．5．8 并行最优化 135
5．6 课后作业 135
5．7 小结 136
第6章 横向扩展——集群化 137
6．1 Akka Cluster介绍 137
6．2 巨型单体应用vs微服务 137
6．3 集群的定义 138
6．3．1 失败检测 139
6．3．2 通过gossip协议达到最终一致性 139
6．4 CAP理论 140
6．4．1 C –一致性（Consistency） 140
6．4．2 A –可用性（Availability） 140
6．4．3 P –分区容错性（Partition Tolerance） 140
6．4．4 CAP理论中的妥协 141
6．5 使用Akka Cluster构建系统 143
6．5．1 创建集群 143
6．5．2 集群成员的状态 150
6．5．3 通过路由向集群发送消息 151
6．5．4 编写分布式文章解析服务 151
6．5．5 用于集群服务的集群客户端 153
6．5．6 集群设计 159
6．6 结合分区与冗余 164
6．7 远程Actor寻址 166
6．8 课后作业 167
6．9 小结 167
第7章 处理邮箱问题 169
7．1 搞垮最可能出问题的服务 169
7．1．1 响应时间变长 170
7．1．2 崩溃 171
7．2 恢复能力 171
7．3 在高负载情况下保持响应速度 175
7．4 课后作业 181
7．5 小结 182
第8章 测试与设计 183
8．1 示例问题 183
8．2 应用程序设计 184
8．3 设计、构建并测试领域模型 186
8．3．1 行为说明 186
8．3．2 设计领域模型 187
8．3．3 构建并测试领域模型 188
8．3．4 基于行为说明编写代码 190
8．4 测试Actor 192
8．4．1 测试Actor行为及状态 192
8．4．2 测试消息流 195
8．5 测试建议 198
8．6 课后作业 199
8．7 小结 200
第9章 尾声 201
9．1 其他Akka功能及模块 201
9．1．1 Akka中的日志 202
9．1．2 消息信道与EventBus 204
9．1．3 Agent 206
9．1．4 Akka Persistence 209
9．1．5 Akka I/O 210
9．1．6 Akka Streams与HTTP 210
9．2 部署工具 210
9．3 监控日志与事件 212
9．4 下一步 212
9．4．1 编写一些Actor代码 213
9．4．2 Coursera课程 213
第1 章 Actor 模型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．1
现实是最终一致的 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．1
解构Actor 模型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．3
所有的计算都在一个actor 中执行 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．4
actor 之间只能通过消息进行通信 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．5
actor 可以创建子actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．6
actor 可以改变自己的状态或行为 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．8
一切都是actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．9
Actor 模型的使用 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．10
定义清晰的边界 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 11
何时适合使用Actor 模型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．13
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．13
第2 章 Akka 简介 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．15
Akka 是什么．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 15
Akka 是开源的 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 15
Akka 正在蓬勃发展 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．16
Akka 是为分布式设计的 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．16
Akka 组件 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．17
Akka actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．17
子actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 18
remoting ：不同JVM 上的actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．20
clustering ：集群成员的自动化管理 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．20
Akka HTTP ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．24
TestKit ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 25
contrib ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 25
Akka OSGi ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 25
Akka HTTP ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．26
Akka Streams ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．26
Akka 实现的Actor 模型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．26
Actor 模型中的Akka actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．26
消息传递 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．27
actor 系统 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 28
Akka Typed 项目 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 28
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．29
第3 章 分布式领域驱动设计 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．31
DDD 概述 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．31
DDD 的好处 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．32
DDD 组件 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．33
域实体 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．34
域值对象 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．34
聚合与聚合根 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 35
仓储 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．37
工厂和对象创建 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 38
域服务 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 38
有界上下文 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．39
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．41
第4 章 优秀的Actor 设计 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．43
大系统小做 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．43
封装actor 中的状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．44
使用字段封装状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．44
使用“状态”容器封装状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．47
使用become 封装状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 48
将futures 与actors 混合 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 50
Ask 模式和替代方案 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 54
Ask 模式的问题 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 55
附带的复杂性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 57
Ask 的替代方案 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 57
命令与事件 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 59
构造函数的依赖注入 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．61
使用路径查找actor ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．61
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．62
第5 章 数据流 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．63
吞吐量与延迟 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．63
流 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．64
路由器 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．66
邮箱 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 68
无界邮箱 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 68
有界邮箱 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．69
拉取的工作模式 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．70
背压 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．73
ack ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．73
高水位标记 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．73
队列长度监控 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．74
速率监控 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．74
Akka 数据流．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．74
源 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 75
汇 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．77
RunnableGraph ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 78
流 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．79
交叉点 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 80
Akka 流中的背压 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 81
Akka 流的使用 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 82
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 84
第6 章 一致性和可扩展性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．85
事务和一致性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 85
强一致性与最终一致性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 86
并发性与并行性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 86
为什么全局一致的分布式状态影响可扩展性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 86
位置透明性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 87
交付保证 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 87
最多投递一次 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 87
最少投递一次 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 88
恰好一次交付是不可能的（但可以近似做到） ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．91
如何近似做到恰好一次交付 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．91
集群单例 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．92
可扩展性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．94
避免全局状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 98
避免共享状态 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 98
遵循Actor 模型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．99
避免顺序操作 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．99
隔离阻塞型操作 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．99
监控和调优 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．99
集群分片和一致性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．99
分片 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 100
Akka 中的分片 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 101
分片键的生成 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 102
分片的分布 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 103
一致性边界 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 103
可扩展性边界 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 104
分片聚合根 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 105
持久化 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 106
钝化 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 106
使用集群分片保证一致性 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 107
结论 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 109
第7 章 容错 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．111
故障类型 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 112
异常 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 112
JVM 中的致命错误 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 113
外部服务故障 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 113
不符合服务等级协议 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 113
操作系统和硬件级故障 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 114
故障隔离 ．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．．． 114