博客首页 → akka

最新文章列表

Akka的生命周期

首先定义一个类，继承Actorclass akka001 extends Actor{ override def preStart() ={ println("this is preStart()") } def receive = LoggingReceive{ case "hello" => println( ...
akkascala 
字母哥 评论(0) 有1166人浏览 2017-07-04 09:52

akka简单入门例子

spark版本里面用到的就是akka通信，2.0版本 已经不再使用akka了。这里写了一个简单的akka程序。 首先定义2个消息类object MyRequest { var message:String=null } object MyResponse { var message:String=null } 定义2个通信的actorclass Student(teacherRef: ...
sparkakka 
字母哥 评论(0) 有1284人浏览 2016-10-25 17:34

Storm和Akka的比较

1.【Storm】==>tuple || bolt || spout || topology Storm is a distributed, real-time computation system. On a Storm cluster, you execute topologies, which process streams of tuples (data).   Each t ...
StormAkka 
can_do 评论(0) 有1465人浏览 2015-09-21 21:46

java akka

1 需要的依赖 <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka</artifactId> <version>2.1.4</version> </dependency> < ...
akkajavaactor 
abc08010051 评论(0) 有914人浏览 2015-06-30 17:48

spark overview

1. spark vs hadoop PS:Databricks团队特别说明，为了和Hadoop对比，这次用于排序的Spark集群没有使用它们的内存缓存机制，他们也是用硬盘存储的中间结果！ http://tieba.yunxunmi.com/mtieba-hadoop-kz-58b9e430a78747f7fb1ea9f9e6374597.html 但是我们要明白，spark的目标是与ha ...
sparkhadoopnettyakkatachyon 
ghostman_yue 评论(0) 有1353人浏览 2015-06-01 13:42

spark总体概况

1. spark vs hadoop PS:Databricks团队特别说明，为了和Hadoop对比，这次用于排序的Spark集群没有使用它们的内存缓存机制，他们也是用硬盘存储的中间结果！ http://tieba.yunxunmi.com/mtieba-hadoop-kz-58b9e430a78747f7fb1ea9f9e6374597.html 但是我们要明白，spark的目标是与ha ...
nettyakkatachyonshuffle 
Stark_Summer 评论(3) 有3613人浏览 2015-05-27 14:55

试用配置管理库typesafe.config

试用配置管理库typesafe.config Typesafe的Config库，纯Java写成、零外部依赖、代码精简、功能灵活、API友好。支持Java properties、JSON、JSON超集格式HOCON以及环境变量。它也是Akka的配置管理库. Overview 纯java实现，无任何依赖 充分的测试 支持: Java properties, JSON, and a hu ...
Akka 
wbj0110 评论(0) 有1339人浏览 2015-03-10 10:38

scala akka 修炼之路6(scala函数式柯里化风格应用场景分析)

胜败兵家事不期，包羞忍耻是男儿——斗牛士fighting，fighting，fighting...       小象学习和使用scala也一段时间了，最初小象学习scala主要为了学习spark ...
Akka 
wbj0110 评论(0) 有829人浏览 2015-03-10 10:38

scala akka 修炼之路5(scala特质应用场景分析)

cala中特质定义：包含一些字段，行为(方法/函数/动作)和一些未实现的功能接口的集合，可以方便的实现扩展或混入到已有类或抽象类中。      scala中特质(trait)是一个很有用的特性，在程序设计中可以 更好的抽象现实，使程序更关注各自功能和更好的将程序拆分成多个特质模块，使程序具有更强的扩展性。熟悉java的同学，可以将特质理解为抽象类，但是scala中可以在一个类中同时混入多个特质 ...
Akka 
wbj0110 评论(0) 有1116人浏览 2015-03-10 10:38

scala akka 修炼之路3(基于java nio的socket编程)

package cn.yangg.scala.base.init   import java.io.Closeable import java.nio.channels.ServerSocketChannel import java.net.InetSocketAddress import java.nio.channels.SocketChannel import java.nio ...
Akka 
wbj0110 评论(0) 有1810人浏览 2015-03-09 11:35

scala akka 修炼之路2(文件操作)

package cn.yangg.scala.base.init   object Start { def main(args:Array[String]){   valpath="/Users/yangguo/tool/mvn.ln"   valurl="http://www.baidu.com"       readDataUseJava ...
Akka 
wbj0110 评论(0) 有821人浏览 2015-03-09 11:34

scala akka 修炼之路1(使用actor实现一个job的并发计算和task失败重启)

package cn.yangg.scala.akka.init   import akka.actor.Actor import akka.actor.Props import akka.actor.ActorRef import akka.actor.Terminated import akka.event.Logging import akka.actor.ActorSyst ...
Akka 
wbj0110 评论(0) 有992人浏览 2015-03-09 11:34

Akka学习笔记：消息传递可靠性

一般规则 关于消息发送，有两条基本规则： 最多一次，即不保证消息传递可靠性 message ordering per sender–receiver pair 消息传递机制 最多一次，意味消息有可能丢失 最少一次，保证消息传递可靠，但可能冗余 保证只成功一次，性能最差，消息成功传递，不冗余 为什么不保证传递
Akka 
wbj0110 评论(0) 有522人浏览 2015-02-28 13:52

Akka学习笔记：Akka与Java的内存模型

Akka简化了编写并发软件的过程，本文主要讨论Akka如何在并发应用中访问共享内存。 Java内存模型 Java5之前的JMM是相当混乱的。多线程访问共享内存很有可能会得奇怪的结果，如： 可见性问题，无法及时看到其他线程写入的值 指令乱序，观测到其他线程不可能的行为 从Java 5的JSR 133的实现，很多问题就解决了。JMM是基于一组"happens-before&q ...
Akka 
wbj0110 评论(0) 有648人浏览 2015-02-28 13:48

Akka学习笔记:Actor

上一节讲到actor是actor system最基本的单元。这一节详细的讲讲actor.更详细here。actor是一个拥有state,behavior,mailbox，children,supervisor strategy的容器.Akka保证所有actor都只运行在自己的轻量级线程，并一次处理一个消息，这样程序员就不用处理同步、竞态 Actor Reference 为了防止actor对象 ...
Akka 
wbj0110 评论(0) 有922人浏览 2015-02-28 13:18

Akka学习笔记：Actor Systems

  图中表示的是一个Actor System，它显示了在这个Actor System中最重要实体之间的关系。 什么是actor,是一个封装了状态和行为的对象，每个actor都通过message交流，从自己的mailbox中读取别的actor发送的消息。
Akka 
wbj0110 评论(0) 有1067人浏览 2015-02-28 12:08

Akka笔记之配置及调度

我们先看下 ActorSystem 里的方法的一个子集。 1. 配置管理 还记得前面我们用来配置日志级别的那个application.conf文件吗？它就好比Java程序里的那些.properties文件一样。马上我们会看到如何通过这个配置文件来自定义分发器以及邮箱等。（这么说好像对 typesafe config 而言不太公平。看过 
Akka 
wbj0110 评论(0) 有903人浏览 2015-02-28 09:58

spark内核揭秘-05-SparkContext核心源码解析初体验

SparkContext在获得了一系列的初始化信息后开始创建并启动TaskScheduler实例： 进入createTaskScheduler方法： 我们看一下其Standalone的方式： 在上述代码中首先实例化一个TaskSchedulerImpl： 然后构建出了masterUrls： 接着创建出关键的backend：
akkaTaskSchedulerSparkDeploySchedulerCoarseGrainedExecutorExecutor 
Stark_Summer 评论(0) 有2569人浏览 2015-01-19 15:09

并发编程之akka简介

什么是akka     akka是一个用scala编写的库，用于简化编写可容错的，可扩展的，高并发应用。akka使用actor模型来提升抽象能力，提供更好的平台来构建可扩展的，弹性的应用。对于比较难处理的错误，akka采用“let it crash”模型来处理，这种模式可以使得一个任务的处理失败不会导致整个应用的crash，使你的系统拥有强大的自愈能力，也不需要重启来恢复系统。同时akka的分 ...
javaakka并发编程 
沉沦的快乐 评论(0) 有3014人浏览 2014-12-02 19:52

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics