文档章节

Akka系列之Routing

mOnsoOn1360
 mOnsoOn1360
发布于 2017/07/21 15:08
字数 711
阅读 10
收藏 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.2K
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
615
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

没有更多内容

加载失败,请刷新页面

加载更多

CentOS 7.* 配置网络

配置静态IP 进入配置文件目录 cd /etc/sysconfig/network-scripts 查找以 ifcfg-eno 开头的文件并编辑它 vi ifcfg-ens32 修改文件中的变量值 BOOTPROTO=staticONBOOT=yesIPADDR=192.168...

阿白
43分钟前
0
0
深入理解OAuth2.0协议

1. 引言 如果你开车去酒店赴宴,你经常会苦于找不到停车位而耽误很多时间。是否有好办法可以避免这个问题呢?有的,听说有一些豪车的车主就不担心这个问题。豪车一般配备两种钥匙:主钥匙和泊...

xtof
47分钟前
1
0
Linux学习-0920

3.4 usermod命令 3.5 用户密码管理 3.6 mkpasswd命令 一、usermode命令 usermode作用是用来修改用户信息。 方法: usermod 参数 username 示例1:修改用户uid usermod -u 1010 test5 示例2...

wxy丶
57分钟前
1
0
synchronized锁对象的坑

今天本来写点其他东西,碰巧写了一下synchronized,没想到掉坑里面了,大佬别笑。 起初代码大概是这样的: package com.ripplechan.part_1_2_3;import java.util.concurrent.CountDownL...

RippleChan
今天
1
0
XAMPP环境搭建(Apache + MariaDB + PHP + Perl)

operation system:ubuntu-18.04.1 step1:download XAMPP #sudo wget https://www.apachefriends.org/xampp-files/7.2.9/xampp-linux-x64-7.2.9-0-installer.run step2:install XAMPP #sudo ......

硅谷课堂
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部