频道栏目
首页 > 程序开发 > 软件开发 > 其他 > 正文
大数据系列修炼:Scala课程90
2016-10-15 09:24:57         来源:数据分析玩家  
收藏   我要投稿

核心内容:

1、基于Scala的Actor之上的分布式并发消息驱动框架Akka初体验


1、基于Scala的Actor之上的分布式并发消息驱动框架Akka初体验

1>Akka是一个用Scala编写的库,用于简化编写容错的、高可伸缩性的Java和Scala的Actor模型应用。它分为开发库和运行环境,可以用于
构建并发、分布式、可容错、事件驱动的基于Java虚拟机的应用。使构建高并发的分布式应用更加容易。
2>Akka基于的模型是Scala中的Actor模型。
3>并发的消息驱动的编程模型首选Akka
4>Spark是一个分布式的并行计算框架,主从节点在通信的时候基本上使用的都是Akka,包括客户端在提交程序的时候也会使用Akka
5>对于Akka中的Actor,每个Actor都有自己的状态和行为,即属性与方法,Actor会不断的循环自己的邮箱mailBox,来接受其余Actor
发送过来的消息。


实例程序1:复习Scala中的Actor

class A extends Actor
{
  override def act()=
  {
    for(i<- 1 to 10)
    {
       println("Step:"+i)
       Thread.sleep(2000)
    }
  }
}
class B extends Actor
{
  override def act()=
  {
    for(i<- 1 to 10)
    {
       println("StepFuther:"+i)
       Thread.sleep(2000)
    }
  }
}
object App6  
{
   def main(args:Array[String]):Unit =
   {
      val aa = new A()
      val bb = new B()
      aa.start() //start具有两层含义:向下开辟一个新的线程,并执行本线程所对应的act方法
      bb.start()
   }  
}

运行结果:

Step:1
StepFuther:1
StepFuther:2
Step:2
StepFuther:3
Step:3
Step:4
StepFuther:4
Step:5
StepFuther:5
Step:6
StepFuther:6
Step:7
StepFuther:7
Step:8
StepFuther:8
StepFuther:9
Step:9
StepFuther:10
Step:10

如有问题,欢迎留言指正!

点击复制链接 与好友分享!回本站首页
上一篇:代理模式设计只能内网访问线上数据库
下一篇:大数据系列修炼:Scala课程91
相关文章
图文推荐
点击排行

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站