Java中触发自定义Apache Ignite事件的最佳实践是什么？

Ignite支持通过公开API实现自定义事件的触发和监听，无需依赖源码内部非公开方法，具体操作流程如下：

1. 定义自定义事件类 #

所有自定义事件需要继承EventAdapter父类，自定义事件类型ID必须大于EventType.EVT_USER_START，避免和Ignite内置事件冲突，示例代码：

import org.apache.ignite.events.EventAdapter;
import org.apache.ignite.events.EventType;

public class CustomIgniteEvent extends EventAdapter {
    // 自定义事件ID，必须从EVT_USER_START后开始分配
    public static final int TYPE_CUSTOM_BIZ_OP = EventType.EVT_USER_START + 1;
    // 自定义携带参数
    private String bizData;

    public CustomIgniteEvent() {}

    public CustomIgniteEvent(String nodeId, String msg, String bizData) {
        super(nodeId, msg, TYPE_CUSTOM_BIZ_OP);
        this.bizData = bizData;
    }

    // getter/setter省略
}

2. 配置启用自定义事件 #

在Ignite启动前的配置中，需要显式声明要启用的自定义事件类型，否则Ignite不会处理该类事件：

IgniteConfiguration cfg = new IgniteConfiguration();
// 加入自定义事件类型到启用列表
cfg.setIncludeEventTypes(CustomIgniteEvent.TYPE_CUSTOM_BIZ_OP);
// 其余业务配置省略
Ignite ignite = Ignition.start(cfg);

3. 注册自定义事件监听器（可选） #

如果需要接收自定义事件，可以在对应节点注册监听器，支持本地监听和跨节点远程监听：

// 本地节点监听自定义事件
ignite.events().localListen(event -> {
    if (event.type() == CustomIgniteEvent.TYPE_CUSTOM_BIZ_OP) {
        CustomIgniteEvent customEvent = (CustomIgniteEvent) event;
        // 处理自定义事件逻辑
        System.out.println("收到自定义事件，业务数据：" + customEvent.getBizData());
    }
    // 返回true保持监听器存活，返回false则监听终止
    return true;
}, CustomIgniteEvent.TYPE_CUSTOM_BIZ_OP);

4. 触发自定义事件 #

直接调用Ignite公开的record方法即可触发事件，不需要调用内部非公开API：

// 构造自定义事件实例
CustomIgniteEvent event = new CustomIgniteEvent(
    ignite.cluster().localNode().id().toString(),
    "业务操作完成",
    "自定义业务数据内容"
);
// 触发事件，Ignite会按配置完成事件传播
ignite.events().record(event);

注意事项 #

• 自定义事件类型ID必须全局唯一，禁止占用内置事件的ID区间
• 如果需要跨节点传播事件，所有节点的类路径下必须包含自定义事件类，否则会触发反序列化异常
• 以上实现全部基于Ignite公开API，不同版本兼容性有保障，无需修改源码

内容的提问来源于stack exchange，提问作者ttuna