使用SQL Server作为多客户端并发队列

在表作为队列的场景中，以某种方式配置和查询它是至关重要的允许多个客户端同时处理队列项。

当使用带有 UPDLOCK 和 ROWLOCK 的悲观行锁定时，只有一个工作线程可以获得锁并处理一个队列项。 排。要解决此问题并启用并发处理，请考虑以下方法：

使用 OUTPUT 子句实现队列

OUTPUT 子句提供了一种原子地检索和修改行的机制。以下是如何使用 OUTPUT 子句实现队列：

with CTE as (
  SELECT TOP(1) COMMAND, PROCESSED
  FROM TABLE WITH (READPAST)
  WHERE PROCESSED = 0)
UPDATE CTE
  SET PROCESSED = 1
  OUTPUT INSERTED.*;

此查询自动执行以下步骤：

1. 使用WITH (READPAST)提示跳过任何锁定的行。
2. 选择顶部PROCESSED=0 的行。
3. 更新所选行以将其标记为已处理(PROCESSED=1).
4. 输出更新后的行，可供工作人员处理。

聚集索引优化

为了进一步优化性能，在 PROCESSED 列上创建聚集索引至关重要。这可确保数据按处理顺序存储。

CREATE CLUSTERED INDEX cdxTable on TABLE(PROCESSED, ID);

避免非标准查询

为了获得最佳吞吐量，必须避免使用上述出队操作以外的方法查询队列表。尝试查看或将表用于其他目的可能会导致死锁和性能下降。