在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
在Akka中实现主从/网格计算模式相关推荐
- akka es/cqrs_在Akka中实现主从/网格计算模式
akka es/cqrs 主从模式是容错和并行计算的主要示例. 模式背后的想法是将工作划分为相同的子任务,然后将其委派给从属. 这些从属节点或实例将处理工作任务,并将结果发送回主节点. 然后主节点将编 ...
- 网格计算Grid Computing
随着超级计算机的不断发展,它已经成为复杂科学计算领域的主宰.但以超级计算机为中心的计算模式存在明显的不足,而且目前正在经受挑战.超级计算机虽然是 一台处理能力强大的"巨无霸",但它 ...
- 云计算机基于什么网络吗,什么是云计算,什么是网格计算,他们之间有什么区别...
原标题:什么是云计算,什么是网格计算,他们之间有什么区别 随着网络技术的广泛应用和深化,网络信息与服务趋于海量,海量数据挖掘处理.分布异构等问题逐渐显现,随之新概念新技术也层出不穷,以云计算与网格计算 ...
- c语言编程计算人口增长模式转变示意图,读“人口增长模式及其转变示意图”,回答下列问题。(5分)(1)图中字母代表的人口增长模式是:A____________、B____...
读"人口增长模式及其转变示意图",回答下列问题.(5分)(1)图中字母代表的人口增长模式是:A____________.B____ 更多相关问题 According to your ...
- 分布式计算、网格计算和云计算
前几天与几个同事无意中聊起了云计算,还说Google也推出了相应的服务. 心里就一直在想这到底是个什么东西哪,上网搜索了一把,又找到几个相近的概念,就在这里记录一下. 1.分布式计算 所谓分布式计算是 ...
- 万丈高楼平地起 ——浅谈网格计算基础
万丈高楼平地起 --浅谈网格计算基础 网格技术的产生.发展必须具备以下三个基本条件:计算资源的广域分布.网络技术(特别是Internet)以及不断增长的对资源共享的需求.在计算器技术发展的早期阶段,只 ...
- php 动态网格,ZBrush中的动态网格该怎么进行运用
DynaMesh是ZBrush最新的基础模型创建工具,该命令用于基本模型的起稿到中模的制作.使用DynaMesh完全不启用考虑模型的拓扑,可以从一个图形拉扯出整个模型的分支,本文将以一个实例简单介绍Z ...
- 【分布计算环境笔记】10 SOA、网格计算、云计算与P2P技术
作者:gnuhpc 出处:http://www.cnblogs.com/gnuhpc/ 1.面向服务的体系结构SOA 1)定义:Service-Oriented Architecture,一种应用的体 ...
- 关于计算机应用的客户服务器模式,计算机客户机/服务器计算模式
客户机/服务器计算模式源于个人计算机PC.工程工作站和计算机网络技术的迅速的发展以及UNIX系统的广泛应用.从而促进计算机系统从集中式处理环境进入分布式计算环境.9 0年代将是以个人计算机.工程工作站 ...
最新文章
- HashMap 1.7工作原理
- 安装CocoaPods
- cas无法使用_一文彻底搞懂CAS实现原理
- 记录一下在mac上做一个usb linux安装盘
- linux之nm命令
- 【牛客 - NC93】设计LRU缓存结构(模拟)
- 看美文,记单词(6)
- Springmvc跨服务器文件上传报403,409错误
- linux开机到登陆的流程图,1-描述linux开机到登陆界面的启动过程.docx
- tomcat classpath两个路径_solr安装-tomcat+solrCloud构建稳健solr集群
- python科学计算库-数值计算库与科学计算库
- Android API 指南
- Mysql学习总结(8)——MySql基本查询、连接查询、子查询、正则表达查询讲解
- java监听鼠标接口实现_自定义Java鼠标监听器?
- 建立时间和保持时间关系详解
- 嵌入式系统与人工智能 1
- 苹果app(iOS app)比较常用的URL schemes,可以用于iOS应用间相互调用
- 引入element组件插件
- CPU、MPU、MCU、SOC的概念与区别
- 历史经验之js个200经验收藏
热门文章
- tomcat(12)org.apache.catalina.core.StandardContext源码剖析
- reactor使用方法_Project Reactor展开方法
- mockito 单元测试_使用FizzBu​​zz和Mockito进行单元测试
- java面试解决项目难题_Java转换难题者,不适合工作(或面试)
- 具有InlfuxDB的Spring Boot和Micrometer第2部分:添加InfluxDB
- 在AWS第1部分中使用Terraform自动缩放组:基本步骤
- javafx透明边框_JavaFX技巧6:使用透明颜色
- 删除已弃用的CMS垃圾收集器的JEP草案
- html嵌入war_WAR文件与具有嵌入式服务器的Java应用程序
- cglib_cglib:缺少的手册