运行点燃服务器节点

Question

我想运行点燃一些服务器节点并从中创建一个单独的集群组（称之为 "WORKER"）。来自该集群组的节点应该 take() 来自点燃队列的元素，以某种方式处理它并将某些内容放入集群组 "CACHE" 节点上的缓存中。这是它的样子：

public interface Batch{ }

public class Runner{

    //initialize batchesToProcess as ignite distrubted queue
    Queue<Batch> batchesToProcess;

    //I need Ignite here.
    //@IgniteInstanceResource does not work this way
    //Because this is just a bean declared in ingite spring configuration
    private Ignite ignite;

    public void executeLogic(){
        Batch b = batchesToProcess.take();
        String cacheName;
        String key;
        String value;
        //process Batch b, get 3 strings
        //1. cache name
        //2. key
        //3. value
        IgniteCache<String, String> cache = ignite.getOrCreateCache(cacheName);
        cache.put(key, value);
    }

}

我想通过运行ning ./ignite.sh _configuration_ 使用指定的配置启动此节点。

问题是我不知道如何写这个 _configuration_ 所以这可以是运行只需将这个配置文件提供给 ./ignite.sh。也许我应该赶上 ContextRefreshedEvent 并把 th

Answer 1

Service Grid 在这种情况下很有用。创建服务并在 IgniteConfiguration bean 中提供它。它将在启动时自动部署。

运行点燃服务器节点

Running ignite server node

java

ignite

运行 点燃服务器节点

Running ignite server node

java

ignite

运行点燃服务器节点