.NET 7 WinForms中SqlDependency事件未触发问题排查

你在.NET 7 WinForms中使用SqlDependency实现数据库变更监听时，OnDependencyChange事件未触发，且数据库无相关队列生成，结合你的代码和配置，以下是遗漏的关键步骤和修复方案：

1. 未初始化SqlDependency全局监听服务 #

SqlDependency必须在应用启动时启动全局监听服务，否则无法注册变更通知，你的代码完全缺失这一步：

• 在WinForms应用的Program.cs的Main方法中添加：

  // 启动SqlDependency监听，使用你的连接字符串
  SqlDependency.Start(LoginUserDetails.Connection);
  // 应用退出时停止监听，避免资源泄漏
  Application.ApplicationExit += (s, e) => SqlDependency.Stop(LoginUserDetails.Connection);
  

  注意：启动和停止监听使用的连接字符串必须与后续数据库操作的连接字符串完全一致。

2. 存储过程违反SqlDependency查询规则 #

SqlDependency对查询语法有严格限制，你的存储过程存在多个违规点：

• 列别名不能带空格/特殊字符：'Reste Qté'、'Poids Tot'这类带空格的别名会导致通知注册失败，必须修改为无空格的标识符，例如Reste_Qte、Poids_Tot。
• （可选）统一表所有者前缀：确保所有表引用都显式指定所有者（如dbo.Employee），避免查询歧义。

修改后的存储过程别名示例：

[Qty] - [WeldingPaintQty] AS Reste_Qte,
CAST(ProShip.[Weight] * [Quantity] AS decimal(18, 2)) AS Poids_Tot,
CONCAT(daiPaiPro.[UserID], ' ', emp.LastName_Employee, ' ', emp.FirstName_Employee) AS Utilisateur,
cust.Name AS Client,

3. SqlDependency对象被垃圾回收 #

你在SelectDataAsync中创建的SqlDependency是局部变量，方法执行完毕后会被GC回收，直接导致监听失效。需要将SqlDependency对象保留在长期存在的容器中：

• 在窗体类中声明全局变量存储引用：

  private SqlDependency _weldingDependency;
  

• 修改DataAccessLayer的方法，返回SqlDependency对象：

  public async Task<(DataTable Data, SqlDependency Dependency)> SelectDataAsync(string stored_procedure, SqlParameter[] param, OnChangeEventHandler onChangeEventHandler = null)
  {
      if (string.IsNullOrEmpty(stored_procedure))
      {
          return (null, null);
      }
  
      await Open().ConfigureAwait(false);
  
      await using var sqlCommand = new SqlCommand();
      AddSqlCommandParameters(sqlCommand, stored_procedure);
  
      if (param != null)
      {
          sqlCommand.Parameters.AddRange(param);
      }
  
      SqlDependency sqlDependency = null;
      if (onChangeEventHandler != null)
      {
          sqlDependency = new SqlDependency(sqlCommand);
          sqlDependency.OnChange += onChangeEventHandler;
      }
  
      using DataTable dt = new();
      using SqlDataAdapter da = new(sqlCommand);
      await Task.Run(() => da.Fill(dt)).ConfigureAwait(false);
  
      Close();
      return (dt, sqlDependency);
  }
  

• 在窗体的GetData方法中保存引用：

  private async Task GetData()
  {
      var result = await ClsWelding.GetWeldingPaintProductionAsync(OnDependencyChange).ConfigureAwait(false);
      GCBlack.DataSource = result.Data;
      _weldingDependency = result.Dependency; // 保留引用防止GC回收
  }
  

4. 数据库用户权限不足 #

连接数据库的用户需要以下权限才能注册变更通知：

• SUBSCRIBE QUERY NOTIFICATIONS
• VIEW DEFINITION
• Service Broker相关的SEND、RECEIVE权限

执行以下SQL为用户授权：

GRANT SUBSCRIBE QUERY NOTIFICATIONS TO [你的数据库用户名];
GRANT VIEW DEFINITION TO [你的数据库用户名];
GRANT SEND ON SERVICE::[SqlDependencyService] TO [你的数据库用户名];
GRANT RECEIVE ON QUEUE::[SqlDependencyQueue] TO [你的数据库用户名];

5. 未提前打开数据库连接 #

你的SelectDataAsync方法未提前打开连接，虽然SqlDataAdapter.Fill会自动打开连接，但SqlDependency注册时连接状态不确定可能导致失败。建议在创建SqlDependency前显式打开连接（上述修改后的SelectDataAsync已包含此步骤）。

6. 验证Service Broker状态 #

虽然你已启用Service Broker，仍需确认其状态正常：
执行SQL检查：

SELECT is_broker_enabled FROM sys.databases WHERE name = '你的数据库名';

返回值应为1，若为0，重新执行启用命令：

ALTER DATABASE [你的数据库名] SET ENABLE_BROKER WITH ROLLBACK IMMEDIATE;

内容的提问来源于stack exchange，提问作者M.Bouabdallah