在Akka中实现主从/网格计算模式

主从模式是容错和并行计算的主要示例。 模式背后的想法是将工作划分为相同的子任务,然后将其委派给从属。 这些从节点或实例将处理工作任务,并将结果发送回主节点。 然后主节点将编译从所有从节点接收到的结果。关键是从节点仅知道如何处理任务,而不知道输出会发生什么。

主从模式类似于网格计算模式,其中控制节点将工作分配给其他节点。 想法是利用网络上的节点进行计算。 SETI @ Home是使用此模型的最早的先驱之一。

我建立了一个类似的示例,不同之处在于工作节点在远程节点上启动,工作节点向Master(WorkServer)注册,然后随后开始处理工作包。 如果没有在Master(WorkServer)上注册的工人从属服务器,则主服务器将等待工人进行注册。 工人可以随时注册,并从那里开始获取工作包。

该示例演示了WorkerActor系统如何发送注册请求。 RegisterRemoteWorker接收该请求,并将其转发到JobController,在此更新RoundRobinRouter以获得新的工作程序信息。 WorkScheduler定期向JobController发送请求,JobController然后将数据包发送给所有注册的工作人员。

对于远程角色死后如何处理故障或如何重新处理尚未处理的数据包,该示例未实现容错功能。 同样,在某些情况下,远程工作人员可能希望在处理一定数量的数据包后关闭,然后他们可以指示主机停止给他们工作。 我将尽快添加容错功能!

更新 :更新了代码库以处理工作程序关闭。 如果远程角色死掉或关闭,则JobController使用远程角色侦听器检测到故障转移,并更新路由器。

本方案的代码库可在以下位置- https://github.com/write2munish/Akka-Essentials的GridPatternExample下

参考:来自Akka Essentials博客的JCG合作伙伴 Munish K Gupta在Akka中 实现了主从/网格计算模式 。


翻译自: https://www.javacodegeeks.com/2012/05/implementing-master-slave-grid.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/372329.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java学习笔记总略

二、正文(一)Java1.接口和抽象类的区别①抽象类里可以有构造方法,而接口内不能有构造方法。②抽象类中可以有普通成员变量,而接口中不能有普通成员变量。③抽象类中可以包含非抽象的普通方法,而接口中所有的方法必须是…

react实现路由跳转_react实现hash路由

众所周知,目前单页面使用的路由有两种实现方式:hash 模式history 模式hash 模式路由原理:我们先来看hash模式,页面首次加载时需要在load事件中解析初始的URL,从而展示进入的页面。当 # 后面的哈希值发生变化时&#xf…

Java中的Google协议缓冲区

总览 协议缓冲区是一种用于结构化数据的开源编码机制。 它是由Google开发的,旨在实现语言/平台中立且可扩展。 在本文中,我的目的是介绍Java平台上下文中协议缓冲区的基本用法。 Protobuff比XML更快,更简单,并且比JSON更紧凑。 当…

匈牙利哦模板 二分匹配 完全匹配问题

匈牙利算法的核心思想就是 腾空间, 有条件 创造,没条件也要创造! bool find(int x){int i,j;for (j1;j<m;j){ //扫描每个被匹配的人 if (line[x][j]true && used[j]false) //如果有关系并且还没有标记过(这里标记的意思是这次查找曾试图改变过的归属问题&a…

ThinkPHP 中验证码的看不清切换

<!--HTML页面--> <!DOCTYPE html><html><head> <title></title></head><body><script type"text/javascript" src"__PUBLIC__/js/jquery-1.8.2.min.js"></script><form action"{:U(H…

mysql从表截取信息_mysql中循环截取用户信息并插入到目标表对应的字段中

操作环境&#xff1a;有表game_list&#xff0c;字段&#xff1a;uid&#xff0c;score1&#xff0c;score2&#xff0c;seat_id&#xff0c;last_update&#xff1b;传入参数为i_player_detail &#xff0c;传入的值为多个用户的id、之前分数、之后分数、座位号&#xff0c;每…

Java中的数组,列表,集合,映射,元组,记录文字

有时&#xff0c;当我对JavaScript的强大功能和表现力感到兴奋时&#xff0c;我发现自己错过了Java世界中的一两个功能。 除了lambda表达式/闭包或任何您想称为“匿名函数”的东西之外&#xff0c;它还对数组&#xff0c;数组&#xff0c;列表&#xff0c;集合&#xff0c;映射…

mysql锁表问题的解决方法_MYSQL锁表问题的解决方法

本文实例讲述了MYSQL锁表问题的解决方法。分享给大家供大家参考&#xff0c;具体如下&#xff1a;很多时候&#xff01;一不小心就锁表&#xff01;这里讲解决锁表终极方法&#xff01;案例一mysql>show processlist;参看sql语句一般少的话mysql>kill thread_id;就可以解…

linux——(1)初识linux

linux有窗口管理员环境和纯文本界面环境&#xff0c;同时linux默认提供6个Terminal来让用户登录。crtlaltF1-6可自由切换。其中如果窗口管理员环境处于运行状态&#xff0c;那么可以按crtlaltF7直接切过去。 常用命令&#xff1a; cd [dir] #进入dir目录下 ls #列出当前目录下的…

4.26学习成果

哇&#xff0c;今天终于开始接触Web了&#xff0c;感觉有点小兴奋&#xff0c;这几天看来那个视频感觉挺有趣的&#xff0c;挺奇妙的。看到人家敲代码&#xff0c;感觉好厉害。但是感觉不懂&#xff0c;所以&#xff0c;要努力学习了。 今天的学习成果&#xff1a; 网页由什么组…

将Glassfish 3连接到外部ActiveMQ 5代理

介绍 在ONVZ&#xff0c;我们将Glassfish 3用作开发和生产应用服务器&#xff0c;我们对其性能和稳定性以及周围的广大社区感到非常满意。 我很少遇到在stackoverflow或java.net上没有匹配解决方案的问题。 作为我们开源策略的一部分&#xff0c;我们还运行了一个定制的ActiveM…

esp8266 lcd 天气_ESP8266 显示实时天气信息

代码文件getdata.h#include #include #include #include #include #include #include #define DEBUG 1#define MAX_CONTENT_SIZE 2000const char* ssid "weather";const char* password "mymymymy";WiFiClient client;HTTPClient http;char response[MAX…

【VS开发】visual studio 2015的NuGet Manager解决方案管理功能

NuGet的官方说明是&#xff1a;NuGet是一款Visual Studio的扩展&#xff0c;它可以简单的安装、升级开源库和工具。 官网地址&#xff1a;http://www.nuget.org/ 官网最醒目的位置就是下载链接&#xff0c;安装完成后我们来快速体验一把。 手上有个小项目需要使用到json格式&am…

五. 面向对象高级特性4. 接口的概念和使用

在抽象类中&#xff0c;可以包含一个或多个抽象方法&#xff1b;但在接口(interface)中&#xff0c;所有的方法必须都是抽象的&#xff0c;不能有方法体&#xff0c;它比抽象类更加“抽象”。接口使用 interface 关键字来声明&#xff0c;可以看做是一种特殊的抽象类&#xff0…

智能配料

我们都有多少次听说“分批处理”会增加延迟&#xff1f; 作为对低延迟系统充满热情的人&#xff0c;这让我感到惊讶。 以我的经验&#xff0c;正确完成批处理不仅可以提高吞吐量&#xff0c;还可以减少平均延迟并保持一致。 那么&#xff0c;批处理如何神奇地减少延迟呢&#x…

mysql从myisam_将MySQL从MyISAM转换成InnoDB错误和解决办法

原来自己用的是为了装的&#xff0c; 所以在设置database usage(如下图1)的时候按照discuz官方的建议&#xff0c;选的都是Non-Transactional Database Only(只支持MyISAM数据引擎的非事务数据库)&#xff0c;用MyISAM数据库&#xff0c;还没涉及到需要InnoDB&#xff0c;因此打…

相似性度量中用到的一些距离函数

本文目录 1. 欧氏距离 2. 曼哈顿距离 3. 切比雪夫距离 4. 闵可夫斯基距离 5. 标准化欧氏距离 6. 马氏距离 7. 汉明距离 8. 杰卡德距离 & 杰卡德相似系数 9. 相关系数 & 相关距离 10. 信息熵 1. 欧氏距离(Euclidean Distance) 欧氏距离是最易于理解的一种距离计算方法&a…

Spring 3.1配置文件和Tomcat配置

Spring 3.1引入了非常有用的功能&#xff0c;称为配置文件 。 因此&#xff0c;它易于构建&#xff0c;可以在所有环境&#xff08;开发&#xff0c;测试&#xff0c;生产等&#xff09;中部署的软件包。 通过定义系统属性spring.profiles.active&#xff0c; Spring允许我们使…

计算1~n之间所有奇数之和_所有奇数长度子数组的和

所有奇数长度子数组的和题目&#xff1a;给你一个正整数数组 arr &#xff0c;请你计算所有可能的奇数长度子数组的和。子数组 定义为原数组中的一个连续子序列。请你返回 arr 中 所有奇数长度子数组的和 。示例 1&#xff1a;输入&#xff1a;arr [1,4,2,5,3]输出&#xff1a…

MYSQL AND OR的联用

MYSQL AND OR的联用 MYSQL中”AND”和”OR”都是条件控制符。”AND”是求交集&#xff0c;而”OR”则是求并集&#xff0c;非常多情况下&#xff0c;须要联用它们两个。下面是两张表,我仅仅列出实用的字段。 Table:student_score 学生成绩 sid(学生ID) cid(课程ID) score(分数)…