0

正如您在 Facebook 的通知系统中看到的那样，当与您的活动相关的指定更改发生时，Facebook 会通知您。重要的问题是，如果我们想使用 SignalR 发送通知，我们有两个选择：

  1. 使用客户端调用向客户端广播消息的服务器方法
  2. 使用服务器端启动连接并调用服务器端的方法，该方法向客户端广播消息，如下所示：
[HubName("messenger")]
    public class MessengerHub : Hub
    {
         /// <summary>
        /// Broads the cast message.
        /// </summary>
        /// <param name="message">The message.</param>
        public void BroadCastMessage(Object message, string group)
        {
            _messenger.BroadCastMessage(message, group);
        }
    }

在这里，我们从服务器调用 BroadCastMessage 方法来通知用户：

            var connection = new HubConnection("http://localhost:21600/");
            SignalRConsole.SignalR.MessengerHub.Message message = new SignalR.MessengerHub.Message();
            message.Content = Console.ReadLine();
            message.Duration = 500;

            var myHub = connection.CreateProxy("messenger");
            connection.Start().Wait();
            myHub.Invoke("broadCastMessage", myData);
            Console.ReadLine();

现在，如果我们想根据数据库中的最后更改作为用户通知广播消息，我们应该经常检查数据库，然后启动连接以调用广播方法向用户发送通知。然后，我知道的方式连续检查使用与下面相同的无限 while 循环：

>      while (true){ 
>         //Some codes for tracing the last changes in Database such as new related events
>         if(CheckIfThereIsaNewEvent()){
>           connection.Start().Wait();
>           myHub.Invoke("broadCastMessage", myData);  
          }
>      }

当我们拥有一亿用户时，这种编码风格应该很糟糕，因为服务器应该不断调用一个方法并检查数据库是否有新的事件并向大量的客户端广播消息，因此我们应该分配大量的计算，因此需要分配大量的加载到服务器上，这不合逻辑。那么，这样做的真正方法是什么？Facebook 对此问题的解决方案是什么？

4

2 回答 2

0

尝试使用 SqlDependency 类 OnChange Event 来触发 SignalR 方法。您可以指定应在哪个查询上触发 Event :)

于 2013-10-31T13:03:57.283 回答
0

在这里，我们可以在数据库更新时触发消息广播。例如我们有以下方法和数据库更新方法

[HubName("messenger")]
    public class MessengerHub : Hub
    {
         /// <summary>
        /// Broads the db update message.
        /// </summary>
        /// <param name="message">The message.</param>
        public void BroadCastDbUpdate(Bool IsDbUpdate, string changes)
        {
            _messenger.BroadCastMessage(IsDbUpdate, changes);
        }
    } 



public void DbUpdate()
            {
//Do your db update and call the broadcast method
                _messenger.BroadCastMessage(IsDbUpdate, changes);
            }
于 2013-07-08T06:28:19.070 回答