package com.bjsxt
import scala.actors.Actor
case class Message(actor:Actor,msg:String)
class MyActor1 extends Actor {
def act(): Unit = {
while(true){
receive {
case message:Message =>{
if(message.msg.equals("hello~")){
println("hello~")
message.actor ! "hi~"
}else if(message.msg.equals("could we have a date?")){
println("could we have a date?")
message.actor ! "no..."
}
}
case _ =>println("no match ...")
}
}
}
}
class MyActor2(actor:Actor) extends Actor {
actor ! Message(this,"hello~")
def act(): Unit = {
while(true){
receive {
case s:String =>{
if(s.equals("hi~")){
println("hi~")
actor ! Message(this,"could we have a date?")
}else if(s.equals("no...")){
println("no...")
println("。。。。。。。。。。")
}
}
case _ =>println("no match ...")
}
}
}
}
object Lesson_Actor02 {
def main(args: Array[String]): Unit = {
val actor1 = new MyActor1()
val actor2 = new MyActor2(actor1)
actor1.start()
actor2.start()
}
}
- 浏览: 70087 次
- 性别:
- 来自: 天津
文章分类
最新评论
发表评论
-
spark11
2018-06-20 15:32 01.1 Spark1 ... -
oozie
2018-06-20 15:14 171. 简述 ... -
公司hive
2018-06-20 15:08 181. 简述 Hive ... -
大数据项目
2018-05-21 23:32 0抽象出四个步骤就是 ... -
scala2
2018-04-23 22:33 347actor:哎各特scala:死噶勒trait:tree得tu ... -
scala
2018-04-23 22:44 400<!--[if !mso]> <styl ... -
scala中的wordcount
2018-04-23 22:42 376package com.bjsxt.sparkimport o ... -
hadooop
2018-04-22 23:24 562查看博客:http://blog.csdn.net/qq_2 ... -
kafka
2018-04-22 23:35 500一、Kafka简介 Kafka是一个分布式的消息队列系 ... -
zookerpeer
2018-04-22 23:35 9081. Zookeeper:攘其外必先安其内。攘其 ... -
jvm调优
2018-04-19 10:44 3131. 方法区又叫永久区,里面放的是.cl ... -
jvm调优
2018-04-19 10:55 0<!--[if !mso]> <styl ... -
jvm调优
2018-04-19 10:42 01. 方法区又叫永久区,里面放的是.cla ... -
java复习
2018-04-19 10:41 349第一:HashMap相关 1. 介绍hashs ... -
机器学习
2018-04-17 08:43 0第一:问题 1. ... -
hive
2018-04-17 08:40 283调优网站:https://www.cnblogs.com/s ... -
大数据集群搭建
2018-03-21 23:34 420NN-1 NN-2 ... -
hbase
2018-03-21 22:55 339第一:hbase介绍 1. HBase是列式存 ... -
hbase代码
2018-03-21 18:06 451package com.sxt.hbase; import ... -
hive
2018-03-21 18:17 373第一:Hive和关系型数据库的区别1.Hive将外部的任务解 ...
相关推荐
响应式架构 消息模式Actor实现与Scala.Akka应用集成 响应式架构 消息模式Actor实现与Scala.Akka应用集成
响应式架构++消息模式Actor实现与Scala.Akka应用集成+,沃恩·弗农+
消息模式Actor实现与Scala、Akka应用集成
响应式架构 消息模式Actor实现与Scala.Akka应用集成 高清扫描版
响应式架构 消息模式Actor实现与Scala.Akka应用集成 ,沃恩·弗农
2016年2月出版的《Reactive Programming with Scala and Akka》,介绍了使用scala和akka构建响应式程序的相关技术,pdf格式
Reactive Programming with Scala and Akka 英文mobi 本资源转载自网络,如有侵权,请联系上传者或csdn删除 本资源转载自网络,如有侵权,请联系上传者或csdn删除
其中包括:Actor模型和响应式软件的主要概念、Scala语言的基础知识、Akka框架与Akka集群功能、Actor模型中的通道机制和技术、降低消息源与消息目的地之间耦合性的方式、持久化Actor对象和幂等接收者。附录A中还介绍...
Harness reactive programming to build scalable and fault-tolerant distributed systems using Scala and Akka About This Book Use the concepts of reactive programming to build distributed systems ...
akka-http-microservice, 在 Scala & akka http中,编写了( 微型) 服务的示例 Akka HTTP microservice示例 这个项目演示了 Akka HTTP插件库和,以编写简单的REST ( 微型) 。 项目显示了大多数基于 Akka http的项目...
akka集群,scala函数式编程。
Akka scala 并发 actor 高清原版pdf 学习scala实现akka进行并发编程
Scala Akka项目源码
akka-rabbitmq:Scala和Akka演员中的RabbitMq客户端
用Scala写的akka actor简单demo,已经打包成SBT程序,因为上传大小限制依赖包没上传,用户安装了sbt后只需要执行update命令即可
scala-akka-study:scala-akka学习探索
scala-akka-http-lucene 使用Akka-http和Lucene在Scala中使用Rest API