如何使用 signalR 通知数据库更改

Question

我刚开始使用 SignalR，想试用实时通知。目标是继续在网页上显示更新的消息。 有一个数据库表 - DummyData，其中有一列 Message。此表只有一条记录 - Hello 页面加载时，会显示“Hello”。

然后我在 sql server 2012 中手动运行命令

update DummyData set Message='hello world'，但网页中没有更新消息。

aspx：

<script>
    $(function () {
        var notify = $.connection.notificationsHub;

        $.connection.hub.start().done(function () {
            notify.server.notifyAllClients();
        });

        notify.client.displayNotification = function (msg) {               
            $("#newData").html(msg);
        };

        notify.client.stopClient = function () {
            $.connection.hub.stop();
        };
    });
</script>
 <span id="newData"></span>

aspx.cs：

public string SendNotifications()
    {
      string message = string.Empty;
      using (SqlConnection connection = new SqlConnection(conStr))
       {
        string query = "SELECT [Message] FROM [dbo].[DummyData]";

        SqlCommand command = new SqlCommand(query, connection)
        command.Notification = null;
        SqlDependency dependency = new SqlDependency(command);
                dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
        connection.Open();
        SqlDataReader reader = command.ExecuteReader();

        if (reader.HasRows)
        {
         reader.Read();
         message = reader[0].ToString();
        }
       }            
        return message;
    }

    private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
    {
        if (e.Type == SqlNotificationType.Change)
        {
            SendNotifications();
        }            
    }

NotificationsHub.cs

public class NotificationsHub : Hub
{
 Messages obj = new Messages();
 public void NotifyAllClients(string msg)
  {
   IHubContext context = GlobalHost.ConnectionManager.GetHubContext<NotificationsHub>();
   context.Clients.All.displayNotification(msg);
  }

 public override System.Threading.Tasks.Task OnConnected()
  {
   NotifyAllClients();
   return base.OnConnected();
  }

 public override System.Threading.Tasks.Task OnDisconnected(bool stopCalled)
 {
  NotifyAllClients();
  return base.OnDisconnected(stopCalled);
 }
}

global.asax：

protected void Application_Start(object sender, EventArgs e)
        {
            SqlDependency.Start(Constr);
        }

当我运行 tsql update 命令时，断点首先位于dependency_OnChange，我可以看到从SendNotification 返回的新更新文本。但它没有反映在页面上。感觉就像我快到了，但缺少一些东西。

Answer 1

Signalr 不会监视您的数据库是否有更改。因此，当您只是在数据库中将用户设置为非活动状态时，对 Signalr 来说没有任何意义。您的 3 个客户端仍处于连接状态。

要获得所需的结果，请将类似这样的内容添加到您的 Hub

public override OnConnected()
{
  // Increase the active user count in the db 
  IHubContext context = GlobalHost.ConnectionManager.GetHubContext<ServerHub>();
  Clients.All.broadcastCount(DB.GetCount());
  return base.OnConnected();
}

public override OnDisconnected() 
{
    //Decrease the connected user count in the db
  IHubContext context = GlobalHost.ConnectionManager.GetHubContext<ServerHub>();
  Clients.All.broadcastCount(DB.GetCount());
  return base.OnDisconnected();
}

然后，当您连接和断开客户端时，集线器会通知已连接的客户端。

您需要以 SignalR 将捕获的方式断开连接，因此您不能只更改数据库中的标志。尝试从您的客户那里拨打$.connection.hub.stop();。

This 链接对此有更详细的说明。

如果你说dependency_OnChange事件在你更新数据库后被触发，那么不要调用SendNotifications();，而是调用一个hub方法，特别是NotifyAllClients(...)