Akka

使用scala的akka实现一个RPC通信的demo

  目前大多数的分布式架构底层通信都是通过RPC实现的,RPC框架非常多,比如前我们学过的Hadoop项目的RPC通信框架,但是Hadoop在设计之初就是为了运行长达数小时的批量而设计的,在某些极端的情况下,任务提交的延迟很高,所有Hadoop的RPC显得有些笨重,Spark 的RPC是通过Akka类库实现的,Akka用Scala语言开发,基于Actor并发模型实现,Akka具有高可靠、高性能 »

多云的Akka群集支持即将加入Akka 2.0

Spring Security的第二个RC 3.1.0 Spring Security 3.1.0的第二个候选版本已经宣布。 此RC将OpenID4Java升级到0.9.6版,并增加了对安全批注中的Enum和代理票证的标准约定的支持。 Active Directory身份验证的错误处理也得到了改进。 有关更改的更多信息,请参见Changelog 。 成为靛蓝500之一 随着Indigo »

什么是Akka?

在深入研究什么是Akka之前,让我们退后一步来了解并发编程的概念在应用程序开发世界中是如何演变的。 应用程序已经从大型的整体程序演变为面向对象的模型。 随着Java EE和Spring框架的出现,应用程序设计演变为更多的基于流程或任务的设计模型。 EJB或Pojo旨在执行一项任务。 该模型将对象提升为无状态(尽管允许状态完整会话Bean),以便能够处理不断增加的负载(又称可伸缩应用程序)。 整个 »

akka之分发和路由

一 Dispatchers 1.1 理解分发器 分发器是一个通信协调员的角色,主要负责消息的接收和传递。主要依据一定的分发策略,用于控制执行流程,然后将到来的消息或者请求路由给相关的业务进程。 提供飞机的航空公司类似于Akka的MailBox,机场跑道类似于Akka的线程资源,航空交通管制塔类似于Dispatcher   1.2 分发器的类型 1.2.1 Dispatcher 这是默认的分 »

[翻译]akka in action之akka-stream(2 流式HTTP)

2 流式HTTP 日志流处理器(log-stream processor )将以HTTP服务运行。让我们来看看这意味着什么。Akka-http 使用 akka-stream,所以从基于文件的APP到HTTP服务并不需要很多粘合代码。Akka-http 是一个非常好的例子,一个包含akka-stream的库。   首先,我们要在工程中添加更多的依赖:     这一次我们将构建LogsApp,可以从 »

Akka笔记之消息传递

英文原文链接,译文链接,原文作者:Arun Manivannan ,译者:有孚 在Akka笔记第一篇的介绍中,我们大致介绍了下Akka工具箱中的Actor。在第二篇当中,我们来看一下Actor消息传递的功能。这里还是延用之前使用的那个学生-老师的例子。 在Actor消息的第一部分中,我们会创建一个老师的Actor,但学生Actor则先不创建,而是使用一个叫做StudentSimulatorApp的 »

程序员英语学习之英文官网查看Akka(二)

程序员英语学习之英文官网查看Akka(二) 1. 背景 作为程序员,由于计算机软件本身历史原因,最新和最全的资料很多都是外网上的英文资料。部分有中文版,但受限于官网或者爱好者精力,并不会很全面和很新。 英语作为现行世界通用语言,很多国际会议、视频等都是英文版本。如果想要跟进世界最新技术,学习英语必不可少 英语能力,听说读写,对于程序员来说,最重要就是读–阅读英文能力。而这一点除了单词词汇量,其 »

Akka之actor模型

一 定义Actor import akka.actor.{Props, ActorSystem, Actor}import akka.actor.Actor.Receiveimport akka.event.Logging/** 通过扩展Actor并实现receive方法来定义Actor*/class MyActor extends Actor{     //获取LoggingAdapter,用于 »

数据处理平台架构中的SMACK组合:Spark、Mesos、Akka、Cassandra以及Kafka

在今天的文章中,我们将着重探讨如何利用SMACK(即Spark、Mesos、Akka、Cassandra以及Kafka)堆栈构建可扩展数据处理平台。虽然这套堆栈仅由数个简单部分组成,但其能够实现大量不同系统设计。除了纯粹的批量或者流处理机制之外,我们亦可借此实现复杂的Lambda以及Kappa架构。 基于Mesos技术的数人云可以快速部署和运行Spark、Akka、Cassandra以及Kafka »

akka-actor第一课

1、从akka内的系统ActorSystem得知整个代码簇中的设置从actor与之相关的ActorSystem(), 可知:ActorSystem是一个重量级结构,它将分配线程,因此请为每个逻辑应用程 »

0205gt

【图文详细 】Scala——Akka Actor

4、Akka Actor    4.1、Akka 概述  Akka 基于 Actor 模型,提供了一个用于构建可扩展的(Scalable)、弹性的(Resilient)、快 速响应的(Responsive)应用程序的平台。    Actor 模型:在计算机科学领域,Actor 模型是一个并行计算(Concurrent Computation)模型, 它把 actor 作为并行计算的基本元素来对待: »

[翻译]AKKA笔记 - ACTOR生命周期 - 基本 -5

原文地址:http://rerun.me/2014/10/21/akka-notes-actor-lifecycle-basic/ (请注意这了讨论的生命周期并不包括 preRestart 或者postRestart方法,当我们讨论supervision时候我们会说这个) 基本的Actor生命周期很直观。除了一点小不同,你可以直接拿基本Actor生命周期与Java Servlet生命周期作比较。 »

Akka源码分析-Cluster-Distributed Publish Subscribe in Cluster

  在ClusterClient源码分析中,我们知道,他是依托于“Distributed Publish Subscribe in Cluster”来实现消息的转发的,那本文就来分析一下Pub/Sub是如何实现的。   还记得之前分析Cluster源码的文章吗?其实Cluster只是把集群内各个节点的信息通过gossip协议公布出来,并把节点的信息分发出来。但各个actor的地址还是需要开发者自行 »

翻译:AKKA笔记 - 介绍Actors

任何以前做过多线程的人都不会否认管理多线程程序是困难并且痛苦的。 我说管理是因为它开始很容易而且当你看到性能提升时会很兴奋。但是,当你看到你没法从子线程的错误中恢复 或者 这些僵尸bug很难重现 或者 »

zhukunrong

B22 - 073、Akka简介

初学耗时:0.5h 注:CSDN手机端暂不支持章节内链跳转,但外链可用,更好体验还请上电脑端。 一、Akka简介 记忆词:   Akka  B22 - 999、大数据组件学习⑲ - Scala  ギ 舒适区ゾ || ♂ 累觉无爱 ♀ 一、Akka简介 Akka基于Actor模型,提供了一个用于构建可扩展的(Scalable)、弹性的(Resilient)、快速响应的(Respon »

Akka的Actor生命周期《Eight》译

  Actor在创建时出现,然后在用户请求时停止。每当一个Actor停止时,它的所有孩子也会被递归停止。此行为极大地简化了资源清理,并有助于避免资源泄漏,例如由打开的套接字和文件引起的资源泄漏。事实上,处理低级多线程代码时常常被忽视的困难是各种并发资源的生命周期管理。     要停止一个Actor,推荐的模式是在Actor内部调用getContext().stop(getSelf())来自行停止, »

【Flink系列】之 Akka和Actors

本文翻译自https://cwiki.apache.org/confluence/display/FLINK/Akka+and+actors Akka和Actors 本页讨论了Flink 0.9版本采用的Akka分布式通信的实现。有了Akka,所有的远程过程调用(RPC)被实现成异步消息。这主要影响了JobManager、TaskManager和JobClient三个组件。未来,很可能更多的组 »

Akka框架基本要点介绍

Akka基于Actor模型,提供了一个用于构建可扩展的(Scalable)、弹性的(Resilient)、快速响应的(Responsive)应用程序的平台。本文基本上是基于Akka的官方文档(版本是2.3.12),通过自己的理解,来阐述Akka提供的一些组件或概念,另外总结了Akka的一些使用场景。 Actor 维基百科这样定义Actor模型: 在计算科学领域,Actor模型是一个并行计算(Co »

简述在akka中发送消息的过程

在flink的数据传输过程中,有两类数据,一类数据是控制流数据,比如提交作业,比如连接jm,另一类数据是业务数据。flink对此采用了不同的传输机制,控制流数据的传输采用akka进行,业务类数据传输在 »

029zz010buct