如何通知其他用户对数据所做的更改

Question

我们有一个供许多用户使用的 ASP.NET 应用程序。此应用程序正在使用自定义数据库。每当一位用户进行更改时，我们都会将更改保存到自定义数据库的审核表中。

现在我们需要通知其他已登录的用户有关此更改...如何做到这一点？

我正在考虑这个解决方案，但它可能有点矫枉过正？

• 每当表更改时以某种方式创建一个 sql 触发器。在文件系统的文本文件中创建一条记录

• 创建一个 Web 服务来持续检查是否有任何新内容添加到文件系统以及是否向其他用户显示通知。

我正在使用文件系统，因为我不想杀死 sql。

Answer 1

在此示例中，我创建了一个非常简单的带有网格的 WPF 应用程序，模拟了一些股票价值。

让我们开始假设以下数据库表：

CREATE TABLE [dbo].[Stocks]( [Code] [nvarchar](50) NULL, [Name] [nvarchar](50) NULL, [Price] [decimal](18, 0) NULL) GO INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'MCD', N'McDonald Corp', CAST(333 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'NKE', N'Nike Inc', CAST(240 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'DIS', N'Walt Disney Co', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'UTX', N'United Technologies Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'MSFT', N'Microsoft Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'PFE', N'Pfizer Inc', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'INTC', N'Intel Corp', CAST(130 AS Decimal(18, 0))) INSERT [dbo].[Stocks] ([Code], [Name], [Price]) VALUES (N'KO', N'Coca Cola Co', CAST(130 AS Decimal(18, 0))) GO

此表会不断更新新的库存值。我们希望在不使用任何轮询系统的情况下不断更新我们的网格。因此，我们需要的是每次表中的记录发生更改时来自数据库的通知。

我们使用以下命令从 Visual Studio 安装 SqlTableDependency 包：

PM> Install-Package SqlTableDependency

现在我们定义一个映射感兴趣的表列的 C# 模型。

public class Stock { public decimal Price { get; set; } public string Symbol { get; set; } public string Name { get; set; } }

如您所见，模型的属性名称可以有不同的表列名称。在这种情况下，我们需要一个映射器来正确绑定这些值：

var mapper = new ModelToTableMapper<Stock>(); mapper.AddMapping(model => model.Symbol, "Code");

最后我们创建了我们的SqlTableDependency：

_dependency = new SqlTableDependency<Stock>(_connectionString, "Stocks", mapper); _dependency.OnChanged += _dependency_OnChanged; _dependency.OnError += _dependency_OnError; _dependency.Start();

完整代码如下：

public partial class Window1 : Window { private IList<Stock> _stocks; private readonly string _connectionString = "data source=.;initial catalog=TableDependencyDB;integrated security=True"; private readonly SqlTableDependency<Stock> _dependency; public Window1() { this.InitializeComponent(); this.McDataGrid.ItemsSource = LoadCollectionData(); this.Closing += Window1_Closing; var mapper = new ModelToTableMapper<Stock>(); mapper.AddMapping(model => model.Symbol, "Code"); _dependency = new SqlTableDependency<Stock>(_connectionString, "Stocks", mapper); _dependency.OnChanged += _dependency_OnChanged; _dependency.OnError += _dependency_OnError; _dependency.Start(); } private void Window1_Closing(object sender, System.ComponentModel.CancelEventArgs e) { _dependency.Stop(); } private void _dependency_OnError(object sender, TableDependency.EventArgs.ErrorEventArgs e) { throw e.Error; } private void _dependency_OnChanged(object sender, TableDependency.EventArgs.RecordChangedEventArgs<Stock> e) { if (_stocks != null) { if (e.ChangeType != ChangeType.None) { switch (e.ChangeType) { case ChangeType.Delete: _stocks.Remove(_stocks.FirstOrDefault(c => c.Symbol == e.Entity.Symbol)); break; case ChangeType.Insert: _stocks.Add(e.Entity); break; case ChangeType.Update: var customerIndex = _stocks.IndexOf(_stocks.FirstOrDefault(c => c.Symbol == e.Entity.Symbol)); if (customerIndex >= 0) _stocks[customerIndex] = e.Entity; break; } this.McDataGrid.Dispatcher.Invoke(DispatcherPriority.Background, new Action(() => { this.McDataGrid.Items.Refresh(); })); } } } private IEnumerable<Stock> LoadCollectionData() { _stocks = new List<Stock>(); using (var sqlConnection = new SqlConnection(_connectionString)) { sqlConnection.Open(); using (var sqlCommand = sqlConnection.CreateCommand()) { sqlCommand.CommandText = "SELECT * FROM [Stocks]"; using (var sqlDataReader = sqlCommand.ExecuteReader()) { while (sqlDataReader.Read()) { var code = sqlDataReader.GetString(sqlDataReader.GetOrdinal("Code")); var name = sqlDataReader.GetString(sqlDataReader.GetOrdinal("Name")); var price = sqlDataReader.GetDecimal(sqlDataReader.GetOrdinal("Price")); _stocks.Add(new Stock { Symbol = code, Name = name, Price = price }); } } } } return _stocks; } }

从代码中可以看出，只执行初始选择来检索和填充网格。随后的更新是使用 SqlTableDependency 事件处理程序完成的：它接收一个模型对象，其中包含有关我们用来更新缓存的已更改记录的信息。

您也可以查看How can I notify my program when the database has been updated?。

Answer 2

如果我没看错，您可以借助表格中传统的“ModifiedOn”列将这些更改发布给其他用户。额外的一点是有一些逻辑来选择和发布在给定时间范围内更改的记录。

您可以选择要跟踪的表并添加一个新列 ModifiedOn;然后在用户更改任何给定行时在此字段上记录一个 TimeStamp。

下一步是编写一些逻辑，每 x 分钟触发一次，以查看该表中所有已修改的行。您可以保留逻辑的最后执行时间以加快搜索速度。

1. 您的监控应用程序检查从sometime 到的所有修改记录 current time
2. 执行后保存当前时间。这是为了帮助后续搜索。假设您将其保存为 LastRunTime
3. 您的应用应在 n 分钟后唤醒并检查 记录从 LastRunTime 修改到现在。
4. 用现在覆盖 LastRunTime 值。