如何获取.NET提交的SQL Server作业的Session ID以支持作业终止操作

核心问题解答 #

提交作业时可以直接获取到对应的Session ID（SQL Server内称为SPID），不需要额外的监听或查询操作。 #

具体实现步骤 #

1. 作业提交时绑定SPID #

你在开启数据库连接执行INSERT/UPDATE作业前，先执行系统内置函数@@SPID即可拿到当前连接对应的会话ID，将其和你的业务作业ID绑定存储即可。
示例代码：

// 引入命名空间
using Microsoft.Data.SqlClient;

// 作业提交逻辑
public async Task SubmitJob(Guid jobId, string execSql)
{
    var conn = new SqlConnection("你的SQL Server连接字符串");
    await conn.OpenAsync();

    // 直接获取当前会话SPID
    using var getSpidCmd = new SqlCommand("SELECT @@SPID", conn);
    int spid = Convert.ToInt32(await getSpidCmd.ExecuteScalarAsync());

    // 绑定SPID和业务作业ID，可存在内存字典、Redis或业务监控表中
    JobRunningCache.Bind(jobId, spid);

    // 异步执行后台作业，不阻塞主线程
    _ = Task.Run(async () =>
    {
        try
        {
            using var jobCmd = new SqlCommand(execSql, conn);
            jobCmd.CommandTimeout = 0; // 后台长作业取消超时限制
            await jobCmd.ExecuteNonQueryAsync();
            // 此处添加作业执行成功的业务逻辑
        }
        catch (SqlException ex) when (ex.Number is 109 or 233)
        {
            // 捕获到会话被KILL的异常，标记作业为手动终止状态
            JobRunningCache.MarkAsCancelled(jobId);
        }
        catch (Exception ex)
        {
            // 其他异常处理逻辑
        }
        finally
        {
            // 作业结束后解绑SPID，关闭连接
            JobRunningCache.Unbind(jobId);
            await conn.CloseAsync();
            conn.Dispose();
        }
    }, CancellationToken.None);
}

2. 终止指定作业逻辑 #

需要终止作业时，取出对应作业绑定的SPID，执行KILL命令即可终止对应会话的所有执行操作：

public async Task CancelJob(Guid jobId)
{
    if (!JobRunningCache.TryGetSpid(jobId, out int spid))
    {
        // 作业已结束，无需终止
        return;
    }

    using var conn = new SqlConnection("你的SQL Server连接字符串");
    await conn.OpenAsync();
    using var killCmd = new SqlCommand($"KILL {spid}", conn);
    // 执行KILL命令的账号需要持有ALTER ANY CONNECTION权限
    await killCmd.ExecuteNonQueryAsync();
}

注意事项 #

• 执行作业的SqlConnection在作业运行期间必须保持打开状态，连接关闭后SPID会被SQL Server回收复用，可能出现误杀其他会话的问题
• 不要复用短期连接提交长耗时作业，避免SPID提前被回收
• 如果需要更高的准确性，可以在执行KILL前先查询sys.sysprocesses系统视图确认SPID对应的执行语句是否为目标作业SQL，避免异常解绑导致的误操作

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