深入解析skill删除via的实现原理与最佳实践

2次阅读

没有评论

共计 2332 个字符，预计需要花费 6 分钟才能阅读完成。

在游戏或应用系统中，技能 (skill) 系统往往是核心模块之一。当玩家或用户需要删除某个技能时，如何保证操作的原子性、数据一致性以及系统性能，就成为了开发者面临的重要挑战。常见的挑战包括：

并发删除时的数据竞争问题
技能与其他系统模块的关联关系处理
删除操作对系统性能的影响
操作失败时的回滚机制

via 机制是一种常见的保证操作原子性的设计模式。它通过引入一个中间状态来确保删除操作要么完全成功，要么完全失败。具体实现上：

首先将技能标记为 ” 待删除 ” 状态
然后处理所有相关依赖
最后才真正从数据库中删除记录

典型的数据结构设计会包含以下字段：

class Skill {
    String id;
    String name;
    // 其他技能属性
    Status status; // NORMAL, PENDING_DELETION, DELETED
    long version; // 用于乐观锁
}

删除操作应该放在一个事务中执行：

开始事务
检查技能状态
更新为待删除状态
处理依赖关系
执行实际删除
提交事务

采用乐观锁机制防止并发修改：

@Transactional
public void deleteSkill(String skillId) {Skill skill = skillRepository.findById(skillId);
    if (skill == null || skill.getStatus() == Status.DELETED) {return;}

    // 检查并设置待删除状态
    if (skill.getStatus() == Status.NORMAL) {skill.setStatus(Status.PENDING_DELETION);
        skillRepository.updateWithVersion(skill);
    }

    // 处理依赖关系
    handleDependencies(skillId);

    // 执行删除
    skill.setStatus(Status.DELETED);
    skillRepository.updateWithVersion(skill);
}

以下是完整的 Java 实现示例：

public class SkillService {private static final Logger logger = LoggerFactory.getLogger(SkillService.class);

    @Transactional
    public void deleteSkill(String skillId) {
        try {Skill skill = skillRepository.findById(skillId);
            if (skill == null || skill.getStatus() == Status.DELETED) {logger.info("Skill {} already deleted", skillId);
                return;
            }

            // 第一阶段：标记为待删除
            if (skill.getStatus() == Status.NORMAL) {skill.setStatus(Status.PENDING_DELETION);
                if (skillRepository.updateWithVersion(skill) == 0) {throw new OptimisticLockingFailureException("Concurrent modification detected");
                }
            }

            // 第二阶段：处理依赖
            handleDependencies(skillId);

            // 第三阶段：真正删除
            skill.setStatus(Status.DELETED);
            if (skillRepository.updateWithVersion(skill) == 0) {throw new OptimisticLockingFailureException("Concurrent modification detected");
            }

            logger.info("Skill {} deleted successfully", skillId);
        } catch (Exception e) {logger.error("Failed to delete skill {}", skillId, e);
            throw e;
        }
    }

    private void handleDependencies(String skillId) {
        // 处理所有依赖该技能的其他实体
        // 比如：移除角色技能关联、清理缓存等
    }
}