0
私のアプリケーションは、databseを持つASP NET MVC 5アプリです。私のデータベースにはログというテーブルがあります。私は、私のアプリがそのテーブルへの新しい挿入についてすべてのクライアントに通知したいので、私はSignalR + SQLTableDependencyを使うことにしました。私はそれらの全て（ただし、すべてのこのようなものにIAMかなり新しい）を組み合わせた、例の多くを読んで、それは私がになってしまったものです：SignalR SQLTableDependencyデータベースの変更トラッキングの問題
マイログEntityクラス：
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
}
マイハブクラス：
[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を経由して、それは」問題をdoesntの）通知を取得することです私のログデータベーステーブルのintの挿入があるとき。しかし、私のコードでは、私はその結果を得ることはできません - 通知は発生しますが、内部にはログデータは含まれておらず、未定義のものがいくつかあります。
もう1つの問題は、ページの更新時に通知を発生させたくないことです。つまり、データベースが変更されたときです。
私は自分のコードのjavascriptの部分を誤解していると思いますが、それは他のものでもかまいません - 私はこのウェブの内容すべてに全く新しいものです。
私は、これらのStockTickerサンプルをもう読めないので、私のために働かないでください。
ありがとうございました。