系列文章

Hazelcast系列(一)：初识hazelcast

Hazelcast系列(二)：hazelcast集成（嵌入式）

Hazelcast系列(三)：hazelcast集成（服务器/客户端）

Hazelcast系列(四)：hazelcast管理中心

Hazelcast系列(五)：Auto-Detection发现机制

Hazelcast系列(六)：Multicast发现机制

Hazelcast系列(七)：TCP-IP发现机制

Hazelcast系列(八)：数据结构

Hazelcast系列(九)：Map（一）加载和存储

Hazelcast系列(十)：Map（二）监听器和拦截器

目录

        前言

        监听器

                监听器列表

                配置方式

        拦截器

                拦截器方法

                配置方式

        测试

                测试监听器

                测试拦截器

        其他

前言

通过 Hazelcast系列(九)：Map（一）加载和存储 对 Map 从数据库中加载方式以及存储数据方式有个大概了解，续接上文，咱们继续对 Map 的其他方面进行探讨。

Map 内容相关文章：

Hazelcast系列(九)：Map（一）主要探讨 Map 加载、存储以及配置

Hazelcast系列(十)：Map（二）主要探讨 Map 监听器、拦截器

Hazelcast系列(十一)：Map（三）主要探讨 Map 备份、过期和驱逐以及内存格式

接下来，咱们来认识一下 Map 的 监听器 和 拦截器。

监听器

监听器 Listener 可以帮助使用者监听不同的事件进行额外的数据操作，事件例如添加数据、删除数据、更新特定数据等等。

针对于 Map 而言，事件分为基于 Map级别 的事件和基于 条目(Entry)的事件。

Map级别事件是由于Map级别的操作触发的，例如：IMap.clear()、IMap.evictAll()。

条目级别事件是由于操作某个特定条目后触发的，例如：IMap.remove()、IMap.evict()。

监听器列表

以下是 Map 级别和基于 条目(Entry) 的事件的监听器：

配置方式

配置的监听器必须实现 MapListener相应子接口，例如 EntryAddedListener 或 MapClearedListener。

监听类

/*** Hazelcast监听器*/
public class HazelcastMapListener implements EntryAddedListener<Long, StudentPo>, EntryUpdatedListener<Long, StudentPo> {@Overridepublic void entryAdded(EntryEvent<Long, StudentPo> entryEvent) {//TODOLong key = entryEvent.getKey();System.out.println("监听到" + key + "添加");}@Overridepublic void entryUpdated(EntryEvent<Long, StudentPo> entryEvent) {Long key = entryEvent.getKey();System.out.println("监听到" + key + "更新");}
}

添加方式

• 方式一

  • 说明：通过编程方式添加监听器
  • 示例

HazelcastInstance hz = Hazelcast.newHazelcastInstance();
IMap<String, String> map = hz.getMap("mapcache");
//不仅仅监听本节点的事件
map.addEntryListener(new HazelcastMapListener(), true);//仅仅监听本节点的事件
//map.addLocalEntryListener(new HazelcastMapListener());

• 方式二

  • 说明：通过编程方式添加某个条件下的监听器
  • 示例

HazelcastInstance hz = Hazelcast.newHazelcastInstance();
IMap<String, String> map = hz.getMap("mapcache");
//不仅仅监听本节点的事件
map.addEntryListener( new HazelcastMapListener(), Predicates.equal("name","xiaozi") ,true );//仅仅监听本节点的事件
//map.addLocalEntryListener(new HazelcastMapListener(), Predicates.equal("name", "xiaozi"), true);

• 方式三

  • 说明：通过配置方式添加监听器
  • 示例

hazelcast:map:mapcache:entry-listeners:- class-name: com.hazelcast.hazelcastspringbootdemo1.config.HazelcastMapListenerinclude-value: falselocal: false

        这里的配置参数同编程方式的方法参数都是一样的，编程方式有些方法只不过重载了。

        说明：class-name  监听器的全限定类名

                   include-value  是否包含特定值的监听

                   local  是否只监听本节点的事件

拦截器

与监听器不同，拦截器可以在 Map 操作完成之前更改对其执行的操作。使用监听器，你可以在方法完成并且内存中的映射已修改后执行操作。拦截器操作是同步的，允许你更改方法的行为、更改其值或完全取消它。

拦截器是服务端的功能。

/*** hazelcast拦截器类*/
public class HazelcastMapInterceptor implements MapInterceptor {/*** 拦截get操作，可以返回其他值来替换原有值** @param o* @return*/@Overridepublic Object interceptGet(Object o) {return o;}/*** get操作执行完后被调用** @param o*/@Overridepublic void afterGet(Object o) {System.out.println("已获取的值" + o);}/*** 拦截put,返回的值会设置到map中** @param oldVal* @param newVal* @return*/@Overridepublic Object interceptPut(Object oldVal, Object newVal) {return newVal;}/*** put操作执行后被调用** @param o*/@Overridepublic void afterPut(Object o) {}/*** 拦截remove,返回被删除对象** @param o* @return*/@Overridepublic Object interceptRemove(Object o) {return o;}/*** remove操作执行后被调用** @param o*/@Overridepublic void afterRemove(Object o) {}/*** hashCode值，为每个实例返回相同的值** @return*/@Overridepublic int hashCode() {return 1956850123;}
}

添加方式

/*** hazelcast配置类*/
@Configuration
public class HazelcastServerConfig {/*** 配置类* @return*/@Beanpublic Config serverConfig() {ClasspathYamlConfig yamlConfig = new ClasspathYamlConfig("hazelcast.yaml");return yamlConfig;}/*** 实例对象* @param serverConfig* @return*/@Beanpublic HazelcastInstance hazelcastInstance(Config serverConfig) {HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(serverConfig);IMap<Object, Object> map = hazelcastInstance.getMap(HazelcastConstants.HAZECAST_MAP_CACHE);map.addInterceptor(new HazelcastMapInterceptor());return hazelcastInstance;}
}

          暂未找到对应的yaml配置方式，所以采用编程的方式添加

         注意：多个节点添加拦截器一定要添加hashcode方法，避免同一个拦截器被多次加入

测试

同一份代码复制两份进行测试，开启不同的端口

测试监听器

• 两个节点分别为 Node1 和 Node2，都采用方式三配置方式，Node1 节点只监听本节点的事件，Node2 监听所有的事件
• 向 Node2 添加数据

•  Node2 收到事件， Node1 未收到事件（这里并不是往哪个节点添加，数据肯定就放到哪儿，注意，这里会根据 Hazelcast 分区负载存放）

• 接下来，向 Node1 添加多次添加数据数据（No从29-34），结果如下

•  可以发现 Node2 收到所有的事件，Node2 符合预期，而 Node1 仅收到 No=34 的事件，这说明只有 No=34 这个 Key 的值在分区在 Node1 节点上，那么如何确认呢？ 
• 可以通过管理中心通过 Map 的 Key 获取，Value 的信息不但包含值，还有所在的节点地址，除此之外，可以通过自己编写 API 获取，这里采用第二种方式，编写 API 获取相关信息
• 发送请求获取 Key 相关信息，结果如下

• 192.168.119.1:5702 就是 Node1 节点的地址（这里 Node1 节点启动的时候会打印当前节点地址和端口，可作为依据），测试完成 

测试拦截器

环境同前面测试监听器一样

• 通过 Node1 发起请求获取 No=34 的 Key 的信息

• 结果如下，Node1 打印了信息，Node2 没有打印，前面我们也验证过，No=34 的数据存放在 Node1 上，所以正确

•  通过 Node1 发起请求获取 No=28 的 Key 的信息

• 结果如下，Node1 没打印拦截器信息，Node2 打印拦截器信息，No=28 的数据存放在 Node2 上，所以正确，测试完成 

其他

• 对象序列化有多种方式，JAVA 自带的 Serializable 序列化效率是最低的
• 监听器根据数据所在分区的所在节点触发事件，如果仅监听当前节点事件，通过当前节点操作数据，不一定就在当前节点触发事件（前提是有多个节点）
• 拦截器最好重写 hashCode方法，避免同一个拦截器被多次使用
• 拦截器生效的节点也就是 Key 所在的节点