Ausführen zünden Serverknoten

Question

Ich möchte einige gezündete Serverknoten ausführen und eine separate Clustergruppe von ihnen erstellen (nennen Sie es "WORKER"). Knoten aus dieser Clustergruppe sollen take() Elemente aus der ignite queue verarbeiten, auf irgendeine Weise verarbeiten und etwas in einen Cache stellen, der sich auf Knoten mit der Clustergruppe "CACHE" befindet. Hier ist, wie es aussieht:

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); 
    } 

} 

Ich möchte diesen Knoten starten, indem ./ignite.sh _configuration_ mit der angegebenen Konfiguration ausgeführt wird.

Die Frage ist, ich weiß nicht, wie man das schreibt _configuration_, so dass dies ausgeführt werden kann, nur durch die Bereitstellung dieser Konfigurationsdatei ./ignite.sh. Vielleicht sollte ich ContextRefreshedEvent fangen und setzen

Answer 1

Service Grid kann in diesem Szenario nützlich sein. Erstellen Sie einen Dienst und stellen Sie ihn in der IgniteConfiguration Bean bereit. Es wird beim Start automatisch bereitgestellt.