hazelcast IMDG

Hazelcast中的MultiMap 是一个key可以有多个值的特殊map。和其他数据结构一样，MultiMap 也是分布式和线程安全的。MultiMap 不是 java.util.Map 的分布式实现，MultiMap支持Map的多数功能，但是不支持索引，谓词和加载/存储。MultiMap 的数据最终也会均匀分布于集群所有节点，新节点加入时的处理逻辑和map一样。

1. 基本操作

创建MultiMap 并存储数据：

HazelcastInstance instance = Hazelcast.newHazelcastInstance();
MultiMap<String, Integer> multiMap = instance.getMultiMap("data");
multiMap.put("even", 2);
multiMap.put("even", 4);
multiMap.put("odd", 5);

遍历元素：

HazelcastInstance instance = Hazelcast.newHazelcastInstance();
MultiMap<String, Integer> multiMap = instance.getMultiMap("data");
multiMap.put("even", 2);
multiMap.put("even", 4);
multiMap.put("odd", 5);

multiMap.keySet().forEach(s -> System.out.println(String.format("key = %s,value = %s", s, multiMap.get(s).toString())));

输出如下:

key = even,value = [4, 2]
key = odd,value = [5]

MultiMap 支持通过 EntryListener 监听数据变化。

2. 配置

在使用MultiMap时，可以通过 valueCollectionType 配置值的集合类型是Set或List。如果选择Set 重复值和空置是不允许的而且顺序是无关紧要的。如果选择使用List 排序是相关的而且可以允许存储重复的值。通过statisticsEnabled 配置可以开启对MultiMap的统计，使用 getLocalMultiMapStats() 方法获取统计信息。

目前，MultiMap不支持数据驱逐。

下面是MultiMap的配置样例。

声明式配置:

<hazelcast>
    ...
    <multimap name="default">
        <backup-count>0</backup-count>
        <async-backup-count>1</async-backup-count>
        <value-collection-type>SET</value-collection-type>
        <entry-listeners>
            <entry-listener include-value="false" local="false" >com.hazelcast.examples.EntryListener</entry-listener>
        </entry-listeners>
        <split-brain-protection-ref>split-brain-protection-name</split-brain-protection-ref>
    </multimap>
    ...
</hazelcast>

代码配置:

MultiMapConfig mmConfig = new MultiMapConfig();
mmConfig.setName( "default" )
        .setBackupCount( 0 ).setAsyncBackupCount( 1 )
        .setValueCollectionType( "SET" )
        .setSplitBrainProtectionName( "splitbrainprotectionname" );

配置参数及其含义:

• backup-count: 同步备份数。
• async-backup-count: 异步备份数。
• statistics-enabled: 是否开启统计。
• value-collection-type: 存储值的集合类型 SET 或 LIST。
• entry-listeners: 监听器.
• split-brain-protection-ref: 脑裂保护。

3. 脑裂保护

MultiMap 和 TransactionalMultiMap 支持配置在应用操作前检查集群可用节点数。在网络分区的情况下，该配置可以避免操作在所有集群（一个集群分为多个）都执行成功。

下面是支持脑裂保护的方法。

MultiMap:

• WRITE, READ_WRITE:
  • clear
  • forceUnlock
  • lock
  • put
  • remove
  • tryLock
  • unlock
• READ, READ_WRITE:
  • containsEntry
  • containsKey
  • containsValue
  • entrySet
  • get
  • isLocked
  • keySet
  • localKeySet
  • size
  • valueCount
  • values

TransactionalMultiMap:

• WRITE, READ_WRITE:
  • put
  • remove
• READ, READ_WRITE:
  • size
  • get
  • valueCount

配置脑裂保护

通过setSplitBrainProtectionName()方法或者 split-brain-protection-ref元素配置脑裂保护。下面是一个声明式配置样例：

<hazelcast>
    ...
    <multimap name="default">
        <split-brain-protection-ref>splitbrainprotection-name</split-brain-protection-ref>
    </multimap>
    ...
</hazelcast>