文档章节

Akka系列之Routing

mOnsoOn1360
 mOnsoOn1360
发布于 2017/07/21 15:08
字数 711
阅读 9
收藏 0
点赞 0
评论 0

什么是Router

akka可以将消息发送到一个路由器(Router)中,一个Router会包含一个或多个Routee(一个Routee可以理解为一个actor), 并且通过Router的分发策略分配到不同的Routee中去执行.

示例:

Master.java

public class Master extends UntypedActor {
	
	private LoggingAdapter log = Logging.getLogger(this.context().system(), this);
	
	Router router;
	{
		List<Routee> routees = new ArrayList<Routee>();
		for (int i=0; i<5; i++) {
			ActorRef r = getContext().actorOf(Props.create(Worker.class));
			getContext().watch(r);
			routees.add(new ActorRefRoutee(r));
		}
		router = new Router(new RoundRobinRoutingLogic(), routees);
	}
	public void onReceive(Object msg) throws Throwable {
		log.info("master msg: " + msg);
		if (msg instanceof Work) {
			router.route(msg, getSender());
		}
		else if (msg instanceof Terminated) {
			router = router.removeRoutee( ((Terminated) msg).actor() );
			ActorRef r = getContext().actorOf(Props.create(Worker.class));
			getContext().watch(r);
			router = router.addRoutee(new ActorRefRoutee(r));
		}
	}
}

Work.java

public class Work implements Serializable {
	private static final long serialVersionUID = 1L;
	public final String payload;

	public Work(String payload) {
		this.payload = payload;
	}

}

RouterMain.java

public class RouterMain {

	public static void main(String[] args) {
		ActorSystem actorSystem = ActorSystem.create();
		ActorRef actor = actorSystem.actorOf(Props.create(Master.class), "master");
		actor.tell(new Work("111"), ActorRef.noSender());
		actor.tell(new Work("222"), ActorRef.noSender());
		actor.tell(new Work("333"), ActorRef.noSender());
		actor.tell(new Work("444"), ActorRef.noSender());
		actor.tell(new Work("555"), ActorRef.noSender());
		actor.tell(new Work("666"), ActorRef.noSender());
		actor.tell(new Work("777"), ActorRef.noSender());
	}
}

Worker.java

public class Worker extends UntypedActor {
	
	private LoggingAdapter log = Logging.getLogger(this.context().system(), this);

	@Override
	public void onReceive(Object o) throws Throwable {
		log.info("Worker receive msg: " + o);
		if (o instanceof Work) {
			Work w = (Work) o;
			this.getSender().tell("OK->" + w.payload, this.getSelf());
		}
	}

}

在这个例子中我们使用的是RoundRobinRoutingLogic(按顺序轮询)的策略来分发消息.

分发策略

  • akka.routing.RoundRobinRoutingLogic

轮询策略, 按顺序将message发送给routee

  • akka.routing.RandomRoutingLogic

随机策略

  • akka.routing.SmallestMailboxRoutingLogic

邮箱最小策略, 将消息发送给邮箱中message数量最小的routee

  • akka.routing.BroadcastRoutingLogic

广播策略, 所有的routee都会收到message

  • akka.routing.ScatterGatherFistCompleteRoutingLogic

广播策略, 与BroadcastRoutingLogic不同的是这个策略会收到回复消息(一个message只有一条reply)

Routee

我们可以使用ActorRefRoutee来包装一个actor来实现一个Routee, 另外我们需要watch这个actor,目的是在这个actor销毁时可以在我们Router里去掉对应的Routee

Router Actor

我们可以使用示例1的方法, 通过自定义一个actor,然后新建一个Router对象并且指定对应的RoutingLogic来实现一个路由器功能. 也可以通过以下两个方式来创建路由器:

  • Pool

通过Pool创建的routees会成为该Pool的child actor,并且routee会在它们销毁之前从router中自动的清理掉(即routeed已经被watch).

  • Group

通过Group创建的router, 它的routees需要手动创建,消息是通过actor selection的方式分发到对应的routee中, 并且routee的actor也没有被watch.

通过配置文件创建Pool

akka.actor.deployment {
  /parent/router1 {
    router = round-robin-pool
    nr-of-instances = 5
  }
}
 ActorRef router1 =
  getContext().actorOf(FromConfig.getInstance().props(Props.create(Worker.class)),
"router1");

通过代码创建Pool

 ActorRef router2 =
  getContext().actorOf(new RoundRobinPool(5).props(Props.create(Worker.class)),
"router2");

通过配置文件创建Group

akka.actor.deployment {
  /parent/router3 {
    router = round-robin-group
    routees.paths = ["/user/workers/w1", "/user/workers/w2", "/user/workers/w3"]
  }
}
   ActorRef router3 =
  getContext().actorOf(FromConfig.getInstance().props(), "router3");

通过代码方式创建Group

 ActorRef router4 =
  getContext().actorOf(new RoundRobinGroup(paths).props(), "router4");

与Pool方式不同的是, Group中的routees需要自己创建

system.actorOf(Props.create(Workers.class), "workers");

© 著作权归作者所有

共有 人打赏支持
mOnsoOn1360
粉丝 4
博文 10
码字总数 3338
作品 0
合肥
程序员
Akka v2.4.5_2.12-M4 发布,Actor 模型开发库

Akka v2.4.5_2.12-M4 发布了,Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。 本次发布值得关注的内容: The cluster client and the...

oschina ⋅ 2016/05/18 ⋅ 3

scala笔记和akka笔记

非阻塞的程序 应该保障的一些特性 : 等待无关性wait-free:能确保每次的调用在有限的步数之内完成,不管其他调用的步骤有多少。杀掉几个线程 锁无关性lock-free:执行这段程序的某些线程会被...

qingfeng哥 ⋅ 2014/07/14 ⋅ 1

Spray.io搭建Rest服务

Spray.io尝试 使用Spray.io搭建Rest服务 Spray.io搭建Rest — 支持Twirl模板并部署 Spray.io搭建Rest — 支持WebSocket 使用Spray.io搭建Rest服务 Spray 是一个开源的 REST/HTTP 工具包和底层...

ForEleven ⋅ 2014/04/28 ⋅ 10

Akka 2.5.4 和 2.4.20 发布,Actor 模型开发库

Akka 2.5.4 和 2.4.20 已发布,Akka 是一个用 Scala 编写的库,用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。 由于 Camel 的安全漏洞,akka-camel 的用户建议将 Came...

局长 ⋅ 2017/08/11 ⋅ 2

Scala 技术周刊 | 第 22 期

这里有最新的 Scala 社区动态、技术博文。 微信搜索 「scalacool」关注我们,及时获取最新资讯。 深度阅读 Status of the Collections Scala 集合重构进展 Akka 系列(十):Akka 集群之 Ak...

ScalaCool ⋅ 2017/09/22 ⋅ 0

Scala 技术周刊 | 第 24 期

这里有最新的 Scala 社区动态、技术博文。 微信搜索 「scalacool」关注我们,及时获取最新资讯。 深度阅读 Resolve me, Implicitly 依赖注入 Refined types, what are they good for? 让类型...

ScalaCool ⋅ 2017/10/23 ⋅ 0

Akka Cluster Aware Router

Cluster Aware Router Cluster aware Router相对于传统的Router区别在哪?传统的Router是相对于一个Akka System[有待进一步确认是否可以远程部署?],Cluster Aware Router是指能够识别集群的...

foucsj ⋅ 2014/02/09 ⋅ 0

Scala 技术周刊 | 第 27 期

这里有最新的 Scala 社区动态、技术博文。 微信搜索 「scalacool」关注我们,及时获取最新资讯。 深度阅读 Replacing IntelliJ with Emacs for Scala Development 用 Emacs 进行 Scala 开发 ...

ScalaCool ⋅ 2017/11/27 ⋅ 0

Actor 模型开发库 Akka 2.5.9 发布,2.4.x 生命周期结束

Akka 2.5.9 已发布,这是一个新的补丁版本,包含了一些小的修复,值得关注的 bug 修复有: 为 Artery 的 Aeron 升级至 1.7.0 #24169 集群分片的优化 #24064 和 #24191 用于 的新的顶层 prot...

局长 ⋅ 01/13 ⋅ 0

Akka 2.5.0-RC1 发布,Actor 模型开发库

Akka 2.5.0-RC1 发布了。自从 Akka 2.4.0(18 个月前)发布以来,我们已经为 2.4.x 版本系列增加了许多新功能,包括 Akka Streams 和 HTTP。但像以前一样,总会有一些变更不能在补丁版本中实...

局长 ⋅ 2017/03/18 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

RabbitMQ学习以及与Spring的集成(三)

本文介绍RabbitMQ与Spring的简单集成以及消息的发送和接收。 在RabbitMQ的Spring配置文件中,首先需要增加命名空间。 xmlns:rabbit="http://www.springframework.org/schema/rabbit" 其次是模...

onedotdot ⋅ 19分钟前 ⋅ 0

JAVA实现仿微信红包分配规则

最近过年发红包拜年成为一种新的潮流,作为程序猿对算法的好奇远远要大于对红包的好奇,这里介绍一种自己想到的一种随机红包分配策略,还请大家多多指教。 算法介绍 一、红包金额限制 对于微...

楠木楠 ⋅ 31分钟前 ⋅ 0

Python 数电表格格式化 xlutils xlwt xlrd的使用

需要安装 xlutils xlwt xlrd 格式化前 格式化后 代码 先copy读取的表格,然后按照一定的规则修改,将昵称中的学号提取出来替换昵称即可 from xlrd import open_workbookfrom xlutils.copy ...

阿豪boy ⋅ 今天 ⋅ 0

面试题:使用rand5()生成rand7()

前言 读研究生这3 年,思维与本科相比变化挺大的,这几年除了看论文、设计方案,更重要的是学会注重先思考、再实现,感觉更加成熟吧,不再像个小P孩,人年轻时总会心高气傲。有1 道面试题:给...

初雪之音 ⋅ 今天 ⋅ 0

Docker Toolbox Looks like something went wrong

Docker Toolbox 重新安装后提示错误:Looks like something went wrong in step ´Checking if machine default exists´ 控制面板-->程序与应用-->启用或关闭windows功能:找到Hyper-V,如果处......

随你疯 ⋅ 今天 ⋅ 0

Guacamole 远程桌面

本文将Apache的guacamole服务的部署和应用,http://guacamole.apache.org/doc/gug/ 该链接下有全部相关知识的英文文档,如果水平ok,可以去这里仔细查看。 一、简介 Apache Guacamole 是无客...

千里明月 ⋅ 今天 ⋅ 0

nagios 安装

Nagios简介:监控网络并排除网络故障的工具:nagios,Ntop,OpenVAS,OCS,OSSIM等开源监控工具。 可以实现对网络上的服务器进行全面的监控,包括服务(apache、mysql、ntp、ftp、disk、qmail和h...

寰宇01 ⋅ 今天 ⋅ 0

AngularDart注意事项

默认情况下创建Dart项目应出现以下列表: 有时会因为不知明的原因导致列表项缺失: 此时可以通过以下步骤解决: 1.创建项目涉及到的包:stagehand 2.执行pub global activate stagehand或pub...

scooplol ⋅ 今天 ⋅ 0

Java Web如何操作Cookie的添加修改和删除

创建Cookie对象 Cookie cookie = new Cookie("id", "1"); 修改Cookie值 cookie.setValue("2"); 设置Cookie有效期和删除Cookie cookie.setMaxAge(24*60*60); // Cookie有效时间 co......

二营长意大利炮 ⋅ 今天 ⋅ 0

【每天一个JQuery特效】淡入淡出显示或隐藏窗口

我是JQuery新手爱好者,有时间就练练代码,防止手生,争取每天一个JQuery练习,在这个博客记录下学习的笔记。 本特效主要采用fadeIn()和fadeOut()方法显示淡入淡出的显示效果显示或隐藏元...

Rhymo-Wu ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部