[.NET][SignalR] 由 Server 调用 JavaScript&ndash;使用 SignalR 实践 Push 消息模式

时间：2019-09-13 12:53:51 阅读：125 评论：0 收藏：0 [点我收藏+]

标签：mes rabl rip 类型 new names 另一个 out connect

在前一个范例中，我们己经实践出来一个简单的应用程序，而这次我们要来展示 SignalR 的另一个功能：由伺服端调用用户端的 JavaScript 命令码的功能，而这个功能的要求必须是要实践成 Hub 的模式，因此我们可以顺便看到如何实践 Hub 类型的 SignalR 应用程序。

一样的，我们在项目内加入一个新的类 PushNotification，并且设定继承 Hub 类 (这是 Hub 应用程序的要求) 以及实践 IConnected, IDisconnect 两个界面：


using System.Threading;
using System.Threading.Tasks;
using SignalR;
using SignalR.Hubs;
using SignalR.Infrastructure;
using SignalR.Hosting.AspNet;

namespace ServerPushMessageApplication
{
    [HubName("push")]
    public class PushNotification : Hub, IConnected, IDisconnect
    {
         // ...
    }
}

接着，加入连线保留的对象以及实践 IConnected/IDisconnect 方法：


private static List _connectionIds = new List();
private static Task pushTask = null;
                        
public Task Disconnect()
{
    if (_connectionIds.Contains(this.Context.ConnectionId))
        _connectionIds.Remove(this.Context.ConnectionId);

    return null;
}

public Task Connect()
{
    _connectionIds.Add(this.Context.ConnectionId);

    return null;
}

public Task Reconnect(IEnumerable groups)
{
    return null;
}

这段程序的用意是，在连线进到 Hub 时，将连线代码加到连线用户的集合中，等会就会使用到，因为我们会依照用户端的 ID 来调用用户端命令码。

接着，我们加入真正重要的程序，也就是 Push 用的程序：


public PushNotification()
{
    pushTask = new Task(() =>
        {
            while (true)
            {
                if (_connectionIds.Count > 0)
                {
                    foreach (string id in _connectionIds)
                        Clients[id].updateDateTime(DateTime.Now.ToString());
                }

                Thread.Sleep(10000);
            }
        });

    pushTask.Start();
}

~PushNotification()
{
    pushTask = null;
}

这段程序的用意是，会在每十秒钟时调用用户端的 updateDateTime() 命令码，并且将参数返回用户端，参数的排列与伺服端传入的顺序相同，等一下我们会实践到用户端的 JavaScript，届时就可以比较一下。

接着，我们在 Global.asax 的程序中，加入启用 Hub 的程序：


public class MvcApplication : System.Web.HttpApplication
{
    protected void Application_Start()
    {
        AreaRegistration.RegisterAllAreas();

        // enable Hub
        RouteTable.Routes.MapHubs();

        FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
        RouteConfig.RegisterRoutes(RouteTable.Routes);
    }
}

至此，服务器端就写好了，看起来不难吧。

接着，在项目中加入新的 View，然后加入下列的 HTML/JavaScript：