微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

tinympi4j 特性 微型 java 分布式离线计算框架

程序名称:tinympi4j 特性

授权协议: MIT

操作系统: 跨平台

开发语言: Java

tinympi4j 特性 介绍

tinympi4j 是一款微型的 java 分布式离线计算框架, 实现原理如图:

特性

  • 简单直观, 没有任何学习难度

  • slave支持多个任务并发/并行执行

  • 使用HTTP协议通信

  • 场景: 找素数/grep/wordcount/超大文件或大量小文件处理

  • 不支持复杂数据类型

  • 没有进度监控,健康监控,无容错功能

例子: 用两台服务器分布式计算找出10000以内的素数

public static void main(String[] args) {

        //启动master上的tomcat
        final int masterport = 8086;
        final String masterurl = "http://192.168.1.100:" + masterport;
        TomcatTool.startMasterTomcat(masterport);

        //创建任务
        final BigTask<Integer> bigtask = BigTask.create(masterurl);

        //添加任务到两台计算节点, 请确保计算节点上的 tinympi4j-slave 已启动
        //关于计算节点: https://github.com/binaryer/tinympi4j-slave
        bigtask.addTask2Slave("http://192.168.1.101:1234", PrimeSplitedtask.class, new Integer[] { 2, 5000 });
        bigtask.addTask2Slave("http://192.168.1.102:1234", PrimeSplitedtask.class, new Integer[] { 5001, 10000 });

        //等待所有节点执行完毕
        final Collection<Integer> resultset = bigtask.executeAndWait();

        //打印结果
        for (int n : resultset){
            //System.out.println(n);
        }
    }

tinympi4j 特性 官网

https://github.com/binaryer/tinympi4j-master

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐