sql-server - 使用 SQL Server 2000 表作为工作队列时，有哪些方法可以编写可伸缩服务？

Question

如果我有一个 SQL Server 2000 数据库表用作要执行的工作队列，以可扩展的方式执行该工作的最佳方法是什么？场景:有一个 Windows 服务将为表中的每一行执行一些可能长时间运行的工作。当只有一项服务正在运行时，很容易获取前 10 或 100 行，执行工作(即使以多线程方式)，然后更新这 10 或 100 行以表明工作已完成。如果我想在 2 个服务器上运行相同的服务，我需要一个锁定机制，这样服务就不会获取相同的行。我最初的想法是在表上添加一个字段，指示在执行工作时该行被锁定，因此服务将更新此“锁定”字段，直到工作完成，并且在选择一组要处理的行时确保行没有被锁定。

这是处理此类工作的最佳方式，还是可以使用数据库级行锁定来完成同样的工作？我知道更理想的解决方案可能是消息队列，但假设我想为工作队列使用数据库表。此外，有人建议这种类型的事情在 Oracle 世界中更为直接，其中数据库级行锁定将是解决方案，我在 SQL Server 2000 上使用行锁定时运气不佳，但可能会遗漏一些东西。

更新:添加标签

Answer 1

如果您确实选择使用数据库表而不是消息队列框架，则可以使用以下模式:

在您的队列表中添加一列用于拥有 worker 。当工作人员寻找新工作时，它可以查询队列表以查找工作列为空的队列中的下一个工作:

SELECT TOP 1 JobId, JobData FROM Queue WHERE Worker IS NULL ORDER BY QueueTime

然后工作人员可以尝试通过执行更新语句来声明作业的所有权:

UPDATE Queue SET Worker = 'workerid' WHERE JobId = 'jobid' AND Worker IS NULL

如果没有行受到此更新语句的影响，则工作人员可以假设另一个工作人员抢先获得所有权，从而继续下一个工作。如果 worker 成功更新了 worker 列，它就可以完成工作。

您还应该跟踪崩溃或挂起的工作线程，并为挂起或崩溃的工作线程声明的作业重置工作列。然后这些工作将由其他 worker 接手。请注意，这意味着作业需要设计为可以重试。可以通过让工作人员定期对工作台执行 ping 操作来跟踪挂起或崩溃的工作人员。