[AIGC] 分布式锁及其实现方式详解与Python代码示例

当你处理分布式系统的并发问题时,你可能需要使用一把全局性的锁来确保在多个进程或线程间顺序执行一些任务。这就是"分布式锁"的概念。在本文中,我们将详细介绍并演示如何在MySQL、Redis以及ZooKeeper中实现分布式锁,并使用Python来提供示例代码。


文章目录

    • 什么是分布式锁?
    • 分布式锁的实现方式
      • MySQL的分布式锁
      • Redis的分布式锁
      • ZooKeeper的分布式锁

什么是分布式锁?

在简单的理解中, 分布式锁就是一个能在分布式系统中多个节点间同步的锁。分布式锁的功能就像传统的单节点锁一样,但是它可以帮助你在网络的多个节点中对资源进行同步。

分布式锁的实现方式

那么我们如何来实现一个分布式锁呢?实际上,有许多方式可以实现。这里我们将会探讨使用MySQL、Redis和ZooKeeper三种不同的方式来实现分布式锁,并使用Python作为示例编程语言。

MySQL的分布式锁

MySQL数据库可以使用GET_LOCK()函数来实现分布式锁。以下是使用Python实现MySQL分布式锁的简单例子:

import pymysql.cursors# 创建数据库连接
connection = pymysql.connect(host='localhost', user='user', password='passwd', db='db', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)try:with connection.cursor() as cursor:# 获取锁sql = "SELECT GET_LOCK('my_lock',10)"cursor.execute(sql)result = cursor.fetchone()["GET_LOCK('my_lock',10)"]if result == 1:print("Get the lock.")# 执行需要同步的代码# ...# 释放锁sql = "DO RELEASE_LOCK('my_lock')"cursor.execute(sql)else:print("Fail to get the lock.")
finally:connection.close()

上述代码中, GET_LOCK('my_lock',10)尝试去获取名为my_lock的锁,并允许等待10秒的时间,RELEASE_LOCK('my_lock')用于释放锁。

Redis的分布式锁

在Redis中,我们可以使用SETNXEXPIRE命令来实现简单的分布式锁。以下是Python示例代码:

import redis
import time# 创建Redis连接
r = redis.Redis(host='localhost', port=6379, db=0)def acquire_lock(lockname, acquire_time=10, lock_timeout=10):identifier = str(time.time())end = time.time() + acquire_timewhile time.time() < end:if r.setnx(lockname, identifier):r.expire(lockname, lock_timeout)return identifierelif not r.ttl(lockname):r.expire(lockname, lock_timeout)time.sleep(0.001)return Falsedef release_lock(lockname, identifier):pipe = r.pipeline(True)while True:try:pipe.watch(lockname)if pipe.get(lockname).decode() == identifier:pipe.multi()pipe.delete(lockname)pipe.execute()return Truepipe.unwatch()breakexcept redis.exceptions.WatchError:continuereturn Falselockname = 'lock:resource_name'# 获取锁lock = acquire_lock(lockname)if lock:print("Get the lock.")# 执行需要同步的代码# ...# 释放锁release_lock(lockname, identifier)else:print("Fail to get the lock.")

acquire_lock()函数尝试设置一个锁,如果当前锁不存在或已过期,acquire_lock()返回True, 表明我们成功获取了锁;若锁已经被其他客户端持有,那么返回False。 当我们完成了同步的代码后,调用 release_lock()函数来释放锁,这样其他客户端就可以获取到锁了。

ZooKeeper的分布式锁

我们也可以使用ZooKeeper实现分布式锁。Python中有一个库叫做 Kazoo,它是一个用来与ZooKeeper进行交互的Python库。以下是使用Kazoo库来实现ZooKeeper分布式锁的Python示例代码:

from kazoo.client import KazooClient
from kazoo.recipe.lock import Lock# 创建 ZooKeeper 客户端
zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()# 创建锁
lock = zk.Lock("/mylock", "my-identifier")# 获取锁
if lock.acquire(blocking=True, timeout=None):print("Get the lock.")# 执行需要同步的代码# ...# 释放锁lock.release()
else:print("Fail to get the lock.")# 按需停止和启动 ZooKeeper 客户端
zk.stop()

上述代码中,我们首先使用KazooClient连接到Zookeeper服务器,然后使用zk.Lock创建一个锁。 如果成功获取了锁,我们就可以执行需要同步的代码。当我们执行完毕后,调用lock.release()释放锁。

到这里,我们已经讲解了如何在MySQL、Redis和ZooKeeper中实现分布式锁并提供了Python版本的示例代码。 请注意,实现分布式锁的方式会因不同的应用和需求而异,在使用时应根据具体情况来选择最合适的实现方式。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/801597.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Rust 实战练习 - 9. 文本编码,URL编码,加密解密

编解码 编程工作中&#xff0c;很复杂的一个环节的就是编解码和多语言。这里只讨论编解码的工作。 目标&#xff1a; 常见文本编码的转换&#xff08;GBK, Shift-JIS, UTF8, Unicode, ASCII)Web中常用的编码常见的加密算法(md5, sha1, HMAC, AES/DES, RSA) encoding/decodi…

Web 后台项目,权限如何定义、设置、使用:菜单权限、按钮权限 ts element-ui-Plus

Web 后台项目&#xff0c;权限如何定义、设置、使用&#xff1a;菜单权限、按钮权限 ts element-ui-Plus 做一个后台管理项目&#xff0c;里面需要用到权限管理。这里说一下权限定义的大概&#xff0c;代码不多&#xff0c;主要讲原理和如何实现它。 一、权限管理的原理 权限…

自动驾驶基础技术-无迹卡尔曼滤波UKF

自动驾驶基础技术-无迹卡尔曼滤波UKF Unscented Kalman Filter是解决非线性卡尔曼滤波的另一种思路&#xff0c;它利用Unscented Transform来解决概率分布非线性变换的问题。UnScented Kalman Filter不需要像Extended Kalman Filter一样计算Jacobin矩阵&#xff0c;在计算量大…

Pixel 手机上连接提示受阻,无法上网-解决方法

命令行中输入 adb shell settings delete global captive_portal_https_urladb shell settings delete global captive_portal_http_url输入服务器信息 adb shell settings put global captive_portal_http_url http://connect.rom.miui.com/generate_204adb shell settings …

从零开始:构建、打包并上传个人前端组件库至私有npm仓库的完整指南

文章目录 一、写组件1、注册全局组件方法2、组件13、组件2 二、测试三、发布1、配置package.json2、生成库包3、配置发布信息4、发布 四、使用1、安装2、使用 五、维护1、维护和更新2、注意事项 一、写组件 确定组件库的需求和功能&#xff1a;在开始构建组件库之前&#xff0c…

基于jenkins+gitlab+docker部署zabbix

背景 我现在已经在一台服务器上部署了jenkins和gitlab&#xff0c;现在有一个场景是需要在服务器上再部署一个zabbix&#xff0c;需要通过jenkins加上gitlab部署&#xff0c;并且要求zabbix是通过docker部署的 前提条件 jenkins、gitlab已完成部署并能正常访问&#xff0c;服…

再探Java为面试赋能(二)Java基础知识(二)反射机制、Lambda表达式、多态

文章目录 前言1.4 反射机制1.4.1 Class对象的获取1.4.2 Class类的方法1.4.3 通过反射机制修改只读类的属性 1.5 Lambda表达式1.5.1 函数式接口1.5.2 Lambda表达式的使用 1.6 多态1.6.1 多态的概念1.6.2 多态的实现条件1.6.3 重载&#xff08;Overload&#xff09;和重写&#x…

大数据之搭建Hive组件

声明&#xff1a;所有软件自行下载&#xff0c;并存放到统一目录中 1.Hive组件的安装配置 1.1实验环境 服务器集群3 个以上节点&#xff0c;节点间网络互通&#xff0c;各节点最低配置&#xff1a;双核 CPU、8GB 内存、100G 硬盘运行环境CentOS 7.4服务和组件完成前面章节实验…

PyCharm详细安装教程与高效使用指南

引言 PyCharm&#xff0c;作为一款广受Python开发者青睐的集成开发环境&#xff08;IDE&#xff09;&#xff0c;以其强大的代码编辑、调试、版本控制以及项目管理功能&#xff0c;极大地提升了开发效率与编程体验。对于初次接触或希望深入掌握PyCharm的用户来说&#xff0c;正…

Spring Boot整合MyBatis-Plus以及实现分页

MyBatis-Plus 是 MyBatis 的一个增强工具包&#xff0c;它在原有的 MyBatis 框架之上提供了更多便捷的功能和增强&#xff0c;有助于简化开发流程、提高开发效率。以下是 MyBatis-Plus 的一些主要特点和功能&#xff1a; CRUD 操作增强&#xff1a; MyBatis-Plus 提供了一套强大…

HTTP 状态码有哪些?分别表示什么?

状态码由三位数字组成&#xff0c;第一位数字表示响应的类型&#xff0c;常用的状态码有五大类&#xff1a; 1xx&#xff1a;表示服务器已接收了客户端请求&#xff0c;客户端可继续发送请求 2xx&#xff1a;表示服务器已成功接收到请求并进行处理 200 OK&#xff1a;表示客户…

Java基础笔记(一)

一、面向对象高级基础 1.Java的动态绑定机制 public class DynamicBinding {public static void main(String[] args) {//a 的编译类型 A, 运行类型 BA a new B();//向上转型System.out.println(a.sum());//40 子类sum()注释后-> 30System.out.println(a.sum1());//30 子类…

android-自定义TextView在文字内容末尾添加图片icon、可以添加间距

样式示意图 自定义属性 style.xml <declare-styleable name"IconLabelTextView"><attr name"iconSrc" format"reference"/><attr name"iconPaddingStart" format"dimension"/><attr name"iconPad…

访问网站显示不安全是什么原因?怎么解决?

访问网站时显示“不安全”&#xff0c;主要原因以及解决办法&#xff1a; 1.没用HTTPS加密&#xff1a;网站还在用老的HTTP协议&#xff0c;数据传输没加密&#xff0c;容易被人偷看或篡改。解决办法是网站管理员启用HTTPS&#xff0c;也就是给网站装个“SSL证书”。这个是最常…

模块十三 异常_Object

回顾与重点 模块十二回顾 权限修饰符&#xff1a; public → protected → 默认 → private a. 构造一般用public&#xff1a;便于new对象 b. 成员方法一般用public&#xff1a;便于调用 c. 属性一般用private&#xff1a;封装思想 final&#xff1a;最终的 a. 修饰类&#x…

k8s_入门_kubelet安装

安装 在大致了解了一些k8s的基本概念之后&#xff0c;我们实际部署一个k8s集群&#xff0c;做进一步的了解 1. 裸机安装 采用三台机器&#xff0c;一台机器为Master&#xff08;控制面板组件&#xff09;两台机器为Node&#xff08;工作节点&#xff09; 机器的准备有两种方式…

前端开发之el-table(vue2中)固定列fixed滚动条被固定列盖住

固定列fixed滚动条被固定列盖住 效果图前言解决方案 效果图 前言 在使用fixed固定列的时候会出现滚动条被盖住的情况 解决方案 改变el-table固定列的计算高度即可 .el-table {.el-table__fixed-right,.el-table__fixed {height:auto !important;bottom:15px !important;}}

数据结构(七)——查找的基本概念

七、查找 7.1 查找的基本概念 7.1.1 基本概念 查找 —— 在数据集合中寻找满⾜某种条件的数据元素的过程称为查找 查找表&#xff08;查找结构&#xff09;—— ⽤于查找的数据集合称为查找表&#xff0c;它由同⼀类型的数据元素&#xff08;或记录&#xff09;组成 关键字 …

Unity抛物线目标点打击

工具类 public class ShootTool {private Transform start, target, control;private float speed, height;private Vector3 moveDir Vector3.zero;private Vector3[] moveNode;private int moveIndex 5;private int segmentNumber 30;private LineRenderer lineRenderer …

Golang | Leetcode Golang题解之第18题四数之和

题目&#xff1a; 题解&#xff1a; func fourSum(nums []int, target int) (quadruplets [][]int) {sort.Ints(nums)n : len(nums)for i : 0; i < n-3 && nums[i]nums[i1]nums[i2]nums[i3] < target; i {if i > 0 && nums[i] nums[i-1] || nums[i]…