AKKA实战PDF电子书下载

第1章Akka简介 1

1.1什么是Akka？ 3

1.2 Actor简介 3

1.3两种扩展方法：建立实例 4

1.4传统扩展 5

1.4.1传统扩展和持久性：一切移入数据库 5

1.4.2传统扩展和交互应用：轮询 7

1.4.3传统扩展和交互应用：Web服务 8

1.5用Akka进行扩展 9

1.5.1用Akka扩展和持久化：发送和接收消息 10

1.5.2用Akka扩展和交互应用：消息推送 11

1.5.3用Akka扩展和容错：异步解耦 12

1.5.4 Akka方式：发送和接收消息 12

1.6 Actor：向上和向外扩展的编程模型 13

1.6.1异步模型 14

1.6.2 Actor操作 15

1.7 Akka Actor 17

1.7.1 ActorSystern 17

1.7.2 ActorRef、邮箱和Actor 18

1.7.3分发器 18

1.7.4 Actor和网络 20

1.8总结 20

第2章 搭建和运行 21

2.1克隆、构建和测试接口 21

2.1.1用sbt进行构建 22

2.1.2快进到GoTicks…com REST服务器 23

2.2探索应用中的App 26

2.2.1 App结构 26

2.2.2处理销售的Actor： TicketSeller 30

2.2.3 BoxOffice Actor 31

2.2.4 RestApi 32

2.3部署到云上 34

2.3.1在Heroku上创建App 34

2.3.2在Heroku上部署并运行 35

2.4总结 36

第3章Actor测试驱动开发 37

3.1测试Actor 37

3.2单向消息 39

3.2.1 SilentActor实例 39

3.2.2 SendingActor实例 42

3.2.3 SideEffectingActor实例 46

3.3双向消息 48

3.4总结 49

第4章 容错 50

4.1容错概述 50

4.1.1普通对象与异常 52

4.1.2 Let it crash 55

4.2 Actor生命周期 58

4.2.1启动事件 58

4.2.2停止事件 58

4.2.3重启事件 59

4.2.4生命周期综合 60

4.2.5生命周期监控 62

4.3监视 63

4.3.1监视器层次结构 63

4.3.2预定义策略 65

4.3.3自定义策略 66

4.4总结 70

第5章Future 71

5.1 Future的应用实例 71

5.2 Future无阻塞 75

5.3 Future错误处理 79

5.4 Future组合 82

5.5 Future组合Actor 89

5.6总结 90

第6章 第一个分布式Akka App 91

6.1向外扩展 91

6.1.1通用网络术语 91

6.1.2采用分布式编程模型的原因 92

6.2远程扩展 93

6.2.1把GoTicks…com app改造成分布式应用 94

6.2.2远程REPL活动 95

6.2.3远程查找 98

6.2.4远程部署 104

6.2.5多JVM测试 107

6.3总结 111

第7章 配置、日志和部署 113

7.1配置 113

7.1.1尝试Akka配置 113

7.1.2使用默认值 116

7.1.3 Akka配置 117

7.1.4多系统 118

7.2日志 120

7.2.1 Akka中的日志记录 120

7.2.2使用日志 121

7.2.3 Akka的日志控制 122

7.3部署基于Actor的应用 123

7.4总结 126

第8章Actor的结构模式 127

8.1管道和过滤器 127

8.1.1企业集成模式：管道和过滤器 128

8.1.2 Akka中的管道和过滤器 128

8.2企业集成模式：分发-收集模式 131

8.2.1适用性 131

8.2.2 Akka处理并行任务 132

8.2.3使用接收者列表实现分发组件 133

8.2.4使用聚合器模式实现收集组件 134

8.2.5组合组件实现分发-收集模式 138

8.3企业集成模式：路由表模式 139

8.4总结 143

第9章 路由消息 144

9.1企业集成路由模式 144

9.2使用Akka Router实现负载平衡 145

9.2.1 Akka Router池 147

9.2.2 Akka Router群组 152

9.2.3 ConsistentHashing Router 156

9.3用Actor实现路由模式 160

9.3.1基于内容的路由 160

9.3.2基于状态的路由 160

9.3.3 Router的实现 162

9.4总结 163

第10章 消息通道 164

10.1通道类型 164

10.1.1点对点通道 165

10.1.2发布-订阅通道 165

10.2特殊通道 172

10.2.1死信 172

10.2.2保证投递 174

10.3总结 178

第11章 有限状态机和代理 179

11.1使用有限状态机 179

11.1.1有限状态机简介 179

11.1.2创建FSM模型 180

11.2 FSM模型的实现 182

11.2.1实现转换 182

11.2.2实现入口动作 185

11.2.3 FSM定时器 189

11.2.4 FSM的终止 191

11.3使用代理实现共享状态 192

11.3.1使用代理简单地共享状态 192

11.3.2等待状态更新 194

11.4总结 195

第12章 系统集成 196

12.1消息终端 196

12.1.1归一化 197

12.1.2规范数据模型 199

12.2使用Apache Camel实现终端 200

12.2.1创建从外部系统接收消息的消费者终端 201

12.2.2实现生产者向外部系统发送消息 206

12.3实现HTTP接口 209

12.3.1 HTTP实例 209

12.3.2用Akka-http实现REST终端 212

12.4总结 216

第13章流 217

13.1基本流处理 217

13.1.1使用源和接收器复制文件 221

13.1.2实体化可运行图 223

13.1.3用Flow处理事件 227

13.1.4处理流中的错误 230

13.1.5用BidiFlow创建协议 231

13.2 HTTP流 233

13.2.1接收HTTP流 233

13.2.2 HTTP响应流 235

13.2.3内容类型和协调的自定义编组与解组 235

13.3用Graph DSL进行扇入和扇出 239

13.3.1广播流 239

13.3.2合并流 241

13.4协调生产者和消费者 243

13.5图的速率隔离 246

13.5.1对较慢的消费者，对事件进行汇总 247

13.5.2快速消费者的扩展度量 247

13.6总结 248

第14章 集群 249

14.1为什么使用集群？ 249

14.2集群成员关系 251

14.2.1加入集群 252

14.2.2离开集群 257

14.3集群作业处理 261

14.3.1启动集群 264

14.3.2使用路由进行工作分配 265

14.3.3弹性作业处理 267

14.3.4测试集群 271

14.4总结 274

第15章Actor持久化 276

15.1事件提取恢复状态 277

15.1.1适时更新记录 277

15.1.2不使用update持久化状态 278

15.1.3 Actor的事件提取 279

15.2持久化Actor 280

15.2.1持久化Actor 281

15.2.2测试 283

15.2.3快照 285

15.2.4持久化查询 288

15.2.5序列化 290

15.3集群持久化 294

15.3.1单例集群 297

15.3.2分片集群 299

15.4总结 302

第16章 性能提示 304

16.1性能分析 304

16.1.1系统性能 305

16.1.2性能参数 306

16.2 Actor性能测量 307

16.2.1收集邮箱数据 308

16.2.2收集处理数据 313

16.3解决瓶颈、提高性能 314

16.4配置分发器 315

16.4.1识别线程池问题 315

16.4.2使用多个分发器实例 316

16.4.3静态调整线程池的大小 318

16.4.4使用动态线程池 320

16.5改变线程释放策略 321

16.6总结 324

第17章 展望 325

17.1 Akka-typed模块 325

17.2 Akka分布式数据 328

17.3总结 328