c# - SignalR SQLTableDependency 数据库更改跟踪问题

Question

我的应用程序是一个带有数据库的 ASP NET MVC 5 应用程序。我的数据库中有一个名为 Logs 的表。我希望我的应用程序通知所有客户关于该表的新插入，所以我决定使用 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; }




}

我的单例服务类:

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();
    }




}

我还在我的 Startup.cs 中添加了 app.MapSignalR();。

这是我的 html View :

<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，但这并不重要)。但是用我的代码我没有得到那个结果 - 通知被触发，但它们不包含任何日志数据，只有一些“未定义”的东西。

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

我认为我对代码的 javascript 部分有一些误解，但它可以是任何其他内容 - 我对所有这些网络内容都是全新的。

请帮助我，我无法再阅读所有那些 StockTicker 示例，它们对我不起作用。

非常感谢您的帮助。

Answer 1

也许像我这样随便的穷人会找出这篇文章，这会对他有所帮助。事实证明，我只是错过了 Microsoft.AspNet.SignalR.Client 包。我不认为我必须手动添加它。我添加了它，一切都开始像魅力一样工作。