Akka实战

出版者:机械工业出版社

作者:Raymond Roestenburg

页数:328

译者:程继洪

出版时间:2018-12

价格:89.00元

装帧:平装

isbn号码:9787111613428

丛书系列:计算机科学先进技术译丛

具体描述

Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行库，同时提供了Scala和Java的开发接口。本书主要介绍了Akka的Actor开发模型，并行编程、消息传递、路由功能、集群、持久化等内容，还介绍了Akka的配置、系统集成和性能分析与度量等有关知识，全面介绍了Akka的主要功能，并给出了丰富的实例。

本书可作为程序员、软件工程师和架构师关于开发分布式并行应用的参考，也可以作为高等院校分布式并行开发的教材还可以作为对于分布式并行开发感兴趣的读者的入门参考书。

作者简介

Raymond Roestenburg is an experienced software craftsman, polyglot programmer, and software architect. He is an active member of the Scala community, an Akka committer, and contributed to the Akka-Camel module.

Rob Bakker is an experienced developer focused on concurrent back-end systems and system integration. He has used Scala and Akka in production from version 0.7.

Rob Williams is founder of ontometrics, a practice that has been focused on Java solutions that include machine learning. He first used Actor-based programming a decade ago, and found Akka while looking for someone who had given thought to the idea of supervision, and has used it for several projects since.

目录信息

目录
序I
译者序II
致谢III
关于本书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-https实现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 启动集群
· · · · · · (收起)

用户评价

拿到《Akka实战》这本书，我的第一反应就是它很有“分量”。这不仅仅是物理上的重量，更是知识上的厚重感。我一直对响应式编程和Actor模型抱有极大的热情，因为我相信这是未来分布式系统发展的重要方向。在我的实际工作中，我们经常面临着海量数据处理、高并发请求以及系统可用性的严峻挑战，而传统的编程模型往往显得捉襟见肘。我非常期待这本书能够深入剖析Akka框架的核心概念，例如Actor的设计哲学、消息传递的机制、状态管理的方法以及容错策略的实现。我希望能够从书中学习到如何构建一个真正意义上的高可用、可伸缩的分布式系统，并能够有效应对各种突发情况。尤其是对Akka Streams的讲解，我希望能够学习到如何高效地处理大数据流，以及它与传统消息队列在应用场景上的区别。此外，对于Akka Cluster的介绍，我也抱有很高的期望，它如何帮助我们构建一个弹性的、能够自我愈合的分布式集群，是我的关注重点。

当我翻开《Akka实战》这本书的时候，首先吸引我的是作者对于复杂概念的清晰阐述能力。我从事软件开发多年，见过不少技术书籍，但真正能够将Actor模型这种相对抽象的概念，以一种易于理解的方式讲解清楚的，并不多见。我期待这本书能够像它的名字一样，深入浅出地讲解Akka的各种实战技巧，从Actor的基本原理到Akka Streams、Akka Cluster等高级特性的应用。我一直关注着如何构建更加健壮、可扩展的分布式系统，而Akka在这方面无疑提供了强大的解决方案。我希望书中能够详细讲解Akka的容错机制，例如Supervisor Strategy的配置和使用，以及如何利用Actor的不可变性来避免并发问题。另外，对于Akka Persistence的介绍，我也非常期待，它能够如何帮助我们实现数据的持久化和状态的恢复，从而构建更具弹性的系统。我希望这本书能够为我提供一套完整的Akka开发指南，让我能够从入门到精通，并能够独立地使用Akka来解决实际工作中的复杂问题。

我一直认为，一本好的技术书籍，应该能够在我阅读的过程中，不断地引发我的思考，并在我合上书本后，能够转化为实际的行动。《Akka实战》给我带来的，正是这种感觉。我特别欣赏书中在讲解Akka的核心概念时，所使用的那些贴近实际开发场景的案例。例如，当它讲解Actor的生命周期管理时，我能够联想到我在工作中曾经遇到的那些因Actor意外终止而导致的服务中断的问题，并思考Akka是如何通过Supervisor来优雅地解决这些问题的。我期待书中能够更深入地探讨Akka的Actor模型在并发控制、状态管理以及容错方面的优势，并提供一些可复用的设计模式和最佳实践。我尤其关注书中对Akka Streams的讲解，它如何帮助我们构建高效的数据处理管道，以及它与传统的批处理和流处理方式有何不同。我希望通过阅读这本书，能够系统地掌握Akka的各项技术，并能够将其有效地应用于我的项目中，从而提升系统的性能、稳定性和可维护性。

我一直相信，学习一门技术，最好的方式就是通过实战。《Akka实战》这本书，恰恰遵循了这一原则。我拿到这本书的时候，就被其内容之丰富，案例之详实所震撼。我一直想深入理解Actor模型，以及它在Akka框架中的具体实现。在我的工作中，我们经常需要处理高并发的请求，并且对系统的可用性和稳定性有着极高的要求。我希望这本书能够为我提供一套完整的Akka开发指南，从Actor的基本概念到Akka Streams、Akka Cluster等高级特性的应用。我尤其关注书中关于Akka的容错机制的讲解，例如Supervisor Strategy的配置和使用，以及如何利用Actor的不可变性来避免并发问题。我希望能够通过阅读这本书，系统地掌握Akka的核心概念和常用组件，并能够独立地使用Akka来构建高性能、高并发的分布式系统。这本书对我而言，不仅仅是学习Akka的工具书，更是我职业生涯中一次重要的技术升级契机。

我一直觉得，学习一门新的技术，最重要的就是能否将理论与实践紧密结合。《Akka实战》这本书给我的第一印象，就是它在这方面做得非常出色。我看到书中不仅仅是枯燥的理论阐述，而是穿插了大量的代码示例，并且这些示例都非常有针对性，直接指向了Akka在实际应用中的核心功能。我尤其关注书中对于Actor生命周期管理的讲解，以及如何通过Supervisor来处理Actor的异常情况。这对于构建稳定、可伸缩的分布式应用至关重要。我一直想深入理解Akka的Actor模型是如何解决传统多线程编程中的各种痛点的，比如死锁、竞态条件等等。希望这本书能够给出清晰的解答，并且提供一些实用的模式和最佳实践。另外，对于Akka Streams的介绍，我也非常感兴趣。在处理大数据流时，Akka Streams能够提供怎样的帮助？它与RxJava等响应式编程库有何异同？这些都是我想要在书中找到答案的问题。我希望通过阅读这本书，能够系统地掌握Akka的核心概念和常用组件，并且能够独立地使用Akka来构建高性能、高并发的分布式系统。我期待这本书能够成为我手边一本常备的参考手册。

我是一个对新技术充满渴望的开发者，而Akka，以其独特的Actor模型和在构建高并发、分布式系统方面的强大能力，一直是我关注的焦点。《Akka实战》这本书，就像一块磁石，吸引着我深入探索Akka的世界。我非常期待书中能够提供一些非常实用的、可以直接应用于生产环境的代码示例。我希望能够从书中学习到如何设计出健壮、可扩展的Actor系统，并能够有效地管理Actor的生命周期和状态。我尤其关注书中关于Akka Cluster的讲解，它如何帮助我们构建一个高度可用的分布式系统，并且在节点故障时能够快速地进行恢复。另外，对于Akka Streams，我希望能够学习到如何利用它来处理海量数据流，并实现高效的数据管道。我希望这本书能够成为我学习Akka的“敲门砖”，为我打开通往更高级分布式系统开发的大门，并帮助我解决在实际工作中遇到的各种挑战。

我作为一个在分布式系统领域摸爬滚打了数年的开发者，一直对Akka这个强大的框架充满好奇。市面上关于Akka的资料不少，但真正能够系统深入地讲解其精髓，并结合实际应用场景的图书却屈指可数。《Akka实战》的出现，无疑填补了这一空白。我拿到这本书的第一感觉是，它不仅仅是一本技术手册，更像是一位经验丰富的架构师在分享他的心得和智慧。我特别期待书中关于Actor模型的核心概念的详细阐述，例如Actor的生命周期、消息传递机制、状态管理以及容错策略。我希望能够从书中学习到如何利用Akka来构建高并发、低延迟、高可用性的分布式系统，并解决实际开发中遇到的各种挑战。例如，如何通过Akka Streams来处理大数据流，如何使用Akka Cluster来构建弹性的分布式应用，以及如何通过Akka Persistence来实现状态的持久化和恢复。我希望这本书能够提供一些真实世界的案例和代码示例，让我能够快速地将学到的知识应用到我的工作中，并提升我构建分布式系统的能力。

当我开始翻阅《Akka实战》这本书的时候，最先引起我注意的是它的章节组织结构。作者似乎花了很多心思来规划内容的逻辑顺序，从最基础的概念引入，循序渐进地深入到更复杂的应用场景。我特别欣赏的是，书中在讲解某个技术点的时候，都会穿插一些实际开发的痛点和挑战，然后引出Akka是如何巧妙地解决这些问题的。这对于我这种更偏向于解决实际问题，而非纯理论研究的开发者来说，非常有吸引力。我希望能从书中看到一些非常贴近现实的代码片段，而不是那些过于抽象的伪代码。例如，在处理高并发请求时，Akka的Actor是如何避免线程安全的问题的？它又是如何通过消息传递来实现解耦和异步处理的？这些都是我在工作中经常会遇到的难题。书中对Akka的容错机制，比如Supervisor Strategy的讲解，我也非常期待。一个健壮的分布式系统，其容错能力至关重要，而Akka在这方面似乎有独特的优势。我希望书中能够详细阐述这些机制的原理，并且给出相应的配置和实现建议，让我能够真正理解并掌握如何构建一个能够自我修复、高可用性的系统。这本书的深度和广度，是我在选择技术书籍时非常看重的一点，我希望它能够提供我所需要的全方位的指导。

我拿到《Akka实战》这本书后，第一眼就被其厚重感和精美的排版所吸引。作为一个对技术细节有着极致追求的开发者，我深知一本优秀的图书不仅仅是内容的深度，更在于其呈现方式。我一直以来都对Actor模型抱有浓厚的兴趣，并认为它是构建现代分布式系统的关键技术之一。在我的工作项目中，我们经常会遇到需要处理海量并发请求，并且对系统可用性和响应速度有着极高要求的情况。而传统的同步、阻塞式编程模型，在应对这些挑战时显得力不从心。我期待这本书能够系统地介绍Akka框架，特别是其核心的Actor模型，并深入剖析其设计理念和实现原理。我希望通过这本书，能够深入理解Actor的生命周期管理、消息传递机制、状态持久化以及容错策略。我尤其关注书中对于Akka Cluster的讲解，它能够如何帮助我们构建一个高可用、可伸缩的分布式系统，并且在节点故障时如何保证服务的连续性。我希望书中能够提供丰富的代码示例，让我能够将学到的知识快速地应用于实际项目中，并解决工作中遇到的实际问题。

刚拿到这本《Akka实战》的时候，我确实被它的封面设计吸引了。那种略带复古的工业风，配合上沉稳的字体，一下子就勾起了我对技术探索的兴趣。我是一名在分布式系统领域摸爬滚打了几年，但一直觉得自己在某些底层原理上有所欠缺的开发者。市面上关于并发、分布式系统的好书不少，但真正能做到深入浅出，并且结合实际案例讲解的却不多。我一直很想深入理解Actor模型，以及它在Akka框架中的具体应用，因为我工作中的项目正面临着高并发、低延迟的需求，而传统的线程模型已经显得力不从心。我期待这本书能够像它的名字一样，不仅仅是理论的堆砌，更能提供切实可行的解决方案和代码示例，让我能够快速地将学到的知识应用到实际工作中。我尤其关心书中对于Akka Streams的部分，它能如何帮助我们处理海量数据流，以及它与传统消息队列的比较。另外，对于Akka Cluster的介绍，我也充满了期待，毕竟构建稳定、可扩展的分布式系统是每个资深开发者都绕不开的课题。希望这本书能够解答我在Actor模型、消息传递、状态管理、容错机制等方面的困惑，并且能够带领我领略Akka在不同场景下的魅力。我希望能从中学到如何设计出更健壮、更具弹性的系统，从而提升项目的整体性能和稳定性。这本书对我而言，不仅仅是学习Akka的工具书，更是我职业生涯中一次重要的技术升级契机。