冗余双写分布式可重入锁解决方案

@Override
public boolean handleAddShortLink(EventMessage eventMessage) {
    // 验证合法性操作 TODO
    String code = shortLinkComponent.createShortLinkCode(shortLinkAddRequest.getOriginalUrl());
    //加锁
    //key1是短链码，ARGV[1]是accountNo,ARGV[2]是过期时间
    String script = "if redis.call('EXISTS',KEYS[1])==0 then redis.call('set',KEYS[1],ARGV[1]); redis.call('expire',KEYS[1],ARGV[2]); return 1;" +
            " elseif redis.call('get',KEYS[1]) == ARGV[1] then return 2;" +
            " else return 0; end;";


    Long result = redisTemplate.execute(new
            DefaultRedisScript<>(script, Long.class), Arrays.asList(code), eventMessage.getAccountNo(),100);
    log.info("分布式锁加锁后的result={}",result);
    //result!=0表示加锁成功
    if(result!=0){
        if(EventMessageType.EVENT_LINK.name().equalsIgnoreCase(messageType)){
            //查询C端数据库中是否已经存在该短链码
            ShortLinkDO linkCode = shortLinkManager.findByShortLinkCode(code);
            if(linkCode==null){
                log.info("C端不存在这个短链对象，可以插入");
                //构造短链对象 C端对象 TODO
                //将短链对象插入数据库
                shortLinkManager.addShrotLink(shortLinkDO);
                return true;
            }
            return false;
        }else if(EventMessageType.EVENT_MAPPING.name().equalsIgnoreCase(messageType)){
            //查询B端数据库中是否已经存在该短链码
            GroupCodeMappingDO groupCodeMappingDO = mappingManager.findByCode(code,shortLinkAddRequest.getGroupId(),eventMessage.getAccountNo());
            if(groupCodeMappingDO==null){
                log.info("B端不存在这个短链对象，可以插入");
                //构造短链对象 B端对象 TODO
                //将短链插入数据
                mappingManager.add(mappingDO);
                return true;
            }
            return false;
        }
    }
    return false;
}