tiympi4j是一款微型的java分布式离线计算框架,实现原理如图：
特性简单直观,没有任何学习难度
slave支持多个任务并发/并行执行
使用HTTP协议通信
场景:找素数/grep/wordcout/超大文件或大量小文件处理
不支持复杂数据类型
没有进度监控，健康监控，无容错功能
例子:用两台服务器分布式计算找出10000以内的素数
public static void mai(Strig[] args) {//启动master上的tomcatfial it masterport = 8086;fial Strig masterurl = "https://192.168.1.100:" + masterport;TomcatTool.startMasterTomcat(masterport);//创建任务fial BigTask<Iteger> bigtask = BigTask.create(masterurl);//添加任务到两台计算节点， 请确保计算节点上的 tiympi4j-slave 已启动//关于计算节点: https://github.com/biaryer/tiympi4j-slavebigtask.addTask2Slave("https://192.168.1.101:1234", PrimeSplitedtask.class, ew Iteger[] { 2, 5000 });bigtask.addTask2Slave("https://192.168.1.102:1234", PrimeSplitedtask.class, ew Iteger[] { 5001, 10000 });//等待所有节点执行完毕fial Collectio<Iteger> resultset = bigtask.executeAdWait();//打印结果for (it : resultset){//System.out.pritl();}}
评论