PostgreSQL行并发更新防护：PHP网关统计计数的原子性保障

嗨，这个高并发下的计数问题我太熟了！你的场景用PostgreSQL其实有非常优雅的解决办法，我给你分两种方案讲，包括你提到的咨询锁的PHP实现，还有更高效的原子操作方案：

这种方法直接把你原来的「查→更/插」三步合并成一条原子SQL，PostgreSQL会自动处理并发冲突，完全避免计数丢失或重复插入的问题，而且性能拉满，特别适合高流量场景。

首先你需要给表加一个唯一约束，确保clientid和gatewayid的组合是唯一的（这是UPSERT生效的前提）：

ALTER TABLE client.gatewaystat_tbl ADD CONSTRAINT unique_client_gateway UNIQUE (clientid, gatewayid);

然后用这条SQL替代原来的所有逻辑：

INSERT INTO client.gatewaystat_tbl (gatewayid, clientid, statetypeid, statvalue)
VALUES (2, 1, 1, 1)
ON CONFLICT (clientid, gatewayid) DO UPDATE
SET statvalue = gatewaystat_tbl.statvalue + 1;

在PHP里直接执行这条SQL就行，不需要额外的判断逻辑——PostgreSQL会自动检查：如果这条client+gateway的记录存在，就把statvalue加1；如果不存在，就插入一条初始值为1的记录。整个过程是原子性的，并发请求不会互相干扰。

如果你因为某些复杂业务逻辑（比如除了计数还要同步更新其他关联表）必须用锁，那咨询锁是个不错的选择。下面是PHP里的具体实现：

我们用事务级咨询锁（pg_advisory_xact_lock），好处是事务结束后会自动释放锁，不用手动处理，避免锁残留。

// 建立PostgreSQL连接（用pg扩展或PDO都可以，这里用pg示例）
$conn = pg_connect("host=localhost dbname=your_db user=your_user password=your_pass");

// 用clientid和gatewayid生成唯一的锁标识（确保不同组合的锁不冲突）
$clientId = 1;
$gatewayId = 2;

// 开启事务
pg_query($conn, "BEGIN");

// 获取事务级咨询锁：用两个参数（clientId和gatewayId）生成唯一锁键
pg_query($conn, "SELECT pg_advisory_xact_lock($clientId, $gatewayId)");

// 执行你的查询和更新/插入逻辑
$result = pg_query($conn, "SELECT id FROM client.gatewaystat_tbl WHERE clientid = $clientId AND gatewayid = $gatewayId");
if (pg_num_rows($result) > 0) {
    $row = pg_fetch_assoc($result);
    pg_query($conn, "UPDATE client.gatewaystat_tbl SET statvalue = statvalue + 1 WHERE id = " . $row['id']);
} else {
    pg_query($conn, "INSERT INTO client.gatewaystat_tbl (gatewayid, clientid, statetypeid, statvalue) VALUES ($gatewayId, $clientId, 1, 1)");
}

// 提交事务，锁会自动释放
pg_query($conn, "COMMIT");

// 关闭连接
pg_close($conn);

注意事项： #

• 锁的键要和clientid+gatewayid一一对应，这样只有同一个组合的并发请求会排队，不同组合的请求互不影响，保证性能。
• 优先用事务级锁（pg_advisory_xact_lock），不要用会话级锁（pg_advisory_lock）——后者需要手动解锁，万一代码报错没执行解锁，会导致锁一直占用，阻塞后续请求。
• 这种方法的性能比UPSERT略低，因为多了锁的开销，所以只在必要时使用。

你原来的「先SELECT再UPDATE/INSERT」是两步独立操作，在高并发下会出现竞态：

• 两个请求同时查到「无记录」，然后都执行INSERT，导致重复数据；
• 两个请求同时读到statvalue=5，然后都改成6，实际应该是7，造成计数丢失。

只有把操作变成原子性的（要么UPSERT，要么加锁包裹整个逻辑），才能避免这些问题。

内容的提问来源于stack exchange，提问作者bloomwood