Akka框架

渔民旁的松树 2014-10-02

Akka是一个用Scala编写的库，用于简化编写容错的、高可伸缩性的Java和Scala的Actor模型应用。它已经成功运用在电信行业。系统几乎不会宕机（高可用性99.9999999%一年只有31ms宕机

Actor模型并非什么新鲜事物，它由CarlHewitt于上世纪70年代早期提出，目的是为了解决分布式编程中一系列的编程问题。其特点如下：

系统中的所有事物都可以扮演一个Actor

Actor之间完全独立

在收到消息时Actor所采取的所有动作都是并行的，在一个方法中的动作没有明确的顺序

Actor由标识和当前行为描述

Actor可能被分成原始（primitive）和非原始（nonprimitive）类别

非原始Actor有

由一个邮件地址表示的标识

当前行为由一组知识（acquaintances）（实例变量或本地状态）和定义Actor在收到消息时将采取的动作组成

消息传递是非阻塞和异步的，其机制是邮件队列（mail-queue）

所有消息发送都是并行的

渔民旁的松树

渔民旁的松树

相关推荐

akka-typed(0) - typed-actor, typed messages

akka 2.6.x正式发布以来已经有好一段时间了。核心变化是typed-actor的正式启用，当然persistence,cluster等模块也有较大变化。但是，akka-cluster-sharding只能支持一种entity actor。毕竟，由于a

渔民旁的松树 / 0评论 2020-05-26

Akka 集群单例Cluster Singleton

集群中Cluster Singleton集群中有而只一个单例，可应用于集群全局调控，单一运算决策，中央命名服务或中央路由等应用场景。compile group: ‘com.typesafe.akka‘, name: ‘akka-cluster-typed_

摇摆少年梦的技术 / 0评论 2020-04-30

怎样在 Akka Persistence 中实现分页查询

　　　　EventSourcedBehavior　　　　Akka Persistence的EventSourcedBehavior里实现了CQRS模型，通过commandHandler与eventHandler解耦了命令处理与事件处理。commandHan

nobodyxiaomi / 0评论 2020-01-08

使用AKKA 构建分布式游戏服务器

一直以来，分布式服务器一直服务器开发一个比较高级的概念，实际上懂分布式的人并不多，所以今天打算分享 java的分布式游戏服务器如何实现java相对 erlang，golang 等函数式语言来说，实现分布式并不十分方便，但如果采用akka组件，则问题迎刃而解

TIGERXC / 0评论 2019-11-04

Akka in Schedulerx2.0

Schedulerx2.0是阿里中间件自研的基于akka架构的新一代分布式任务调度平台，提供定时、任务编排、分布式跑批等功能，具有高可靠、海量任务、秒级调度等能力。本篇文章以Schedulerx2.0为例子，介绍akka的应用场景，希望能给同样从事分布式系

求贤若渴礼贤下士 / 0评论 2019-09-06

Improve the Throttle for Akka(1)Local Cache

StarttheAkkaSystem,sendmessages.println("hello!"). println("huh?"). //helloActor!"hello". //helloA

摇摆少年梦的技术 / 0评论 2016-02-15

Play framework with Akka Throttle for Output

"com.typesafe.akka"%%"akka-contrib"%"2.3.13",contextIOThrottler!SetTarget(Some(contextIOActor))

jiexray / 0评论 2015-11-21

Akka简介以及入门案例

Akka 是一个用 Scala 编写的库，用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。而Akka是基于消息的Actor模型，Actor是具有属性和操作的，所有的操作都在Actor自身来完成，所以不存共享数据的问题。

jiexray / 0评论 2014-11-04

Akka(6)Remote Actor - akka-sample-remote-scala

Akka(6)Remote Actor - akka-sample-remote-scala1. Installation of AkkaDownload the akka_2.10-2.3.4.zip, put it in the working pla

nobodyxiaomi / 0评论 2014-08-12

Akka(4)Chapter 2 General - Actor System

) or stoppingSupervisor StrategyThe final piece of an actor is its strategy for handling faults of its children

摇摆少年梦的技术 / 0评论 2014-08-02

akka接地气构建一个简单分布式系统

业务需要，小组内部搭建了一个基于akka简单的分布式集群，尽量轻量级。actorRef的tell用法真的好绕，且akka的用法太灵活，同种功能，实现方式太多，导致学习成本有点大，且中文资料几乎没有，只能硬着头皮啃官方文档了，不过先看一些简单的demo，对于

摇摆少年梦的技术 / 0评论 2013-11-26

akka源码分析

看akka源码的一些体会，没有列出源码来。akka代码主要包括两块：底层分发和上层模型，从底层线程调度往上看起。函数式语言主要处理表达式求值，面向对象语言主要处理对象间消息发送消息。处理10亿级别的ForkJoin任务。ActorCell是actor的内部

jiexray / 0评论 2012-08-20

为什么用Akka

Akka提供可扩展的实时事务处理。你可以选择包括只有部分Akka包,在您的应用程序中，或者全包。Akka也提供了多种并发方式，从而为用户选择合适的规则。我们看到Akka被许多大型组织所使用，如投资和银行，零售和社会媒体，游戏和博彩，汽车和交通系统，医疗保健

nobodyxiaomi / 0评论 2012-05-19

akka是什么？

我们相信，书写正确的并发，容错和可伸缩的应用程序是比较困难。大部分时间，这是因为我们使用了错误的工具和错误的抽象水平。AKKA在这里改变这种状况。对于容错，我们采取“让它崩溃”的模式，已在电信业的巨大成功用于构建应用，自我修复，永不停止的系统。Actor也

渔民旁的松树 / 0评论 2012-05-19

Play framework 2.0 -集成AKKA

akka使用Actor模型，提高抽象层次，并提供一个更好的平台，建立正确的并发和可伸缩的应用程序。akka2.0能够在若干个被称作Actor系统的容器上工作。Actor系统管理为了运行它包含的Actors的配置资源。这个actor系统跟随应用的生命周期，当

TIGERXC / 0评论 2012-05-02

Akka单元测试

actor测试需了解scalatest，在多节点测试时，还需要使用sbt进行。scalatestscalatest是一个特别针对scala语言设计的单元测试框架，除了提供必要的基类和断言系统外，scalatest可以与IntelliJ IDEA和maven

80931836 / 0评论 2019-06-27

【Akka扩展】Akka Extensions

如果你想为 Akka 添加功能，那么有一个非常优雅且功能强大的机制。它被称为 Akka 扩展，由2个基本组件组成：Extension 和 ExtensionId。每个 ActorSystem 只能加载一次扩展，由 Akka 管理。你可以选择通过 Akka

nobodyxiaomi / 0评论 2019-06-27

AKKA浅析

AKKA 是一款基于actor模型实现的 并发处理框架。基于事件驱动的并发处理模型，每一个actor拥有自己的属性和操作，这样就避免了通常情况下因为多个线程之间要共享属性（数据）而是用锁机制的处理。这种机制在scala，cloure 语言中应用的很好，将操

TIGERXC / 0评论 2014-12-22

Akka系列（七）：Actor持久化之Akka persistence

Akka作为一款成熟的生产环境应用，为我们提供了相应的解决方案就是Akka persistence。为什么需要持久化的Actor？答案显而易见，当出现机器死机，或者内存溢出等问题时，数据很有可能就丢失了导致无法恢复。在这种背景下，我们是不是有一种比较好的解

渔民旁的松树 / 0评论 2019-06-21

Akka系列（五）：Java和Scala中的Future

随着CPU的核数的增加，异步编程模型在并发领域中的得到了越来越多的应用，由于Scala是一门函数式语言，天然的支持异步编程模型，今天主要来看一下Java和Scala中的Futrue，带你走入异步编程的大门。Future很多同学可能会有疑问，Futrue跟异

jiexray / 0评论 2019-06-21

Akka(1)Introduction

1.1WhatisAkka?1.2.WhyAkka?snip...akka-actorClassicActors,TypedActors,IOActoretc.

lrxcmwy / 0评论 2013-01-11

使用Akka Cluster Singleton实现集群单例

上篇文章主要讲了如何使用Akka作异步任务处理。最后还抛出一个问题。虽然这个方案已经可以解决问题了，但并不是最理想的。首先，现在的项目中只是用akka处理一些无状态的任务异步处理，但是将来肯定要用akka作更多的事情。因此我又继续作了一些调研，最终发现了C

TIGERXC / 0评论 2019-06-21

使用akka作异步任务处理

同步转异步是一种常见的优化手段，最近一次在做调优时便大量使用了这种方式。通常在一个业务场景中会包含多个操作，有些操作的结果需要让用户立马知道，但有些操作则不需要。这么做最直接的效果就是缩短接口响应速度，提升用户体验。最初我用的方案是Spring提供的@As

摇摆少年梦的技术 / 0评论 2019-06-21

使用ConstructR启动akka集群

一种是手动加入节点; 另一种是通过在配置中指定seed node。seed node是集群的通信节点，用来进行集群的创建和选举。需要注意，当启动第一个节点时，这个节点一定要配置在seed node第一个位置。当我们尝试引入akka cluster到项目中时

lankk的魔法书札 / 0评论 2019-06-21

如何用sbt新建akka项目

"com.typesafe.akka" %% "akka-actor" % "2.2.1","com.typesafe.akka" %% "akka-testkit&

xiaoshengyige / 0评论 2019-06-20

Akka HTTP：自定义指令（Directive）

将已有指令通过命名配置的方式来定义新的指令转换已存在的指令从头开始实现一个指令命名配置。创建自定义指令最简便的方法就是将一个或多个已有指令通过配置的方式分配一个新的名字来定义。事实上Akka HTTP预定义的大多数指令都由以较低级别指令命名配置的方式来定义

nobodyxiaomi / 0评论 2018-10-14

Akka HTTP：自定义指令（Directive）

将已有指令通过命名配置的方式来定义新的指令转换已存在的指令从头开始实现一个指令命名配置。创建自定义指令最简便的方法就是将一个或多个已有指令通过配置的方式分配一个新的名字来定义。事实上Akka HTTP预定义的大多数指令都由以较低级别指令命名配置的方式来定义

nobodyxiaomi / 0评论 2018-10-13

Akka HTTP实战：为Ant Design Pro提供后端接口

Ant Design Pro 已经是一个完整的后台前端应用，我们只需要使用 Akka HTTP 为其提供后端API接口服务支持和静态资源文件的HTTP获取功能。Akka HTTP 的 Routing DSL 是从上到下一级一级的匹配路由的，当前一个路由不匹

jiexray / 0评论 2018-10-10

Scala Web开发-Akka HTTP中使用JSON

同时，Jackson支持对大部分Java和Scala下的集合库、数据类型的JSON序列化，而大部分Scala范的JSON库只支持Scala的集合库、case class和数据类型。基于 Akka HTTP 的 marshal/unmarshal 机制，可以

渔民旁的松树 / 0评论 2018-10-09

Akka向设备组添加Actor注册《thirteen》译

我们已经完成了设备级别的注册支持，现在我们必须在组级别实现它。在注册时，小组成员还有更多工作要做，包括：。通过将注册请求转发给现有设备actor或通过创建新actor并转发消息来处理注册请求。跟踪组中存在哪些设备Actor，并在组停止时从组中删除它们。要通

TIGERXC / 0评论 2018-10-06

持久性Akka、Kafka、Cassandra实现CQRS数据同步

现有的Cassandra插件已经多次证明它是稳定的并且可以生产。不幸的是这种方案不是响应式Rective的。默认情况下Cassandra时间间隔为3秒。相比采用eventsByPersistenceId，可以使用使用eventsByTag查询被标记的事件。

wangtua / 0评论 2018-08-09

基于 Scala 和 Akka HTTP 进行响应式服务开发

Scala 基于 JVM 的的多范式编程语言，集成了面向对象和函数式编程的优点。与 Java 的良好交互性使其可以继承 Java 生态的工具和类库。同时 Scala 生态也有如 Akka、Spark 等丰富的类库，在大数据分析、机器学习等领域广泛使用。相比

摇摆少年梦的技术 / 0评论 2018-07-16

阿里p8架构师浅谈：分布式应用框架Akka详解

Akka 是一个用 Scala 编写的库，用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。使构建高并发的分布式应用更加容易。Akka在设计时采用了异步通讯和分布式架构，并对上层进行抽象，如Actors、Futures

asartear / 0评论 2019-04-14

使用Akka来优化Spark+ElasticSearch的准实时系统

假如有这样一个场景：系统每秒钟都会收到大量的事件，每个事件又包含很多参数，用户不仅需要准实时地还需要定期地判断每一种事件、事件的每一种参数值的组合是否超过了系统设定的阈值。面对这一场景，用户应该采用什么样的方案呢？最近，来自于 Premium Minds

jiexray / 0评论 2015-12-18

Akka Cluster简介与基本环境搭建

akka集群是高容错、去中心化、不存在单点故障以及不存在单点瓶颈的集群。它使用gossip协议通信以及具备故障自动检测功能。Gossip收敛集群中每一个节点被其他节点监督。根据以上陈述，当集群中某节点不可达时，gossip收敛不能完成。akka集群不存在l

宋世泊 / 0评论 2017-12-25

Akka Serialization

Akka本身使用了Protocol Buffers来序列化内部消息。Akka系统还可以配置自定义序列化机制。}默认的，在local actor之间的消息是不会序列化的。序列化所有的消息不回给性能带来提升，应当只在测试时使用。}编程式手动获取类对应的序列器。

BitTigerio / 0评论 2017-12-25

Akka（42）： Http：身份验证 - authentication, autorization and use of ra

当我们把Akka-http作为数据库数据交换工具时，数据是以Source[ROW,_]形式存放在Entity里的。很多时候除数据之外我们可能需要进行一些附加的信息传递如对数据的具体处理方式等。我们可以通过Akka-http的raw-header来实现附加自

前端外刊评论 / 0评论 2017-12-13

Akka（41）： Http：DBTable-rows streaming - 数据库表行交换

在前面一篇讨论里我们介绍了通过http进行文件的交换。在上期讨论我们提到过这种转换其实是ROW->Json->ByteString或者反方向的转换，在Akka-http里称之为Marshalling和Unmarshalling。Akka-htt

前端外刊评论 / 0评论 2017-12-12

Akka（40）： Http：Marshalling reviewed - 传输数据序列化重温

上篇我们讨论了Akka-http的文件交换。由于文件内容编码和传输线上数据表达型式皆为bytes，所以可以直接把文件内容存进HttpEntity中进行传递。高级数据类型与byte之间的相互转换就是marshalling和unmarshalling过程了。这

BitTigerio / 0评论 2017-12-06

Akka（39）： Http：File streaming-文件交换

所谓文件交换指的是Http协议中服务端和客户端之间文件的上传和下载。Akka-http作为一种系统集成工具应该具备高效率的数据交换方式包括文件交换和数据库表行的上传下载。Akka-http的数据交换模式支持流式操作：代表交换数据可以是一种无限长度流的元素。

前端外刊评论 / 0评论 2017-12-02

Akka（38）： Http：Entityof ByteString-数据传输基础

Http是个在网上传输和接收的规范协议。数据交换双方是通过Http消息类型Request和Response来实现的。这两个类型都具备HttpEntity类型来装载需要交换的数据。首先，无论如何数据在线上的表现形式肯定是一串bytes。在Akka-http里

编程语言与高级语言虚拟机杂谈仮 / 0评论 2017-11-30

Akka（11）： 分布式运算：集群-均衡负载

在上篇讨论里我们主要介绍了Akka-Cluster的基本原理。同时我们也确认了几个使用Akka-Cluster的重点：首先，Akka-Cluster集群构建与Actor编程没有直接的关联。集群构建是ActorSystem层面上的，可以是纯粹的配置和部署行为

软件设计 / 0评论 2017-07-03

Akka（8）： 分布式运算：Remoting-远程查找式

Akka是一种消息驱动运算模式，它实现跨JVM程序运算的方式是通过能跨JVM的消息系统来调动分布在不同JVM上ActorSystem中的Actor进行运算，前题是Akka的地址系统可以支持跨JVM定位。Akka的Remoting是一种点对点的跨JVM消息通

软件设计 / 0评论 2017-06-21

Spark集群 + Akka + Kafka + Scala 开发(3) : 开发一个Akka + Spark的应用

前言在Spark集群 + Akka + Kafka + Scala 开发 : 配置开发环境中，我们已经部署好了一个Spark的开发环境。在Spark集群 + Akka + Kafka + Scala 开发 : 开发一个Spark应用中，我们已经写好了一个S

编程爱好者联盟 / 0评论 2016-10-02