利用SQL实现简单的分布式锁-php手册-PHP中文网

利用SQL实现简单的分布式锁

php中文网

发布： 2016-06-13 08:42:31

原创

1398人浏览过

华友协同办公自动化OA系统

华友协同办公管理系统(华友OA)，基于微软最新的.net 2.0平台和SQL Server数据库，集成强大的Ajax技术，采用多层分布式架构，实现统一办公平台，功能强大、价格便宜，是适用于企事业单位的通用型网络协同办公系统。系统秉承协同办公的思想，集成即时通讯、日记管理、通知管理、邮件管理、新闻、考勤管理、短信管理、个人文件柜、日程安排、工作计划、工作日清、通讯录、公文流转、论坛、在线调查、

查看详情

利用sql实现简单的分布式锁

分布式锁和普通锁的主要区别在于参与主体跨不同节点，因此需要考虑到节点失效和网络故障的问题。搞清楚问题要点，可以用各种不同的东西去实现，比如redis，zookeeper等。但是其实用sql实现也是非常容易的，下面以postgresql为例进行说明。

1. 方法1：会话锁

利用postgresql中特有的排他会话级别咨询锁。
pg_advisory_lock(key bigint)
pg_advisory_unlock(key bigint)
pg_try_advisory_lock(key bigint)

详细参考: http://www.postgres.cn/docs/9.4/functions-admin.html#functions-advisory-locks-table

这种锁是会话级的，在释放锁之前，锁的获得得者必须一直持有这个会话，也就是连接，否则锁就会被释放。
这个特性自然而然地解决了锁的获得者发生故障时锁的释放问题。
但是，对于需要长时间持有的锁，它会产生长连接，而数据库的连接是比较耗资源的，往大了配一般也就几千个，这是需要注意的地方。
另外一个需要考虑的问题是，当网络或节点发生故障时连接的两端未必能立刻感知到，因此tcp的keepalive是必须的，幸好postgresql的客户端和服务端都支持这个设置。
下面是服务端的参数：
tcp_keepalives_idle
tcp_keepalives_interval
tcp_keepalives_count

2. 方法2：期限锁

锁对象是持久的，为防止拿到锁的客户端奔溃导致锁无法释放，每个锁都有一个过期期限。
在postgresql中可以按下面的方式实现

建表

postgres=# create table distlock(id int primary key,expired_time interval,owner text,ts timestamptz);
create table
postgres=# insert into distlock(id) values(1);
insert 0 1

加锁和续期

postgres=# update distlock set owner='node1',ts=now(),expired_time=interval '20 second' where id=1 and (owner='node1' or owner is null or now() > ts + expired_time);
update 1

获得锁的客户端如果要长时间持有锁必须定期执行相同的方法对锁进行续租，否则会丢锁。

此时，其它客户端取锁会失败

postgres=# update distlock set owner='node2',ts=now(),expired_time=interval '20 second' where id=1 and (owner='node2' or owner is null or now() > ts + expired_time);
update 0

等锁过期后取锁成功

postgres=# update distlock set owner='node2',ts=now(),expired_time=interval '20 second' where id=1 and (owner='node2' or owner is null or now() > ts + expired_time);
update 1

释放锁