老版本的AKKA换成新版本会有
Exception in thread "main" java.lang.IllegalArgumentException: cannot use non-static local Creator to create actors; make it static (e.g. local to a static method) or top-level
new UntypedActorFactory() { public UntypedActor create() { return new ReduceActor(aggregateActor); } }
都是UntypedActorFactory造成的。新版已经不使用了。
可以改写成:
static class newCreator implements Creator<ReduceActor> { private static final long serialVersionUID = -1772539428749702579L; final ActorRef actorRef; public newCreator(ActorRef actorRef) { super(); this.actorRef = actorRef; } @Override public ReduceActor create() throws Exception { return new ReduceActor(actorRef); } }
这个是个例子,需要根据具体情况进行修改。
相关推荐
akka-cluster 2.53 demo,整理官网的...它提供了一套容错机制,允许在Actor出现异常时进行一些恢复或重置操作。 Akka既可以在单机上构建高并发程序,也可以在网络中构建分布式程序,并提供位置透明的Actor定位服务。
#kedev-akka-tutorial 步骤1:编写一个简单的actor-WordsCounter(标度:s1,java:j1) 演员系统演员层次和路径 ...如果actor崩溃了(I / O异常)->监督会发生什么? Akka期货 演员监控 生命周
兔一个针对Scala和Akka... 异常处理的通用模式,用于将错误发布到Airbrake,Syslog或以上所有内容模块化的与继承相比,组合更受青睐,可实现灵活且高度的代码重用。 仿照队列绑定,使用案例类建模的交换绑定对Queue和E
spring-hibernate-springdata-springmvc-maven-project-framework:此项目提供示例Hibernate实体,spring数据实体,akka actor,以减轻诸如作业,模型,存储库,服务和控制器类的邮件发送。 还有许多框架级别的类可...
java中异常的笔试题Java基础 流行的 Java 库: 常用的 Java 库 实用程序 - 集合、IO、记录器功能 分布式系统库 - 网络库有助于为各种协议(如 http、http2、套接字)设置客户端和服务器。 Akka 实现了并发的 actor ...
目录如下 Scala简介&快速入门 基础语法 变量 数据类型 流程控制 操作符重载 模式匹配 函数式编程基础 函数式编程说明 函数定义/声明 函数运行机制 递归 函数注意事项和细节 ... 惰性函数和异常 ...Akka 介绍
+ 支持不同流程调用的A/B实验,同时, 基于FlowDSL可以方便扩展一些高级的实验功能, 例如超参调优实验, 主动学习采样实验。 + **分布式执行机制** + 星盘支持flow的分布式执行,基于Akka实现了高并发和全异步的实时...
l Yarn:Hadoop2的资源管理组件,实现在多台机器上一键部署参数服务器和工作节点,实时监控各节点的运行状态,处理异常。SpeeDO提供docker镜像(只支持CPU)以方便系统的快速构建和测试,获取镜像:docker pull ...
面试高频算法、akka、多线程、NIO、Netty、SpringBoot、Spark&&Flink 等 Java是一种广泛使用的面向对象的编程语言,由Sun Microsystems公司于1995年5月正式发布。它的设计目标是“一次编写,到处运行...
Scala语言概述、运算符、程序流程控制、数据结构之集合、Map映射、过滤、化简、折叠、扫描、拉链、视图、并行集合、高阶函数、函数柯里化、偏函数、参数推断、控制抽象、Trait、面向对象编程、异常处理、惰性函数、...
机器学习应用无处不在,从自动驾驶汽车,工程设计,物流,制造和交易策略到基因异常的检测。 这本书是您的一站式指南,向您介绍Scala编程语言的功能,这些功能对于创建机器学习算法(如依赖项注入和隐式)至关重要...
它使用微服务(由akka / erlang参与者免费启发),该服务使用 a + promises(或生成器async / await)实现,以解决回调地狱问题。 您要集群化吗? 实时指标? 简单的异步编程? 完全分离的服务? 不再担心引发异常...