Hazelcast 3.x转5.x：AbstractEntryProcessor备份实现与使用指引

1. 替代带applyOnBackup参数的构造方法 #

Hazelcast 5.x 移除了AbstractEntryProcessor中带boolean applyOnBackup的构造方法，不再通过构造参数控制备份节点的逻辑执行。取而代之的是，通过实现EntryProcessor接口并重写getBackupProcessor()方法来控制备份行为：

• 返回EntryBackupProcessor实例：表示需要在备份节点执行对应逻辑
• 返回null：表示跳过备份节点的逻辑执行

3.x 原有代码示例 #

public class MyProcessor extends AbstractEntryProcessor<String, Object> {
    public MyProcessor() {
        super(true); // 开启备份节点执行
    }

    @Override
    public Object process(Map.Entry<String, Object> entry) {
        // 主节点处理逻辑
        entry.setValue("updated-value");
        return entry.getValue();
    }
}

5.x 替代实现 #

public class MyProcessor implements EntryProcessor<String, Object> {
    @Override
    public Object process(Map.Entry<String, Object> entry) {
        // 主节点处理逻辑
        entry.setValue("updated-value");
        return entry.getValue();
    }

    @Override
    public EntryBackupProcessor<String, Object> getBackupProcessor() {
        // 返回备份处理器，等价于3.x中applyOnBackup=true
        return new MyBackupProcessor();
    }
}

2. 适配原有备份处理器逻辑 #

在3.x中，当applyOnBackup=true时，备份节点会自动复用主节点的process方法逻辑；而5.x需要显式实现EntryBackupProcessor接口，将备份逻辑写入processBackup方法。

场景1：主备逻辑完全一致 #

如果主节点和备份节点的处理逻辑相同，可以复用公共代码：

public class MyProcessor implements EntryProcessor<String, Object> {
    @Override
    public Object process(Map.Entry<String, Object> entry) {
        return commonHandle(entry);
    }

    @Override
    public EntryBackupProcessor<String, Object> getBackupProcessor() {
        return new MyBackupProcessor();
    }

    // 主备共享的处理逻辑
    private Object commonHandle(Map.Entry<String, Object> entry) {
        entry.setValue("updated-value");
        return entry.getValue();
    }

    private class MyBackupProcessor implements EntryBackupProcessor<String, Object> {
        @Override
        public void processBackup(Map.Entry<String, Object> entry) {
            // 复用主节点逻辑
            commonHandle(entry);
        }
    }
}

场景2：主备逻辑不同 #

如果主节点和备份节点需要执行不同逻辑，分别实现对应方法即可：

public class MyProcessor implements EntryProcessor<String, Object> {
    @Override
    public Object process(Map.Entry<String, Object> entry) {
        // 主节点专属逻辑：比如记录操作日志
        String oldValue = (String) entry.getValue();
        entry.setValue("updated-by-primary");
        return oldValue;
    }

    @Override
    public EntryBackupProcessor<String, Object> getBackupProcessor() {
        return new MyBackupProcessor();
    }

    private class MyBackupProcessor implements EntryBackupProcessor<String, Object> {
        @Override
        public void processBackup(Map.Entry<String, Object> entry) {
            // 备份节点专属逻辑：仅更新值，不记录日志
            entry.setValue("updated-by-backup");
        }
    }
}

3. 核心变化总结 #

• 5.x 不再支持通过构造参数控制备份执行，必须通过getBackupProcessor()方法显式声明
• EntryBackupProcessor的processBackup()方法是备份节点的逻辑入口，替代了3.x中备份节点自动调用process的行为
• 如果不需要备份逻辑，直接在getBackupProcessor()中返回null即可

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