标签: distributed

我有一些代码将2D数组打印到标准输出.问题是,当我运行它时,每个进程都会写入输出并且数据重叠,使其无法使用.

如何在MPI中构建一个关键部分,以便一次只有一个进程进入我显示输出的部分？

我正在使用OpenMPI.

什么是以数据为中心的应用程序,与面向对象的应用程序模型有什么区别？

我正在寻找一个库(或库的组合)来构建一个java分布式系统,由几个应用程序组成,通过几个成对连接(没有mapreduce)交换数据.目前我对现有的库进行了解释,我只能丢弃我发现的内容.这是我的要求:

• 在运行时轻松发现系统(可能通过中央服务器/目录)
• 轻量级和低延迟消息(无CORBA,RMI,SOAP等)
• 分散的通信(没有像LINDA那样)
• 易于使用和学习(没有JXTA)
• 兼容GPL许可证(所以GPL,BSD等)

你有什么建议吗？提前致谢

我一直在研究几种DLM,但大多数是用JAVA或C++编写的.似乎无法找到专门为.NET实现的任何服务.在.NET中分布式同步的任何想法或建议？

我有一个在统一的java进程网格上运行的应用程序(可能在不同的物理机器上).我想从这个应用程序的单次运行中收集cpu使用情况统计信息.我已经查找了分析工具,寻找自动收集数据的选项,但未能在netbeans,tptp,jvisualvm,yourkit等中找到任何内容.

也许我看错了路？

我在想的是:

• 使用一些特殊的设置运行网格上的进程,允许它们转储分析信息
• 像往常一样运行我的应用程序 - 它会将任务推送到网格,进程将执行任务并发布分析信息
• 使用一些工具来收集和分析分析结果

但我找不到任何与此类似的东西.

有什么想法,经验和建议吗？

谢谢!

我正在尝试决定使用哪个并行调试器.到目前为止,我发现没有很多开源的,所以我的选择是:

• http://www.allinea.com/products/ddt/
• http://www.roguewave.com/products/totalview-family/totalview.aspx

你推荐哪一个？还有什么值得的吗？

我想做的是:

1)在服务器上创建一个主actor,可以在10台不同的机器上动态创建10个远程actor

2)主人将任务分配给10个远程演员

3)当每个远程演员完成他们的工作时,他们将结果发送给主演员

4)主人关闭整个系统

我的问题是:

1)我不知道如何配置主演员,下面是我的服务器部分代码:

class MasterAppliation extends Bootable{
    val hostname = InetAddress.getLocalHost.getHostName
    val config = ConfigFactory.parseString(
          s"""
            akka{
            actor{
                provider = "akka.remote.RemoteActorRefProvider"
                deployment {
                    /remotemaster {
                        router = "round-robin"
                        nr-of-instances = 10
                        target {
                            nodes = ["akka.tcp://remotesys@host1:2552", "akka.tcp://remotesys@host2:2552", ....... akka.tcp://remotesys@host10:2552"]
                        }
                }
            }
            remote{
                enabled-transports = ["akka.remote.netty.tcp"]
                netty.tcp{
                hostname = "$hostname"
                port = 2552
                }
            }     
          }""")

    val system = ActorSystem("master", ConfigFactory.load(config))        
    val master = system.actorOf(Props(new master), name = "master") 
    def dosomething = master ! Begin()
    def …

我正在开发一个将部署到AWS的套接字服务器,到目前为止,我们已经按照与Erlang in Practice中的示例项目类似的结构设置了基本的OTP应用程序,但我们希望避免使用全局消息路由器,因为这不会很好地扩展.

通过分布式应用程序的OTP设计指南以及" 了解你一些Erlang"中的相应章节(Distribunomicon和分布式OTP),看来内置的分布式应用程序机制适用于已知主机名和IP的内部部署解决方案.群集配置是提前确定的,而在我们预期的设置中,应用程序需要动态地上下扩展,并且节点的IP地址将是随机的.

对不起,这是一个冗长的构建,我的问题是,是否有部署到云的分布式Erlang应用程序的设计指南,需要处理所有动态扩展？

谢谢,

我正在使用Apache Curator库在Zookeeper上进行领导选举.我将我的应用程序代码部署在各种机器上,我只需要从一台机器执行我的代码,这就是为什么我在动物园管理员上进行领导选举,以便我可以检查我是否是领导者,然后执行此代码.

下面是我的LeaderElectionExecutor类,它确保我每个应用程序都有一个Curator实例

public class LeaderElectionExecutor {

    private ZookeeperClient zookClient;

    private static final String LEADER_NODE = "/testleader";

    private static class Holder {
        static final LeaderElectionExecutor INSTANCE = new LeaderElectionExecutor();
    }

    public static LeaderElectionExecutor getInstance() {
        return Holder.INSTANCE;
    }

    private LeaderElectionExecutor() {
        try {
            String hostname = Utils.getHostName();

            String nodes = "host1:2181,host2:2181;

            zookClient = new ZookeeperClient(nodes, LEADER_NODE, hostname);
            zookClient.start();

            // added sleep specifically for the leader to get selected
            // since I cannot call isLeader method immediately after starting …

现在我们构建一个实时分析系统,它应该是高度分布式的.我们计划使用分布式锁和计数器来确保数据的一致性,我们需要一种分布式映射来了解哪个客户端连接到哪个服务器.我之前没有分布式系统的经验,但我认为我们有两个选择:

1. Java的+ Hazelcast

2. Golang + ETCD

但是在主题背景下彼此的利弊是什么？