asp.net - 使用信号器定期向所有客户端发送消息

Question

我想在特定时间间隔后使用集线器将一些数据从服务器发送到所有连接的客户端。我怎样才能使用信号集线器来实现这一点。

Answer 1

启动System.Threading.Timer，并从它的回调中使用特定集线器广播消息。

全球.asax：

private Timer timer;
public class Global : System.Web.HttpApplication
{
    protected void Application_Start(object sender, EventArgs e)
    {
        RouteTable.Routes.MapHubs("~/signalr2");
        timer = new Timer(TimerCallback(timerCallback), null, Timeout.Infinite, 1000);
    }
}

检查SignalR wiki 页面中的“从集线器外部通过集线器广播”部分。

Answer 2

使用ReactiveExtensions然后设置一个Observable.Interval调用。然后响应式将自动调用可以广播给您的客户的 lambda。

Answer 3

我偶然发现了 Jason Roberts 的这篇文章 => http://dontcodetired.com/blog/post/Using-Server-Side-Timers-and-SignalR-in-ASPNET-MVC-Applications.aspx

他使用 IRegisteredObject 和 HostingEnvironment.RegisterObject 然后在类中使用System.Threading.Timer来完成这项工作，我自己没有尝试过，但它看起来正是那种东西。

Answer 4

只需添加

Thread.Sleep(5000);

在您的发送方法中。

前任：

    public void Send(string name, string message)
    {
        Thread.Sleep(5000);
        //call the broadcast message to upadate the clients.
        Clients.All.broadcastMessage(name, message); 
    }

希望能帮助到你。

编辑

以下代码每 5 秒呈现一次当前时间。

这是它的脚本：

<script type="text/javascript">
    $(function () {
        $.connection.hub.logging = true;
        $.connection.hub.start();
        // Declare a proxy to reference the hub.  
        var chat = $.connection.chatHub;

        //Appending the responce from the server to the discussion id
        chat.client.currentTime = function (time) {
            $('#discussion').append("<br/>" + time + "<br/>");
        };

        // Start the connection. 
        $.connection.hub.start().done(function () {

            //Call the server side method for every 5 seconds
            setInterval(function () {
                var date = new Date();
                chat.client.currentTime(date.toString());
            }, 5000);
        });

    }); 
</script>

<div id="discussion"></div>

在 HubClass 上写下以下内容：

public class ChatHub: Hub
   {
        public void currentTime(string date)
        {
            Clients.All.broadCastTime(date);
        }
   }