SignalR SQLTableDependency数据库更改跟踪问题

问题描述：

我的应用程序是带有数据库的ASP NET MVC 5应用程序。我的数据库中有一个名为Logs的表。我希望我的应用程序通知所有客户端有关该表的新插入，因此我决定使用SignalR + SQLTableDependency。我读了很多的例子，结合所有的人（但IAM很新的这一切的东西），而这正是我结束了：SignalR SQLTableDependency数据库更改跟踪问题

我的日志实体类：

public class Log 
{ 
    public Log(int visitRequestId, string requestNumber) 
    { 
     Created = DateTime.Now; 
     VisitRequestId = visitRequestId; 
     RequestNumber = requestNumber; 
    } 

    public Log() 
    { 

    } 
    [DatabaseGenerated(DatabaseGeneratedOption.Identity), Key] 
    public int Id { get; set; } 

    [Required] 
    public int VisitRequestId { get; set; } 

    public string RequestNumber { get; set; } 

    public DateTime Created { get; set; } 


    public string Message { get; set; } 




}

我singletone服务类：

public class JournalMessangesService 
    { 
     private static readonly Lazy<JournalMessangesService> _instance = new Lazy<JournalMessangesService>(()=>new JournalMessangesService(GlobalHost.ConnectionManager.GetHubContext<JournalMessageHub>().Clients)); 

    private static SqlTableDependency<Log> _tableDependency; 
    private IHubConnectionContext<dynamic> Clients { get; } 

    public static JournalMessangesService Instance => _instance.Value; 

    private JournalMessangesService(IHubConnectionContext<dynamic> clients) 
    { 
     Clients = clients; 


     _tableDependency = new SqlTableDependency<Log>(
      ConfigurationManager.ConnectionStrings["EFDbContext"].ConnectionString, 
      "Logs" 
      ); 
     _tableDependency.OnChanged += SqlTableDependency_Changed; 
     _tableDependency.OnError += SqlTableDependency_OnError; 
     _tableDependency.Start(); 
    } 

    private void SqlTableDependency_OnError(object sender, ErrorEventArgs e) 
    { 
     throw e.Error; 
    } 

    private void SqlTableDependency_Changed(object sender, RecordChangedEventArgs<Log> e) 
    { 
     if (e.ChangeType != ChangeType.None) 
     { 
      BroadcastJournalMessage(e.Entity); 
     } 
    } 

    private void BroadcastJournalMessage(Log log) 
    { 
     Clients.All.updateMessage(log); 
    } 

    public IEnumerable<Log> GetAllLogs() 
    { 
     var logEntries = new List<Log>(); 
     var connString = ConfigurationManager.ConnectionStrings["EFDbcontext"].ConnectionString; 
     using (var connection = new SqlConnection(connString)) 
     { 
      connection.Open(); 
      using (var command = connection.CreateCommand()) 
      { 
       command.CommandText = "SELECT * FROM [Logs]"; 
       using (var dataReader = command.ExecuteReader()) 
       { 
        while (dataReader.Read()) 
        { 
         var id = dataReader.GetInt32(dataReader.GetOrdinal("VisitRequestId")); 
         var reqNum = dataReader.GetString(dataReader.GetOrdinal("RequestNumber")); 
         var created = dataReader.GetDateTime(dataReader.GetOrdinal("Created")); 
         var message = dataReader.GetString(dataReader.GetOrdinal("Message")); 
         logEntries.Add(new Log(id, reqNum) {Created = created, Message = message}); 
        } 
       } 
      } 
     } 

     return logEntries; 
    } 
    #region IDisposable Support 
    private bool disposedValue = false; // To detect redundant calls 

    protected virtual void Dispose(bool disposing) 
    { 
     if (!disposedValue) 
     { 
      if (disposing) 
      { 
       _tableDependency.Stop(); 
      } 

      disposedValue = true; 
     } 
    } 

    ~JournalMessangesService() 
    { 
     Dispose(false); 
    } 


    public void Dispose() 
    { 
     Dispose(true); 
     GC.SuppressFinalize(this); 
    } 

    #endregion 

}

我的HUB类：

[HubName("journalMessageHub")] 
public class JournalMessageHub : Hub 
{ 


    private readonly JournalMessangesService _journalMessangesService; 
    public JournalMessageHub() : this(JournalMessangesService.Instance) { } 

    public JournalMessageHub(JournalMessangesService journalMessangesService) 
    { 
     _journalMessangesService = journalMessangesService; 
    } 

    public IEnumerable<Log> GetAllLogs() 
    { 
     return _journalMessangesService.GetAllLogs(); 
    } 




}

我还添加了app.MapSignalR();我启动的.cs。

这里是我的HTML视图：

<script src="~/Scripts/jquery.signalR-2.2.2.js"></script> 
<script src="/signalr/hubs" type="text/javascript"></script> 
<script src="~/Scripts/noty.js"></script> 

<script type="text/javascript"> 
    $(document).ready(function() { 

    var journalHub = $.connection.journalMessageHub; 
    journalHub.client.updateMessage = function(log) { 
     new Noty({ 
          text: log.Message, 
          type: 'warning', 
          theme: 'metroui', 
          timeout: '2000' 
         }).show(); 
    }; 
    $.connection.hub.start().done(function() { 

     journalHub.server.getAllLogs().done(function(data) { 
      console.log('data length: ' + data.length); 
     }); 
     journalHub.client.updateMessage(); 
    }); 
});

我想要的是得到一个通知（通过Noty.js，但它不”物）时，有一个插入INT我的日志数据库表。但是用我的代码我没有得到那个结果 - 通知被触发，但是它们不包含任何内部的日志数据，只有一些'未定义'的东西。

另一个问题是我不想在页面刷新时触发通知 - 最初是在数据库更改时。

我想我对我的代码的JavaScript部分有一些误解，但它可以是其他任何东西 - 我完全是所有这些网络的新东西。

请帮助我，我再也看不到所有这些StockTicker示例，它们不适用于我。

非常感谢您的帮助。

答

也许像我这样的随机可怜的人会把这篇文章弄错了，它会帮助他。原来，我错过了Microsoft.AspNet.SignalR。 客户端包。我不认为我必须手动添加它。我添加了它，一切都开始像魅力一样工作。

SignalR SQLTableDependency数据库更改跟踪问题

相关推荐