Akka

Akka系列(二):Akka中的Actor系统

  前言......... Actor模型作为Akka中最核心的概念,所以Actor在Akka中的组织结构是至关重要,本文主要介绍Akka中Actor系统。 1.Actor系统 Actor作为一种封装状态和行为的对象,总是需要一个系统去统一的组织和管理它们,在Akka中即为ActorSystem,其实这非常容易理解,好比一个公司,每个员工都可以看成一个Actor,它们有自己的职位和职责,但是我们需 »

akka pubsub example

测了一个小时的 Pubsub 模式,发现这个模式和自己预期的不太一样,具体表现在: 1. 当 subscriber 订阅了某个 topic 并附带 groupName 时,如果 publish 发布的消息只含有 topic 而没有 groupName,那么该 subscriber 不会收到消息。而按照 doc 的说法每个 groupName 下的 actor 会收到一个消息。通过修改配置文件,决定 »

AKKA HTTP 简单示例

AKKA HTTP 简单示例   依赖包: compile("com.typesafe.akka:akka-http_2.13:10.1.8") compile("com.typesafe.akka:akka-stream_2.13:2.5.23")   代码示例:   package http import akka.actor.ActorSystem import ak »

Akka官方文档翻译:Cluster Specification

参加了CSDN的一个翻译项目,翻译Akka的文档。CSDN提供的翻译系统不好使,故先排版一下放在博客上。 注意:本文档介绍了集群的设计理念。它分成两部分,第一部分描述了当前已经实现的部分,第二部分描述了未来要增强/增加的部分。对未现部分的引用被用脚注[*]标出。 5.1.1 目前的集群 简介     Akka集群提供了一个容错的、去中心化的、基于点对于点的集群成员关系服务,没有单点故障,也没 »

flink RPC(akka)

  flink中的rpc框架使用的akka。在本节并不详细讲述akka,而是就flink中rpc来讲述akka的部分内容。本节,我从AkkaRpcActor.handleRpcInvocation方法讲起。   看过hadoop、yarn、hive、hbase、presto的rpc框架,感觉flink的通信框架是最容易让人绕晕的。虽然之前也看过一点spark中akka的通信,但现在早已忘得一干二净 »

Akka Stream文档翻译:Motivation

    Motivation The way we consume services from the internet today includes many instances of streaming data, both down- loading from a service as well as uploading to it or peer-to-peer data tra »

Scala 中使用 akka system 的 scheduler 的例子

这是在scala控制台直接执行的例子。   import akka.actor._ import scala.concurrent.duration._ import scala.concurrent.Future val system = ActorSystem("mySystem") import system.dispatcher Future { var i:Int=0 »

Akka 和 μJavaActors入门

     Akka和μJavaActorsμJavaActors均是java的Actor库,其中Akka提供了叫为完整的Actor开发框架,较为庞大,学习成本很高,μJavaActors 是一个轻量级Actor库,大约仅有1200行代码,比较适合入门。 一.Akka Demo  Akka是一个相当成熟、强大的库,github上download下的是Akka的源码,应该使用sbt构建的工程,如 »

[翻译]AKKA笔记 - DEATHWATCH -7

当我们说Actor生命周期的时候,我们能看到Actor能被很多种方式停掉(用ActorSystem.stop或ActorContext.stop或发送一个PoisonPill - 也有一个kill和gracefulstop)。 无论Actor是怎么死的,有些情况一些系统中的其他actor想要知道。让我们举一个Actor与数据库交互的例子 - 我们叫它RepositoryActor。很明显,会有一些 »

(转)Akka学习笔记

Akka学习笔记系列文章:  《Akka学习笔记:ACTORS介绍》  《Akka学习笔记:Actor消息传递(1)》  《Akka学习笔记:Actor消息传递(2)》    《Akka学习笔记:日志》  《Akka学习笔记:测试Actors》  《Akka学习笔记:Actor消息处理-请求和响应(1) 》  《Akka学习笔记:Actor消息处理-请求和响应(2) 》  《Akka学习笔记:Ac »

alpakka-kafka(10)-用kafka实现分布式近实时交易

随着网上购物消费模式热度的不断提高,网上销售平台上各种促销手段也层出不穷,其中“秒购”已经是各种网站普遍流行的促销方式了。“秒购”对数据的实效性和精确性要求非常高,所以通过分布式运算实现高并发数据处理应该是正确的选择。不过,高并发也意味着高频率的数据操作冲突,而高频使用“锁”又会严重影响效率及容易造 ... »

使用AKKA做分布式爬虫的思路

上周公司其它小组在讨论做分布式爬虫,我也思考了一下。提了一个方案,就是使用akka分布式rpc框架来做,自己写master和worker程序,client向master提交begin任务或者其它爬虫需求,master让worker去爬网页,worker都是kafka的同一个group然后从kafka里面拉取数据(URL),然后处理爬了的网页,解析内容,把爬下来的网页通过正則表達式匹配出嵌套的网页, »

Akka之BackoffSupervisor

一、背景 最近在开发一个项目,项目的各模块之间是使用akka grpc传输音频帧的,并且各模块中的actor分别都进行了persist。本周在开发过程中遇到了一个bug,就是音频帧在通行一段时间后,整个系统处于卡死状态,没有了反应。刚开始怀疑是akka grpc通信时,流中断了,或者没有传输过来,可是通过抓包和日志,发现流的每一帧已经接受到了。最后定位到问题时persist的原因,每次卡死之间都可 »

AKKA文档2.3(java版)—什么是角色

  原文: http://doc.akka.io/docs/akka/2.3.5/general/actors.html 译者:Vitas 什么是角色? 前面角色系统一节介绍了一群角色如何形成一个层次结构,并且介绍了角色是构建应用程序的最小单位。本节我们将角色拿出来单独介绍,解释一些你在使用它的过程中可能遇到的概念。对于一些更深入的细节,将会在后面的章节中详细介绍。你可以将角色想象成一个容器,它 »

AKKA 笔记 - 有限状态机 -2

原文地址: http://rerun.me/2016/05/22/akka-notes-finite-state-machines-2/ 在上一节的Akka FSM笔记中,我们看了一些基本的使用Akka FSM和咖啡机的使用方式 - Actor的数据结构和一队我们要发给Actor的消息。这次的第二部分也是最终部分,我们会过一遍这些状态的实现细节。 总结 作为一个快速的总结,让我们先看一下FMS的 »

Scala学习笔记--Akka

待完成  http://www.gtan.com/akka_doc/ http://my.oschina.net/mingdong/blog/297972   http://www.jdon.com/concurrent/akka/tutorial.html http://ju.outofmemory.cn/entry/69776 »

一步一步来熟悉Akka.Net(一)

标签(空格分隔): .netcore 分布式 一、不利flag   好久没写过文章了,翻开前几年写的博客,看到有两个目标“代码生成器”和“文件隐身”。说起来并不是太难的东西,难产到现在还没有出来。还有之前定的学习计划--先学习spring boot,再熟悉spring cloud,再这些基础上,再去.net环境上去寻找完善更适合的解决方案。不过学完spring boot以后,由于一些原因clo »

akka模块

模块 Akka的模块化做得非常好,它为不同的功能提供了不同的Jar包。 akka-actor-2.0.jar – 标准Actor, 有类型Actor,等等 akka-remote-2.0.jar – 远程Actor akka-slf4j-2.0.jar – SLF4J事件处理监听器 akka-testkit-2.0.jar – 用于测试Actor的工具包 akka-kernel-2.0 »

Akka系列(九):Akka分布式之Akka Remote

  前言.... Akka作为一个天生用于构建分布式应用的工具,当然提供了用于分布式组件即Akka Remote,那么我们就来看看如何用Akka Remote以及Akka Serialization来构建分布式应用。 背景 很多同学在程序的开发中都会遇到一个问题,当业务需求变得越来越复杂,单机服务器已经不足以承载相应的请求的时候,我们都会考虑将服务部署到不同的服务器上,但服务器之间可能需要相互调用 »

Akka - Basis for Distributed Computing

Some concepts as blow:   Welcome to Akka, a set of open-source libraries for designing scalable, resilient systems that span processor cores and networks. Akka allows you to focus on meeting busines »