PostgreSQL死锁相关

原创
09/02 17:33
阅读数 3.9K

作者:阎书利

记得原来一老大哥说他运维ORACLE,发现死锁的时候,总想着缓一缓,再拖一拖,没准再查看的时候。死锁就已经自己释放掉,不需要处理了(运维的无奈)。而在PostgreSQL中,事务可以按照任意顺序加锁。且PostgreSQL也有着其死锁处理机制。

当进程请求加锁的时候,如果失败,会进入等待队列。如果在队列中已经存在一些进程要求本进程中已经持有的锁,那么为了尽量避免死锁,可以把本进程插入到它们的前面。当一个锁被释放时,将会试图唤醒等待队列里的进程。这个行为预防了死锁的产生。

但是这种方法不能完全避免死锁的产生,PostgreSQL提供如下图的死锁检验机制。


且PostgreSQL使用等待图(WFG)来检验死锁,WFG为一个有向图,顶点ABC表示申请加锁的进程,XY有向边表示依赖关系。


图中的虚线为soft edge,实线为hard edge

当进程A和进程B都在某个锁的等待队列,且进程A在进程B的后边,两个进程的加锁要求冲突,进程A在等待进程B,则存在从A到B的有向边,名为soft edge;如果进程A的加锁要求和进程B已经持有的锁冲突,这时候从A指向B的为hard edge。

系统出现死锁当且仅当WFG出现环,如果WFG中有soft edge环,则可以通过拓扑排序对队列进行重排,尝试消除死锁。从顶点开始,沿着WFG有向边走,如果能回到顶点,说明出现死锁。如果路径没有出现soft edge,则直接终止此事务。如果存在soft edge,则记录所有 的soft edge,并尝试对这个集合进行调整。

通过拓扑排序找到可行的方案,则采用此方案,消除死锁,(不一定是最优的),否则死锁清除失败,终止该事务。

以下为pg12.1有向边的数据结构

/*
 * One edge in the waits-for graph.
 *
 * waiter and blocker may or may not be members of a lock group, but if either
 * is, it will be the leader rather than any other member of the lock group.
 * The group leaders act as representatives of the whole group even though
 * those particular processes need not be waiting at all.  There will be at
 * least one member of the waiter's lock group on the wait queue for the given
 * lock, maybe more.
 */
typedef struct
{
    PGPROC     *waiter;         /* the leader of the waiting lock group */
    PGPROC     *blocker;        /* the leader of the group it is waiting for */
    LOCK       *lock;           /* the lock being waited for */
    int         pred;           /* workspace for TopoSort */
    int         link;           /* workspace for TopoSort */
} EDGE;

PostgreSQL对进程的检验过程为:

  1. 递归试图检验和消除死锁。

  2. 测试当前队列状态是否会发生死锁,如果不满足约束性检查,则死锁。对soft edge调整,并检验是否合法。

  3. 判断是否出现环,如果存在且不能调整,则死锁。


相关参数:

1. Postgresql中,有一个死锁等待事件的参数,默认是1s,也就是是说Postgresql后台进程会以1s的频率来检测是否存在死锁。


锁等待超时

2. Postgresql中同样可以设置锁等待的超时时间,意味着当前事务在请求一个锁的时候,一旦等待时长超出指定的时间,当前语句被中止。该参数的默认值为0,意味着发生锁等待的时候永远不超时,一直等待下去。默认情况下,锁超时之后,当前Session的任何语句都 会被回滚,即便是执行一个commit。


以下为标准锁的锁模式以及对应的操作


锁手动处理:

1.查询阻塞:

postgres=# SELECT w.query as waiting_query,
postgres-# w.pid as w_pid,
postgres-# w.usename as w_user,
postgres-# l.query as locking_query,
postgres-# l.pid as l_pid,
postgres-# l.usename as l_user,
postgres-# t.schemaname || '.' || t.relname as tablename
postgres-# from pg_stat_activity w join pg_locks l1 on w.pid = l1.pid
postgres-# and not l1.granted join pg_locks l2 on l1.relation = l2.relation
postgres-# and l2.granted join pg_stat_activity l on l2.pid = l.pid join pg_stat_user_tables t on l1.relation = t.relid;
   waiting_query    | w_pid |  w_user  |            locking_query             | l_pid |  l_user  |   tablename
--------------------+-------+----------+--------------------------------------+-------+----------+----------------
truncate tab_ysl ; |  5391 | postgres | update tab_ysl set id =9 where id=1; |  5524 | postgres | public.tab_ysl
(1 row)

//其中l_pid为阻塞者的pid,w_pid为被阻塞者的pid。

2.查询表持有的锁:

postgres=# select oid from pg_class where relname= 'tab_ysl';
 oid
------
24580 
(1 row)

使pg_class.oid=pg_locks.relation,则表tab_ysl上持有的锁为,RowExclusiveLock和
AccessExclusiveLock ,对应了update和truncate的操作。

postgres=# select * from pg_locks where pid in ('5524','5391');
   locktype    | database | relation | page | tuple | virtualxid | transactionid | classid | objid | objsubid | virtualtransaction | pid  |        mode         | granted | fastpath
---------------+----------+----------+------+-------+------------+---------------+---------+-------+----------+--------------------+------+---------------------+---------+----------
relation      |    13593 |     2659 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2658 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     1249 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     3455 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2663 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2662 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2685 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2684 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     2615 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
relation      |    13593 |     1259 |      |       |            |               |         |       |          | 7/11               | 5524 | AccessShareLock     | t       | t
virtualxid    |          |          |      |       | 7/11       |               |         |       |          | 7/11               | 5524 | ExclusiveLock       | t       | t
virtualxid    |          |          |      |       | 6/181      |               |         |       |          | 6/181              | 5391 | ExclusiveLock       | t       | t
transactionid |          |          |      |       |            |           512 |         |       |          | 7/11               | 5524 | ExclusiveLock       | t       | f
relation      |    13593 |    24580 |      |       |            |               |         |       |          | 7/11               | 5524 | RowExclusiveLock    | t       | f
transactionid |          |          |      |       |            |           513 |         |       |          | 6/181              | 5391 | ExclusiveLock       | t       | f
relation      |    13593 |    24580 |      |       |            |               |         |       |          | 6/181              | 5391 | AccessExclusiveLock | f       | f
(16 rows)

杀掉阻塞者的进程,释放锁:

select pg_cancel_backend('上面查询到的阻塞着的pid');

##注意##pg_cancel_backend(‘阻塞者的pid值’);只能杀死select语句,对其他语句不生效,杀了之后查询发现还存在,考虑使用pg_terminate_backend(‘进程ID’);



规模空前,再创历史 | 2020 PG亚洲大会圆满结束
PG ACE计划的正式发布
三期PostgreSQL国际线上沙龙活动的举办
六期PostgreSQL国内线上沙龙活动的举办

中国PostgreSQL分会与腾讯云战略合作协议签订


PostgreSQL 13.0 正式版发布通告

深度报告:开源协议那些事儿

从“非主流”到“潮流”,开源早已值得拥有

Oracle中国正在进行新一轮裁员,传 N+6 补偿

PostgreSQL与MySQL版权比较

新闻|Babelfish使PostgreSQL直接兼容SQL Server应用程序

四年三冠,PostgreSQL再度荣获“年度数据库”


更多新闻资讯行业动态技术热点,请关注中国PostgreSQL分会官方网站

https://www.postgresqlchina.com

中国PostgreSQL分会生态产品

https://www.pgfans.cn

中国PostgreSQL分会资源下载站

https://www.postgreshub.cn


点赞在看分享收藏

本文分享自微信公众号 - 开源软件联盟PostgreSQL分会(kaiyuanlianmeng)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

展开阅读全文
打赏
1
2 收藏
分享
加载中
更多评论
打赏
0 评论
2 收藏
1
分享
返回顶部
顶部