扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章给大家介绍php中怎么实现redis分布式锁,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
成都创新互联是一家专业提供新民企业网站建设,专注与成都做网站、网站建设、H5网站设计、小程序制作等业务。10年已为新民众多企业、政府机构等服务。创新互联专业网站设计公司优惠进行中。
分布式锁一般有三种实现方式:
1. 数据库乐观锁;2. 基于Redis的分布式锁;3. 基于ZooKeeper的分布式锁。
首先,为了确保分布式锁可用,我们至少要确保锁的实现同时满足以下四个条件:
互斥性。在任意时刻,只有一个客户端能持有锁。
不会发生死锁。即使有一个客户端在持有锁的期间崩溃而没有主动解锁,也能保证后续其他客户端能加锁。
具有容错性。只要大部分的Redis节点正常运行,客户端就可以加锁和解锁。
解铃还须系铃人。加锁和解锁必须是同一个客户端,客户端自己不能把别人加的锁给解了
servers = $servers;$this->retryDelay = $retryDelay;$this->retryCount = $retryCount;$this->quorum = min(count($servers), (count($servers) / 2 + 1));}public function lock($resource, $ttl){$this->initInstances();$token = uniqid();$retry = $this->retryCount;do {$n = 0;$startTime = microtime(true) * 1000;foreach ($this->instances as $instance) {if ($this->lockInstance($instance, $resource, $token, $ttl)) {$n++;}}# Add 2 milliseconds to the drift to account for Redis expires # precision, which is 1 millisecond, plus 1 millisecond min drift # for small TTLs. $drift = ($ttl * $this->clockDriftFactor) + 2;$validityTime = $ttl - (microtime(true) * 1000 - $startTime) - $drift;if ($n >= $this->quorum && $validityTime > 0) {return ['validity' => $validityTime,'resource' => $resource,'token' => $token,];} else {foreach ($this->instances as $instance) {$this->unlockInstance($instance, $resource, $token);}}// Wait a random delay before to retry $delay = mt_rand(floor($this->retryDelay / 2), $this->retryDelay);usleep($delay * 1000);$retry--;} while ($retry > 0);return false;}public function unlock(array $lock){$this->initInstances();$resource = $lock['resource'];$token = $lock['token'];foreach ($this->instances as $instance) {$this->unlockInstance($instance, $resource, $token);}}private function initInstances(){if (empty($this->instances)) {foreach ($this->servers as $server) {list($host, $port, $timeout) = $server;$redis = new \Redis();$redis->connect($host, $port, $timeout);$this->instances[] = $redis;}}}private function lockInstance($instance, $resource, $token, $ttl){return $instance->set($resource, $token, ['NX', 'PX' => $ttl]);}private function unlockInstance($instance, $resource, $token){$script = ' if redis.call("GET", KEYS[1]) == ARGV[1] then return redis.call("DEL", KEYS[1]) else return 0 end ';return $instance->eval($script, [$resource, $token], 1);}}
使用示例
lock('test', 10000);if ($lock) {print_r($lock);} else {print "Lock not acquired\n";}}
关于php中怎么实现redis分布式锁就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流