189 8069 5689

分布式全局锁-创新互联

Distlock

参考文档:http://redis.io/topics/distlock

成都创新互联公司客户idc服务中心,提供四川绵阳服务器托管、成都服务器、成都主机托管、成都双线服务器等业务的一站式服务。通过各地的服务中心,我们向成都用户提供优质廉价的产品以及开放、透明、稳定、高性价比的服务,资深网络工程师在机房提供7*24小时标准级技术保障。

分布式全局锁用在:分布式定时任务(执行前取锁),问医生(医生回答问题前取锁)

设计原理:使用redis SET resource_name my_random_value NX PX 30000,当键不存在时才set值,键为锁的标识,值为该锁的删除验证码,用于删除锁时使用

具体流程:1.操作前拿锁,并设置删除码。2.执行业务操作。3.通过锁键拿到锁值,如果锁值与之前设置的删除码一致,则删除该锁,如果不一致,则需要考虑锁过期,别人已经拿到锁做了相关业务,自己的业务是否需要回滚。

实际使用:

1.pom加入redis依赖:


    org.springframework.boot
    spring-boot-starter-redis

2.application.properties 配置redis服务器

spring.application.name=provider-service

#使用哨兵,不手动指定redis服务器
spring.redis.host=10.3.5.21
spring.redis.port=6379
#spring.redis.sentinel.master=master1
#spring.redis.sentinel.nodes=10.3.5.36:26379,10.3.5.38:26379
#微服务专用database 所有key需要以标准前缀(手动指定 微服务名: 或 缓存自动指定 类名完整路径) 不是该结构的key全部删除
spring.redis.database=2
spring.redis.timeout=10000

3.使用分布式全局锁

@Value("${spring.application.name}")
private String appName;

@Inject
@Resource(name = "redisTemplate")
private ValueOperations valueOperations;

@Scheduled(cron = "0 58 * * * ?")
public void foo(){
    if(!RedisDistributedLock.lock(valueOperations, appName+":lock_BarService.foo()", "", 60)){
        System.out.println("EnableScheduling return.");
        return;
    }
    System.out.println("EnableScheduling "+System.currentTimeMillis());
}

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


网站栏目:分布式全局锁-创新互联
网站URL:http://cdxtjz.cn/article/gisgd.html

其他资讯