AKKA实战PDF|Epub|txt|kindle电子书版本网盘下载

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 Actor17

1.7.1 ActorSystern17

1.7.2 ActorRef、邮箱和Actor18

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探索应用中的App26

2.2.1 App结构26

2.2.2处理销售的Actor： TicketSeller30

2.2.3 BoxOffice Actor31

2.2.4 RestApi32

2.3部署到云上34

2.3.1在Heroku上创建App34

2.3.2在Heroku上部署并运行35

2.4总结36

第3章Actor测试驱动开发37

3.1测试Actor37

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 crash55

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章Future71

5.1 Future的应用实例71

5.2 Future无阻塞75

5.3 Future错误处理79

5.4 Future组合82

5.5 Future组合Actor89

5.6总结90

第6章 第一个分布式Akka App91

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 Router156

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持久化Actor280

15.2.1持久化Actor281

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