Web Garden下基于StateServer的多线程Session变量使用问题

首先得明确你遇到问题的核心原因：

1. 后台线程无HttpContext：你在后台线程里直接操作Session，但Session是和当前请求的HttpContext绑定的——后台线程启动后，原请求的上下文可能已经释放，而且Web Garden下后台线程属于某个工作进程，用户后续的Timer请求可能被分配到另一个进程，即使StateServer的Session跨进程，后台线程也无法正确访问Session的代理对象。
2. 多进程隔离：类变量是进程内的，默认的Cache也是进程级的，Web Garden的多个工作进程完全隔离，所以这些存储方式跨进程根本看不到。

下面给出一个最小改动、完全兼容原有功能的解决方案，利用你现有数据库来做状态共享——毕竟你已经有DBAccess类，不需要额外引入新依赖。

步骤1：创建临时状态表 #

先在数据库里建一张临时表，用来存储每个用户的交易状态，用SessionId作为唯一标识（如果你的系统有用户ID，用用户ID更稳妥）：

CREATE TABLE [dbo].[UserTransactionStatus] (
    [SessionId] NVARCHAR(128) PRIMARY KEY,
    [NextTransactionId] INT NULL,
    [TransactionStatus] NVARCHAR(255) NOT NULL DEFAULT 'Starting...',
    [FinalStatus] NVARCHAR(255) NULL,
    [IsCompleted] BIT NOT NULL DEFAULT 0,
    [CreatedTime] DATETIME NOT NULL DEFAULT GETDATE() -- 用于后续清理过期数据
)

步骤2：修改后台线程的状态更新逻辑 #

把原来直接写Session的代码，改成写入数据库。注意：必须在启动线程前捕获当前请求的SessionId，因为后台线程启动后HttpContext.Current可能已经失效。

修改按钮点击事件（初始化状态+启动线程） #

protected void btnTransaction_Click(object sender, EventArgs e) {
    timerTrans.Enabled = true;
    timerTrans.Interval = 200;
    string sessionId = Session.SessionID;
    string connStr = dbConnectionString;

    // 初始化当前用户的状态记录（不存在则插入）
    using (DBAccess dba = new DBAccess(connStr)) {
        dba.ExecuteNonQuery(@"
            IF NOT EXISTS(SELECT 1 FROM UserTransactionStatus WHERE SessionId = @SessionId)
            INSERT INTO UserTransactionStatus(SessionId) VALUES(@SessionId)",
            new SqlParameter("@SessionId", sessionId));
    }

    // 给后台线程传递连接字符串和SessionId（用匿名对象打包参数）
    Thread thread = new Thread(new ParameterizedThreadStart(DoAllWork));
    thread.Start(new { ConnectionString = connStr, SessionId = sessionId });
}

修改DoAllWork方法（用数据库替代Session） #

public void DoAllWork(object state) {
    // 解析传递的参数
    dynamic param = state;
    string connStr = param.ConnectionString;
    string sessionId = param.SessionId;

    using (DBAccess dba = new DBAccess(connStr)) {
        // 获取新交易ID并写入数据库
        int newTransId = dba.getNewTransactionId();
        dba.ExecuteNonQuery(@"
            UPDATE UserTransactionStatus 
            SET NextTransactionId = @TransId 
            WHERE SessionId = @SessionId",
            new SqlParameter("@TransId", newTransId),
            new SqlParameter("@SessionId", sessionId));

        // 处理每个交易，更新状态
        foreach (transaction t in transactions) {
            string statusMsg = $"Processing transaction {t.id}";
            // 更新状态到数据库
            dba.ExecuteNonQuery(@"
                UPDATE UserTransactionStatus 
                SET TransactionStatus = @Status 
                WHERE SessionId = @SessionId",
                new SqlParameter("@Status", statusMsg),
                new SqlParameter("@SessionId", sessionId));
            
            // 可选：加个小延迟，避免过于频繁的数据库操作
            Thread.Sleep(100);
        }

        // 更新最终状态
        dba.ExecuteNonQuery(@"
            UPDATE UserTransactionStatus 
            SET FinalStatus = @FinalStatus, 
                TransactionStatus = @Status, 
                IsCompleted = 1 
            WHERE SessionId = @SessionId",
            new SqlParameter("@FinalStatus", "All Transactions Completed"),
            new SqlParameter("@Status", "Done"),
            new SqlParameter("@SessionId", sessionId));
    }
}

步骤3：修改Timer轮询逻辑（从数据库读状态） #

把原来从Session读状态的代码，改成从数据库查询：

protected void timerTrans_Tick(object sender, EventArgs e) {
    string sessionId = Session.SessionID;
    string connStr = dbConnectionString;

    using (DBAccess dba = new DBAccess(connStr)) {
        // 查询当前状态
        DataRow statusRow = dba.GetDataRow(@"
            SELECT TransactionStatus, IsCompleted 
            FROM UserTransactionStatus 
            WHERE SessionId = @SessionId",
            new SqlParameter("@SessionId", sessionId));

        if (statusRow != null) {
            string currentStatus = statusRow["TransactionStatus"].ToString();
            lblStatus.Text = currentStatus;

            // 判断是否完成
            if ((bool)statusRow["IsCompleted"]) {
                lblStatus.Text = "Getting final status ...";
                billEndTime = DateTime.Now;
                ShowFinalStatus();
                timerTrans.Enabled = false;

                // 清理临时记录（可选：或者定时任务清理过期数据）
                dba.ExecuteNonQuery(@"
                    DELETE FROM UserTransactionStatus 
                    WHERE SessionId = @SessionId",
                    new SqlParameter("@SessionId", sessionId));
            }
        } else {
            lblStatus.Text = "Status not found...";
        }
    }
}

额外注意事项 #

1. SQL注入防护：所有数据库操作必须用参数化查询，上面的示例已经全部采用参数化，避免安全风险。
2. 临时表清理：可以定时清理CreatedTime超过1小时（或你设定的过期时间）的记录，避免表数据膨胀。
3. 线程安全：后台线程和Timer请求同时操作数据库，但因为是按SessionId隔离的，不会有并发问题；如果需要更严格的控制，可以加行锁。
4. 替代方案：如果不想用数据库，也可以用分布式缓存（比如Redis），把数据库操作换成缓存的读写操作，逻辑是一样的——但需要额外部署缓存服务，不如数据库方案直接。

这个方案几乎保留了你原有代码的业务逻辑，只是把状态存储从Session换成了数据库，完全适配Web Garden（甚至Web Farm）环境，而且解决了后台线程操作Session的潜在风险。

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