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

系列文章

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> {

    @Override
    public void entryAdded(EntryEvent<Long, StudentPo> entryEvent) {
        //TODO
        Long key = entryEvent.getKey();
        System.out.println("监听到" + key + "添加");
    }

    @Override
    public 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.HazelcastMapListener
          include-value: false
          local: false

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

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

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

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

拦截器

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

拦截器是服务端的功能。

/**
 * hazelcast拦截器类
 */
public class HazelcastMapInterceptor implements MapInterceptor {

    /**
     * 拦截get操作，可以返回其他值来替换原有值
     *
     * @param o
     * @return
     */
    @Override
    public Object interceptGet(Object o) {
        return o;
    }

    /**
     * get操作执行完后被调用
     *
     * @param o
     */
    @Override
    public void afterGet(Object o) {
        System.out.println("已获取的值" + o);
    }

    /**
     * 拦截put,返回的值会设置到map中
     *
     * @param oldVal
     * @param newVal
     * @return
     */
    @Override
    public Object interceptPut(Object oldVal, Object newVal) {
        return newVal;
    }

    /**
     * put操作执行后被调用
     *
     * @param o
     */
    @Override
    public void afterPut(Object o) {

    }

    /**
     * 拦截remove,返回被删除对象
     *
     * @param o
     * @return
     */
    @Override
    public Object interceptRemove(Object o) {
        return o;
    }

    /**
     * remove操作执行后被调用
     *
     * @param o
     */
    @Override
    public void afterRemove(Object o) {

    }

    /**
     * hashCode值，为每个实例返回相同的值
     *
     * @return
     */
    @Override
    public int hashCode() {
        return 1956850123;
    }
}

添加方式

/**
 * hazelcast配置类
 */
@Configuration
public class HazelcastServerConfig {

    /**
     * 配置类
     * @return
     */
    @Bean
    public Config serverConfig() {
        ClasspathYamlConfig yamlConfig = new ClasspathYamlConfig("hazelcast.yaml");
        return yamlConfig;
    }

    /**
     * 实例对象
     * @param serverConfig
     * @return
     */
    @Bean
    public 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 所在的节点