, wie die Anzahl der Einträge auf lokales Mitglied überprüfen

Question

mein bestes Mitglied

public static void main(String[] args) throws InterruptedException { 

    Config config = new Config(); 
    config.setProperty(GroupProperty.ENABLE_JMX, "true"); 
    config.setProperty(GroupProperty.BACKPRESSURE_ENABLED, "true"); 
    config.setProperty(GroupProperty.SLOW_OPERATION_DETECTOR_ENABLED, "true"); 

    config.getSerializationConfig().addPortableFactory(1, new MyPortableFactory()); 

    HazelcastInstance hz = Hazelcast.newHazelcastInstance(config); 

    IMap<Integer, Rule> ruleMap = hz.getMap("ruleMap"); 

    // TODO generate rule map data ; more than 100,000 entries 
    generateRuleMapData(ruleMap); 
    logger.info("generate rule finised!"); 
    // TODO rule map index 

    // health check 
    PartitionService partitionService = hz.getPartitionService(); 
    LocalMapStats mapStatistics = ruleMap.getLocalMapStats(); 
    while (true) { 
     logger.info("isClusterSafe:{},isLocalMemberSafe:{},number of entries owned on this node = {}", 
       partitionService.isClusterSafe(), partitionService.isLocalMemberSafe(), 
       mapStatistics.getOwnedEntryCount()); 
     Thread.sleep(1000); 
    } 

} 

logs

2016-06-28 13:53:05,048 INFO [main] b.PrimeMember (PrimeMember.java:41) - isClusterSafe:true,isLocalMemberSafe:true,number of entries owned on this node = 997465 
    2016-06-28 13:53:06,049 INFO [main] b.PrimeMember (PrimeMember.java:41) - isClusterSafe:true,isLocalMemberSafe:true,number of entries owned on this node = 997465 
    2016-06-28 13:53:07,050 INFO [main] b.PrimeMember (PrimeMember.java:41) - isClusterSafe:true,isLocalMemberSafe:true,number of entries owned on this node = 997465 

meinen Nachläufer

public static void main(String[] args) throws InterruptedException { 
    Config config = new Config(); 
    config.setProperty(GroupProperty.ENABLE_JMX, "true"); 
    config.setProperty(GroupProperty.BACKPRESSURE_ENABLED, "true"); 
    config.setProperty(GroupProperty.SLOW_OPERATION_DETECTOR_ENABLED, "true"); 

    HazelcastInstance hz = Hazelcast.newHazelcastInstance(config); 

    IMap<Integer, Rule> ruleMap = hz.getMap("ruleMap"); 
    PartitionService partitionService = hz.getPartitionService(); 
    LocalMapStats mapStatistics = ruleMap.getLocalMapStats(); 
    while (true) { 
     logger.info("isClusterSafe:{},isLocalMemberSafe:{},number of entries owned on this node = {}", 
       partitionService.isClusterSafe(), partitionService.isLocalMemberSafe(), 
       mapStatistics.getOwnedEntryCount()); 
     Thread.sleep(1000); 
    } 
} 

Protokolle 2016.06.28 14: 05: 53,543 INFO [main] B.SlaveMember (SlaveMember.java:31) - isClusterSafe: false, isLocalMemberSafe: false, Anzahl der Einträge ned auf diesem Knoten = 412441 2016-06-28 14: 05: 54,556 INFO [main] B.SlaveMember (SlaveMember.java:31) - isClusterSafe: false, isLocalMemberSafe: false, Anzahl der Einträge auf diesem Knoten = 412441 2016-06-28 14: 05: 55,563 INFO [main] b.SlaveMember (SlaveMember.java:31) - isClusterSafe: false, isLocalMemberSafe: false, Anzahl der Einträge auf diesem Knoten = 412441 2016-06-28 14: 05: 56578 INFO [main] b.SlaveMember (SlaveMember.java:31) - isClusterSafe: false, isLocalMemberSafe: false, Anzahl der auf diesem Knoten = 412441

meine Frage gehört Einträge ist:

warum Nummer der Einträge, die für prime-Member gelten, werden nicht geändert, nachdem der Cluster einen sl hinzugefügt hat Ave Mitglied?

Answer 1

Ich sollte die Statik pro Sekunde bekommen.

Answer 2

Eine weitere Option ist die Verwendung von localKeySet, das den lokalen Schlüsselsatz zurückgibt.

IMap::localKeySet.size()