课程大纲

简介、环境设置和第一个应用程式

  • Akka 框架
    • 演员模型(定义和起源)
    • 容错
    • 位置透明度
    • 缩放
    • 演员 Akka
  • 设置 Scala/Maven 环境
  • Akka 中的第一次申请
    • 创建专案
    • 定义消息类
    • 定义 actor 类
    • 定义 execution 类
  • 架构和配置档

演员 & 类型化演员

  • 演员剖析
  • 建立 Actors(预设建构函数、自订构造函数、Actor 层次结构)
  • 消息传递模型
    • 发送消息
      • 即发即弃
      • 发送和接收
    • 接收消息
    • 回复消息
    • 转发消息
  • 停止角色
  • Kill Actors(杀死角色)

Fault Tolerance - 参与者生命周期和状态

  • 让它崩溃
  • 监督和监督策略
    • 一对一
    • 人人为我
  • 生命周期回调
  • 接收消息
  • 线上/离线状态
  • 热插拔:Become / Unbecome (& stash)
  • 有限状态机 FSM
    • 国家
    • 行为

并发

  • 阻塞 API 与事件驱动 API
  • 使用futures & Promise

调度员和路线

  • 调度
    • Dispatcher 作为模式
    • 执行者和调度员
    • 调度程式的类型 / 何时使用
      • 默认调度程式
      • 固定调度程式
      • CallingThread 调度程式
      • 平衡调度程式
  • 路由器
    • 路由器的类型
    • 路由器使用方式
    • 通过 application.conf 使用路由器
    • 分散式 Actor 的路由器使用方式
    • 动态调整路由器大小
    • 自定义路由器

聚类

  • 关于Akka集群和CAP定理
  • 定义集群
  • 集群成员状态
  • 将消息路由到集群
  • 寻址远端参与者

邮箱

  • 邮箱类型
  • 持久邮箱
  • 断路 器

交易 (时间允许)

测试

  • 编写单元测试
  • Access Actor 参考
  • 测试 actor 行为
  • 测试异常场景

JMX 和 REST 介面

  • RESTful API
  • JMX

要求

参加本课程不需要任何特定要求。

 21 小时

即将举行的公开课程

课程分类