PROSAGA码农传奇-分布式计算-基本的Hazelcast分布式计算概念

我与Hazelcast的人们进行了交谈，发现我对它的工作原理有一些基本的误解。我不了解您必须通过在计算节点上运行“ com.hazelcast.examples.StartServer”来像服务或守护程序一样部署Hazelcast。这就是节点如何了解彼此并进行交互的方式。为此，Hazelcast zip包含一些批处理和外壳脚本。也许这对于其他人来说是显而易见的，但是我在文档中没有发现任何明确说明这一点的内容。我从文档中得到的就是将jar放到类路径中，这使我可以访问所有类和方法。我不知道应该如何准备计算节点以相互了解。

我的前两个问题上面从Hazelcast文档，其中在分布式计算部分的第一个例子，他们创造一个新的Hazelcast实例来里面的可赎回。我不确定他们为什么要这样做，但这对我来说极具误导性。我认为这意味着我需要创建一个新的Hazelcast实例并将其与每个线程相关联。

上面的Pveentjer回答了问题3。答案是肯定的，如果您愿意的话。

问题4只是由于我对Hazelcast的工作方式感到困惑。基本上，正如我所想到的，Hazelcast实例和线程之间没有一对一的映射。每个Hazelcast实例已经是多线程的，因此出于并行处理的原因，无需在一个节点上创建多个实例（但是您可能由于其他原因（堆空间限制等）而希望这样做。必须在所有计算节点（我使用上面提到的StartServer）上部署Hazelcast。

简而言之，通过简单的操作，我就可以轻松创建计算集群

1）将Hazelcast jar放到主节点上的类路径中（或将其包含在Eclipse项目中）

2）使用带有StartServer调用的批处理文件在计算节点上部署Hazelcast

3）创建一个Runnable并使其可序列化（及其所有依赖项）

4）在我的Main（）方法中创建一个Hazelcast实例，并获得一个IExecutorService来执行我的Runnable实例

唯一的另一个重要步骤是确保在将StartServer部署到计算节点上时，将Hazelcast jar和所有包含Runnable定义及其依赖的所有类的jar放入类路径中。

下面是一个简单的示例：

```
public class myRunnable implements Runnable, Serializable {

myTestClass mclass;

public myRunnable(){
    mclass = new myTestClass();
}

@Override
public void run(){

try {
        System.out.println("Putting thread to sleep for 5 seconds");
        Thread.sleep(5000);
    }
    catch(Exception e){
        e.printStackTrace();
    }

System.out.println("\nTesting MyRunnable on Thread: " + Thread.currentThread().getName());

}
}
```

然后定义Runnable依赖的类：

```
public class myTestClass implements Serializable{

List<Double> list = new ArrayList<Double>(10);

public void myTestClass(){

for (int i = 0; i < 10; i++)
        list.add( (double) i);
}
}
```

并创建一个Hazelcast实例和IExecutorService来执行

```
public class TestHazelCast {

public static void main(String[] args) {

Config cfg = new Config();
    HazelcastInstance instance = Hazelcast.newHazelcastInstance(cfg);
    IExecutorService exec = instance.getExecutorService("exec");

for (int i = 0 ; i < 7; i++){
        exec.execute(new myRunnable());
    }

}
}
```

然后将Hazelcast连同适当的jar一起部署在计算节点上，方法如下：

```
java -server -Xms1G -Xmx1G -cp "../lib/hazelcast-3.2.2.jar;../lib/AllMyClasses.jar" com.hazelcast.examples.StartServer
```