文档章节

Akka路由_RoundRobinRoutingLogic

秋风醉了
 秋风醉了
发布于 2015/01/20 16:19
字数 535
阅读 303
收藏 0

Akka路由_RoundRobinRoutingLogic

使用Round Robin算法的Router,代码中有注释,基本和上篇文章中的代码一样

http://my.oschina.net/xinxingegeya/blog/369721

具体如下,关于Round Robin,请移步,http://my.oschina.net/xinxingegeya/blog/369781

下面是主要代码,

package com.usoft10;

import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.routing.ActorRefRoutee;
import akka.routing.CustomRouterConfig;
import akka.routing.RoundRobinRoutingLogic;
import akka.routing.Routee;
import akka.routing.Router;

import java.util.ArrayList;
import java.util.List;

public class BurstyMessageRouter extends CustomRouterConfig {

    private int noOfInstances;

    public BurstyMessageRouter(int inNoOfInstances) {
        noOfInstances = inNoOfInstances;
    }

    @Override
    public Router createRouter(ActorSystem system) {
        final List<Routee> routees = new ArrayList<Routee>(noOfInstances);
        for (int i = 0; i < noOfInstances; i++) {
            routees.add(new ActorRefRoutee(system.actorOf(
                    Props.create(MsgEchoActor.class), "actor-" + String.valueOf(i))));
        }
        /**
         * 使用轮询调度算法的router
         */
        return new Router(new RoundRobinRoutingLogic(), routees);
    }
}

启动router,发出消息,

package com.usoft10;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;

public class Example {
    /**
     * @param args
     */
    public static void main(String[] args) throws InterruptedException {
        ActorSystem _system = ActorSystem.create("CustomRouterExample");
        ActorRef burstyMessageRouter = _system.actorOf(Props.create(
                MsgEchoActor.class).withRouter(new BurstyMessageRouter(5)), "MsgEchoActor");

        /**
         * 在这里模拟发出10个消息,使用RoundRobinRoutingLogic的router会轮询调度每个actor接收消息
         * 也就是说每次tell,router只会选择其中一个actor进行消息的响应
         */
        for (int i = 1; i <= 10; i++) {
            //sends series of messages in a round robin way to all the actors
            burstyMessageRouter.tell("are you ready?" + String.valueOf(i), ActorRef.noSender());
        }

        Thread.sleep(2000);
        _system.shutdown();
    }

}

运行结果,

[INFO] [01/20/2015 16:08:24.668] [main] [Remoting] Starting remoting

[INFO] [01/20/2015 16:08:25.242] [main] [Remoting] Remoting started; listening on addresses :[akka.tcp://CustomRouterExample@127.0.0.1 :2552]

[INFO] [01/20/2015 16:08:25.246] [main] [Remoting] Remoting now listens on addresses: [akka.tcp://CustomRouterExample@127.0.0.1 :2552]

Received Message 'are you ready?1' in Actor akka://CustomRouterExample/user/actor-0

Received Message 'are you ready?6' in Actor akka://CustomRouterExample/user/actor-0

Received Message 'are you ready?2' in Actor akka://CustomRouterExample/user/actor-1

Received Message 'are you ready?7' in Actor akka://CustomRouterExample/user/actor-1

Received Message 'are you ready?3' in Actor akka://CustomRouterExample/user/actor-2

Received Message 'are you ready?8' in Actor akka://CustomRouterExample/user/actor-2

Received Message 'are you ready?4' in Actor akka://CustomRouterExample/user/actor-3

Received Message 'are you ready?9' in Actor akka://CustomRouterExample/user/actor-3

Received Message 'are you ready?5' in Actor akka://CustomRouterExample/user/actor-4

Received Message 'are you ready?10' in Actor akka://CustomRouterExample/user/actor-4

[INFO] [01/20/2015 16:08:27.294] [CustomRouterExample-akka.remote.default-remote-dispatcher-8] [akka.tcp://CustomRouterExample@127.0.0.1 :2552/system/remoting-terminator] Shutting down remote daemon.

[INFO] [01/20/2015 16:08:27.297] [CustomRouterExample-akka.remote.default-remote-dispatcher-8] [akka.tcp://CustomRouterExample@127.0.0.1 :2552/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[INFO] [01/20/2015 16:08:27.348] [ForkJoinPool-3-worker-7] [Remoting] Remoting shut down

[INFO] [01/20/2015 16:08:27.348] [CustomRouterExample-akka.remote.default-remote-dispatcher-7] [akka.tcp://CustomRouterExample@127.0.0.1 :2552/system/remoting-terminator] Remoting shut down.


Process finished with exit code 0

================END================

© 著作权归作者所有

共有 人打赏支持
上一篇: Scala入门
秋风醉了
粉丝 239
博文 572
码字总数 416654
作品 0
朝阳
程序员
私信 提问
Akka框架基本要点介绍

Akka基于Actor模型,提供了一个用于构建可扩展的(Scalable)、弹性的(Resilient)、快速响应的(Responsive)应用程序的平台。本文基本上是基于Akka的官方文档(版本是2.3.12),通过自己的...

东风125
2015/11/28
120
2
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
Akka路由_BroadcastRoutingLogic

Akka路由_BroadcastRoutingLogic 路由actor是将收到的消息路由到目的actor的actor. 路由acto将消息发送给它所管理的称为 ‘routees’ 的actor。 在Akka中,受Router管理的actor称作 Routee...

秋风醉了
2015/01/20
0
0
Akka实战:构建REST风格的微服务

使用Akka-Http构建REST风格的微服务,服务API应尽量遵循REST语义,数据使用JSON格式交互。在有错误发生时应返回:类似的JSON错误消息。 代码: https://github.com/yangbajing/akka-action ...

羊八井
2015/11/27
854
0
Akka HTTP实战:为Ant Design Pro提供后端接口

实战:为Ant Design Pro提供后端接口 之前章节已经了解了Akka HTTP的路由定制、数据序列化等内容,是时候开始一个比较完整的Web应用示例了。这里我们将使用 Akka HTTP 来集成 Ant Design Pro...

羊八井
10/10
0
0

没有更多内容

加载失败,请刷新页面

加载更多

idea 删除代码的注释

搜索栏使用 正则表达式搜索 (/\*([^*]|[\r\n]|(\*+([^*/]|[\r\n])))*\*+/|[ \t]*//.*) 会搜索出来所有注释的代码 用空格replace替换掉就可以了。 或者搜索 (/\*([^*]|[\r\n]|(\*+([^*/]|[\r\...

时刻在奔跑
6分钟前
0
0
eclipse maven 项目运行mvn clean 后无法运行

错误: 错误:找不到或无法加载主类com.yyy.test.Main 解决方法: “project” --"Clean" 参考链接:https://jingyan.baidu.com/article/cbcede07107d9802f40b4dff.html...

qimh
10分钟前
0
0
崛起于Springboot2.X之集成工作流Activiti5.22(42)

声明:该博客主要是Springboot1.X和Springboot2.X集成Activiti5.22版本,并说一下两个版本的搭建不同的地方 技术:Springboot2.0.3+mysql+jpa(自动生成25张表)+Activiti5.22 /然后Springboo...

木九天
21分钟前
3
1
windows环境下搭建rabbitMQ开发环境

windows环境下搭建rabbitMQ开发环境 下载与安装 erlang rabbitmq 是使用erlang语言开发的,所以需要erlang环境; 下载地址 rabbitmq 下载地址 rabbitmq与erlang版本关系 下载之后直接安装即可...

晨猫
32分钟前
1
0
JVM 中的守护线程

特点 通常由JVM启动 运行在后台处理任务,比如垃圾回收等 用户启动线程执行结束或者JVM结束时,会等待所有的非守护线程执行结束,但是不会因为守护线程的存在而影响关闭。 判断线程是否为守护...

小刀爱编程
36分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部