Skip to content

12 V2.3.0升级特性pg_unlock使用说明

JennyJennyChen edited this page Jan 1, 2022 · 4 revisions

1. 安装 pg_unlock 工具:

连接任意主CN:

CREATE EXTENSION pg_unlock;

2. 构造分布式死锁用例

session1—cn1:

postgres=# begin; select * from a; 

session2—cn2:

postgres=# begin; select * from b; 

session1—cn1:

postgres=# drop table b;

session2—cn2:

postgres=# drop table a;

3. 查找事务间依赖关系(不检测死锁)

session3—cn1:

postgres=# select * from pg_unlock_check_dependency();
 dependencyid |      dependency       |    nodename     |              query              
--------------+-----------------------+-----------------+---------------------------------
            0 | 0:1998:5 --> 1:1995:1 | cn001 --> cn002 | drop table b; --> drop table a;
            1 | 1:1995:1 --> 0:1998:5 | cn002 --> cn001 | drop table a; --> drop table b;
(2 rows)

上述用例中的事务间等待关系。其中 dependencyid 表示记录数, dependency 中展示了事务间等待关系,其中每个事务使用其 global transactionid 来表示。"0:1998:5 --> 1:1995:1"表示记录0的事务"1998:5"等待记录1的事务"1995:1"。

4. 查找集群中的死锁(不解开死锁)

postgres=# select * from pg_unlock_check_deadlock();
 deadlockid |                   deadlocks                   | nodename |     query     
------------+-----------------------------------------------+----------+---------------
          0 | 0:1998:5       (100.105.50.198 :30004       )+| cn001   +| drop table b;+
            | 1:1995:1       (100.105.50.198 :30005       ) | cn002    | drop table a;
(1 row)

上述用例中存在的所有死锁。其中 deadlockid 表示死锁的记录数,deadlocks 中展示了每个死锁中包含的所有事务(这些事务之间由“+”号连接),并且还打印出了每个事务的发起节点的 ip 和 port。

5. 检测死锁并解开死锁

postgres=# select * from pg_unlock_execute();
 executetime | txnindex |                  rollbacktxnifo                  | nodename | cancel_query  
-------------+----------+--------------------------------------------------+----------+---------------
           0 |        0 | 0:1998:5       (100.105.50.198 :30004          ) | cn001    | drop table b;
(1 row)

上述用了解开死锁所结束的事务。其中 executetime 表示执行结束事务的次数,因为若集群中在第一次结束事务解开死锁之后,可能形成新的死锁或者第一次检测过程中死锁数目大于 50,只解开了部分死锁;txnindex 表示结束事务的记录数;rollbacktxninfo 表示结束事务的信息,同样这个信息里包括事务的 global transactionid, ip 和 port。

6. 分析过程

1)在上述用例中,在 CN1 中发起了事务“1998:5”,在 CN2 中发起了事务“1995:1”。
2)首先,在两个 session 中执行“select”语句,事务“1998:5”获取了表 a 的 ACCESS SHARE 锁,事务“1995:1”获取了表 b 的 ACCESS SHARE 锁。
3)然后,两个 session 中分别执行“drop table”语句,事务“1998:5”申请表 b 的 ACCESS EXCLUSIVE 锁,这与“1995:1”持有的表 b 的 ACCESS SHARE 锁冲突,因此 “1998:5 --> 1995:1”。同理,也有“1995:1 --> 1998:5”。
4) 至此两个事务间死锁形成。由上述可知,检测到死锁之后,程序结束了事务 “1998:5”。