Redis系列四 锁

/**
     * 上锁🔒
     * @param lockName 锁名字
     * @param randomVale 随机值， 为解锁是校验持有者
     * @param expireTime 过期时间，单位秒, 过期后自动删除
     * !保证上锁的安全--一条命令保证安全性
     */
    public async lock(lockName: string, randomVale: string, expire: number) {
        const start = Date.now();
        const self = this;

        return (async function intranetLock(this: any): Promise<any> {
            try {
                // 核心代码
                //* 1. 如果key不存在，则设置key-value, 且value的唯一性，保证删除的时候同样可以校验
                // * 2. 如果key存在，NX 保证不做任何操作
                const result = await self.redis.set(lockName, randomVale, self.expiryMode, expire | self.lockLeaseTime, self.setMode);
                // 上锁成功
                if (result === 'OK') {
                    console.log(`${lockName} ${randomVale} 上锁成功`);
                    return true;
                }
                // 锁超时
                if (Math.floor((Date.now() - start) / 1000) > self.lockTimeout) {
                    console.log(`${lockName} ${randomVale} 上锁重试超时结束`);
                    return false;
                }
                // 循环等待重试
                console.log(`${lockName} ${randomVale} 等待重试`);
                await sleep(3);
                console.log(`${lockName} ${randomVale} 开始重试`);
                return intranetLock();
            } catch (err) {
                throw new Error(err);
            }
        })();

    }

/**
     * 解锁
     */
    public async unLock(lockName: string, randomValue: string) {
        try {
            // Watch 命令监控锁。监控锁对应的 key(lockName)，事务开启后，如果其它的客户端对这个 Key 进行了更改，
            // 那么本次事务会被取消而不会执行 redis.watch(lockName)。
            await this.redis.watch(lockName);
            const value = await this.redis.get(lockName);
            // 如果获取到🔒对应的值，与 randomValue 相等
            if (randomValue === value) {
                // 开启事务，删除锁🔒
                const result = await this.redis.multi().del(lockName).exec();
                if (DistributedLock.RELEASE_SUCCESS === result.length) {
                    console.log('解锁成功');
                    return true;
                }
            } else {
                console.log('value 不相等，解锁失败');
            }
        } catch (error) {
            console.log('解锁error', error);

        }
    }