当前位置: 首页 > news >正文

使用php和redis实现分布式锁

实现分布式锁是在分布式环境中确保资源独占性的重要手段。在这里,我将使用 PHP 和 Redis 来展示如何实现基于 Redis 的分布式锁。

首先,我们需要使用 Redis 的 SET 指令来尝试获取锁,并设置一个过期时间,确保锁不会永久存在。在 Redis 中,我们可以利用 SET 指令的特性,例如在给定的键不存在时设置键的值并设置过期时间来实现分布式锁。

下面是一个使用 PHP 和 Redis 实现分布式锁的示例:

<?phpclass RedisLock
{private $redis;private $lockKey;private $timeout; // 锁的超时时间,单位:秒public function __construct($redis, $lockKey, $timeout = 10){$this->redis = $redis;$this->lockKey = $lockKey;$this->timeout = $timeout;}public function acquireLock(){$startTime = time();$expiry = $startTime + $this->timeout + 1; // 锁的超时时间加一,确保不会因为客户端时间偏差导致误判while (time() < $expiry) {$result = $this->redis->set($this->lockKey, 1, ['NX', 'EX' => $this->timeout]);if ($result === true) {return true; // 获取锁成功}usleep(10000); // 等待10毫秒后重试}return false; // 获取锁超时}public function releaseLock(){$this->redis->del($this->lockKey);}
}// 使用示例
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);$lockKey = 'my_distributed_lock';
$lock = new RedisLock($redis, $lockKey);if ($lock->acquireLock()) {try {// 在获取到锁之后,执行需要加锁的代码块echo "Lock acquired! Performing critical section...\n";sleep(5); // 模拟需要加锁保护的代码echo "Critical section complete.\n";} finally {$lock->releaseLock(); // 释放锁}
} else {echo "Failed to acquire lock within specified timeout.\n";
}$redis->close();

在上面的示例中,我们首先创建了一个 RedisLock 类,该类负责封装了获取锁和释放锁的逻辑。在主程序中,我们实例化 RedisLock 对象,并调用 acquireLock 方法来尝试获取锁。如果获取锁成功,则执行需要加锁保护的关键代码块;如果获取锁失败(超时),则输出获取锁失败的信息。

在关键代码块执行完成后,我们使用 finally 块确保无论如何都会释放锁,调用 releaseLock 方法来释放锁资源。

需要注意的是,在实际应用中,分布式锁的实现可能需要考虑更多的复杂性,例如处理锁的续约、处理死锁等情况。此外,Redis 本身提供了一些针对分布式锁的优化方案,例如使用 Redlock 算法来实现更加可靠的分布式锁,你可以根据具体需求来选择合适的方案。

更详细请看
https://blog.csdn.net/qq_42133326/article/details/136454740
https://www.cnblogs.com/phpphp/p/18091067

http://www.lryc.cn/news/349777.html

相关文章:

  • 大龄程序员是否要入职嵌入式python岗位?
  • STL—string类(1)
  • 科技查新中化工领域查新点如何确立与提炼?案例讲解!
  • 国网698.45报文解析工具
  • 留学资讯 | 2024英国学生签证申请需要满足哪些条件?
  • Python 中的分步机器学习
  • C++错题集(持续更新ing)
  • 静态IP代理:网络世界的隐秘通道
  • 信号和槽的其他说明和优缺点
  • 手工创建 kamailio database tables
  • SpringBoot接收参数的19种方式
  • Disk Map for Mac,让您的Mac更“轻”松
  • 【二叉树】(三)二叉树的基础修改构造及属性求解2
  • PyCharm2024安装教程
  • JavaScript基础知识强化:变量提升、作用域逻辑及TDZ的全面解析
  • [Cesium]Cesium基础学习——Primitive
  • java相等忽略音调
  • 自养号测评实战指南:Shopee、Lazada销量翻倍不再是难题
  • 【Java开发面试系列】JVM相关面试题(精选)
  • 解决Win11下SVN状态图标显示不出来
  • 代码随想录训练营第四十天 | 343. 整数拆分、96.不同的二叉搜索树
  • python爬取数据并将数据写入execl表中
  • Linux动静态库
  • 线程与进程___(一)
  • Google IO 2024有哪些看点呢?
  • 纯血鸿蒙APP实战开发——Navigation页面跳转对象传递案例
  • Windows C++ 读取、修改配置文件.ini
  • 物联网D3——按键控制LED、光敏传感蜂鸣器
  • Spring初学入门(跟学笔记)
  • 二进制部署k8s---下篇