根据 SQL 表时间戳安排 .exe 执行

Question

问题

我有一个消息记录的 SQL 表，tbl_message_queue，每个都有一个发布时间戳字段（现在或将来）。新记录不断被插入。

当发布时间戳到期时，符合条件的记录需要由控制台应用程序 .exe 处理。处理完成后，将从tbl_message_queue 中删除相应的记录。

应该减少/消除发布时间戳和执行之间的延迟时间。

选项 #1：频繁轮询

我可以通过Windows Task Scheduler 将我的 .exe 设置为每 10-15 秒运行一次。其中将包括如下 SQL 语句：

SELECT *
FROM tbl_message_queue
WHERE qmsg_ts_release <= GETDATE()

这感觉像是一种低效、蛮力、滞后友好的解决方案。但这是我最熟悉的结构。

选项 #2：重新安排 SQL 代理作业

我从未尝试过这个，但似乎它可以工作。这听起来很老套，所以如果这是一个非常糟糕的主意，请原谅我。

我可以创建一个具有CmdExec Job Step 的 SQL 代理作业，并不断重新安排该作业：

1. UPDATE qmsg_ts_release
2. INSERT tbl_message_queue
3. .exe 完成

在MIN(qmsg_ts_release) 运行下一个。

呼...我知道这听起来真的很难看，但它并没有积极的轮询，并且可能会消除任何延迟。

其他选项

对于此类问题，还有其他选择或更好的解决方案吗？我不熟悉消息队列架构中的最佳实践。

像MSMQ 或SQL Server Service Broker 这样的东西会更好地解决这类问题吗？我对其他选项知之甚少，不知道从哪里开始。

Answer 1

您的选项 2 应该可以工作，但您可能会遇到意想不到的问题，因为频繁的重新调度很可能不是 SQL 代理的常用用法，而且您几乎无法控制它。

根据您的基础架构，您可以自己实施类似的方法。我将概述算法。

首先，假设您的带有队列的表已被填充并且没有被外部进程更改。

您的控制台应用程序不会启动和停止，但会一直运行。 它启动后立即运行查询以确定位于队列顶部的消息：

SELECT TOP(1) *
FROM tbl_message_queue
ORDER BY qmsg_ts_release

应用程序检查返回消息的时间戳以查看它是过去还是将来。如果是过去，则应立即处理，消息为“过期”。如果有过期消息，则对其进行处理，将其从队列中删除，然后重复查询并查找队列中可能也过期的下一条消息，依此类推。

一旦处理完所有过期消息，循环就会停止。此时，您将获得消息的时间戳。所以，我们只需要等到未来的那一刻。让线程休眠这段时间。一旦它醒来，您就知道现在是处理消息的正确时刻。然后重复整个过程。

如果计算机上的时钟稳定并且可能的等待时间不太长，则此方法相当有效。所有时钟和计时器都会漂移，等待的时间越长，累积的误差就越多。

接下来要考虑的是将新项目添加到队列中时要做什么。将项目添加到队列的进程/过程需要一种方法来通知处理应用程序它可能需要比预期更早唤醒。但首先，做一个简单的检查。将项目添加到队列时，您可以检查队列中是否已有任何具有较小时间戳的项目。如果已经有这样的项目，您可以简单地将新项目添加到队列中，处理应用程序将照常处理它。如果检查显示新项目的时间戳早于队列中已经存在的所有其他时间戳，则意味着处理应用程序正在休眠，我们必须比预期更早唤醒它。

不幸的是，我不知道从存储过程等向外部应用程序发送信号的好方法。我想知道一个自己。在您的情况下，只要将此类项目添加到队列中，只需重新启动处理应用程序就足够了。随着处理应用程序重新启动，它会重新读取队列并相应地继续等待。

一般来说，将项目添加到队列中的进程/应用程序应该能够将更改通知工作应用程序。

我刚刚发现另一个question 说您可以使用SqlDependency 接收此类通知。