文档章节

Akka系列之Routing

mOnsoOn1360
 mOnsoOn1360
发布于 2017/07/21 15:08
字数 711
阅读 11
收藏 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
2.3K
3
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
763
2
Scala 技术周刊 | 第 22 期

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

ScalaCool
2017/09/22
0
0
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
0
10
Scala 技术周刊 | 第 24 期

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

ScalaCool
2017/10/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

编程价值观、原则、模式

读自《实现模式》 模式,即是针对特定问题的通用解决方案。 每个模式都承载这一点点理论,但实际编程中存在着一些更加深远的影响力,远不是孤立的模式所能概括的。 价值观是编程过程的统一支...

遥借东风
12分钟前
1
0
php分割二级域名做跳转处理方法

使用php中的全局变量 $_SERVER['HTTP_HOST'] ,可以获得用户当前访问的域名字符串,在这里面查询自己定义的各个子域名字符串,然后使用header函数重定向到不同的页面 代码如下 if( strpos($...

Mr_Azaz
13分钟前
1
0
容器之Zookeeper的使用

我们使用zookeeper时,都是在Linux上安装zookeeper,之后启动时要加入配置文件。 使用docker之后,我们可以直接使用镜像运行容器,镜像可以从docker.hub上下载,地址是https://hub.docker.co...

克虏伯
昨天
3
0
esxi 更换ssl证书

概述 就是想换一个证书而已,你可以通过下面的途径去申请一个泛解析域名的证书之后再esxi上安装上 使用阿里云域名api申请Let’s Encrypt泛域名免费ssl证书 申请完成证书之后进行下一步 操作 ...

bboysoulcn
昨天
1
0
PLC编程入门:梯形图

梯形图(LAD)是PLC编程的最佳可视化语言,它看起来非常类似于继电器电路图,因此如果 你对继电器控制和电子电路有所了解的话,那么学起来会非常容易! 在这个教程中,我们将学习关于使用梯形...

汇智网教程
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部