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:
clearforceUnlocklockputremovetryLockunlock
- READ, READ_WRITE:
containsEntrycontainsKeycontainsValueentrySetgetisLockedkeySetlocalKeySetsizevalueCountvalues
TransactionalMultiMap:
- WRITE, READ_WRITE:
putremove
- READ, READ_WRITE:
sizegetvalueCount
配置脑裂保护
通过setSplitBrainProtectionName()方法或者 split-brain-protection-ref元素配置脑裂保护。下面是一个声明式配置样例：
<hazelcast>
...
<multimap name="default">
<split-brain-protection-ref>splitbrainprotection-name</split-brain-protection-ref>
</multimap>
...作者：大哥你先走
链接：https://www.jianshu.com/p/cba434a5b849
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。
