Hazelcast IMap - Was kann der effizienteste Weg sein, um Wert für mehrere Schlüssel zu erhalten?

Question

Anwendungsfall: IMap und hat 70K Einträge. Mehrheit der Operationen sind GET-Aufruf für mehrere Schlüssel. GET Anrufe (90%)> PUT Anrufe (10%). Wir verwenden EP für PUT-Aufrufe.

Problem: Was ist der effizienteste Weg, um die Daten für mehrere Schlüssel zu erhalten, die in mehreren Instanzen vorhanden sein können?

Mögliche Lösung: 1. EP mit ReadOnly, Offloadable und verwenden executeOnKeys Methode. 2. Parallele map.get (Schlüssel) für alle Schlüssel ausführen.

Gibt es einen anderen effizienten Weg, um die Daten für mehrere Schlüssel zu erhalten?

3. Prädikats

   public class ExecuteOnSelectedKeyPredicateTest { public static void main (String [] args) { HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();

    IMap<String, Integer> map = hazelcastInstance.getMap("testMap"); 
   
        map.put("testKey1", 1); 
        map.put("test", 2); 
        map.put("testKey3", 3); 
   
        // Get entries which ends with a number 
        Set<Map.Entry<String, Integer>> entries = map.entrySet(new ExecuteOnSelectedKeyPredicate("^.+?\\d$")); 
   
        System.out.println(entries); 
       } 
   
       public static class ExecuteOnSelectedKeyPredicate implements Predicate<String, Integer> { 
   
        private String keyRegex; 
        private transient Pattern pattern; 
   
        public ExecuteOnSelectedKeyPredicate(String keyRegex) { 
         this.keyRegex = keyRegex; 
        } 
   
   
        @Override 
        public boolean apply(Map.Entry<String, Integer> mapEntry) { 
         if (pattern == null) { 
          pattern = Pattern.compile(keyRegex); 
         } 
         Matcher matcher = pattern.matcher(mapEntry.getKey()); 
         return matcher.matches(); 
        } 
       } 
   } 
   

Answer 1

mehrere Schlüssel die Anfrage bekommen hat möglicherweise mehrere Mitglieder zu gehen. executeOnKeys ist hier ziemlich optimal, da es die Partitionen berechnet, auf denen die Operationen ausgeführt werden müssen, und es sendet diese Operation nur an diese Partitionen. Offloadable stellt sicher, dass Sie die partitionThreads nicht blockieren und ReadOnly die Verarbeitung weiter optimiert.

Mehrere get Operationen generieren mehr Netzwerkverkehr, da Sie pro Schlüssel einen Vorgang haben.