分布式锁

保证同一时间只有⼀个客户端可以对共享资源进⾏操作
为了防⽌分布式系统中的多个进程之间相互⼲扰，需要⼀种分布式协调技术来对这些进程进⾏调度利用互斥机制来控制共享资源的访问，这就是分布式锁要解决的问题

设计分布式锁应该考虑的东西

• 排他性
  • 在分布式应⽤集群中，同⼀个⽅法在同⼀时间只能被⼀台机器上的⼀个线程执行
• 容错性
  • 分布式锁⼀定能得到释放，⽐如客户端奔溃或者网络中断
• 满⾜可重⼊、⾼性能、⾼可⽤
• 注意分布式锁的开销、锁粒度

基于Redis实现

加锁并配置过期时间，保证原子性；解锁要防止误删除，并保证原子性

lua脚本有一定的原子性，不会背其它命令插队，可以完成一些redis事务性的操作

@RestController
@RequestMapping("/lock")
public class TestLock {
    @Resource
    private StringRedisTemplate stringRedisTemplate;
    @GetMapping("/test")
    public void distributeLock(@RequestParam("pid")Long pid) {
        String key = "distribute:" + pid;
        //uuid防止其它线程误删
        String uuid = UUID.randomUUID().toString().substring(1, 7);
        lock(key, uuid);
    }
    private void lock(String key, String uuid) {
        //线程加锁
        Boolean isLock = stringRedisTemplate.opsForValue().setIfAbsent(key, uuid, 10, TimeUnit.MINUTES);
        System.out.println("线程"+uuid+"加锁状态"+isLock);
        if (isLock) {
            try {
                //todo 业务逻辑
                System.out.println("线程"+uuid+"处理业务");
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                //这里删除key要保证原子性 用lua脚本执行
                stringRedisTemplate.delete(key);
                System.out.println("线程"+uuid+"解锁");
            }
        } else {
            //自旋争取
            try {
                System.out.println("线程"+uuid+"开始自旋");
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            lock(key, uuid);
        }
    }
}