SignalR主动通知订阅者示例

简介: html代码: $(function () { var hub = $.connection.payHub; hub.client.waitNotify = function (tran, url) { console.

html代码:

<script src="~/Scripts/jquery.signalR-2.2.0.min.js"></script>
<script src="@Url.Content("~/signalr/hubs")" type="text/javascript"></script>
<script>
    $(function () {
        var hub = $.connection.payHub;
        hub.client.waitNotify = function (tran, url) {
            console.log("waitNotify:" + tran + "   " + url);
            if (tran) {
                location.href = url;
            }

        };
        $.connection.hub.start().done(function () {
            console.log("hub done");
        });
    })
</script>

hub代码:

[HubName("payHub"), Authorize]
    public class payHub : Hub
    {
        public static Dictionary<Guid, string> userPayHub = new Dictionary<Guid, string>();
        public static void Notify(Guid userId, string redirectUrl)
        {
            if (userPayHub.ContainsKey(userId))
            {
                Microsoft.AspNet.SignalR.GlobalHost.ConnectionManager.GetHubContext<Hubs.payHub>()
                   .Clients.Client(Hubs.payHub.userPayHub[userId])
                   .waitNotify(true, redirectUrl);
            }
        }
        public override Task OnConnected()
        {
            var uid = this.Context.User.Identity.GetUserId();
            userPayHub[uid] = this.Context.ConnectionId;
            return base.OnConnected();
        }
        public override Task OnDisconnected(bool stopCalled)
        {
            var uid = this.Context.User.Identity.GetUserId();
            userPayHub.Remove(uid);
            return base.OnDisconnected(stopCalled);
        }
        public override Task OnReconnected()
        {
            var uid = this.Context.User.Identity.GetUserId();
            userPayHub.Remove(uid);
            return base.OnReconnected();
        }
    }

通知调用Notify方法即可。

关键点:GlobalHost.ConnectionManager.GetHubContext

目录
相关文章
|
消息中间件 存储 JavaScript
Electron开发自定义通知 & 多并发下接收消息处理
Electron 专门提供了 Notification 可以用来实现`系统通知`,但是如果想实现自定义(如自定义UI样式等)通知,Notification 则不能实现。 下面摘录了我在`系统通知`和如何实现`自定义通知`的思路,另外也阐述了`多并发下接收消息`方案实现。
671 0
|
程序员 C#
【C#】SignalR之主动推送信息的简单解决方案
在本篇文章中,将讲讲C#如何使用SignalR通讯 Core下的SignalR实现原理一样,只是写法不一样,主动推送消息的场景使用:页面登录后台管理系统,最新订单信息的通知等
333 0
|
开发工具 开发者
消息服务-事件通知使用 | 学习笔记
快速学习消息服务-事件通知使用
消息服务-事件通知使用 | 学习笔记
|
消息中间件 NoSQL Redis
SpringDataRedis 中配置消息的监听器| 学习笔记
快速学习 SpringDataRedis 中配置消息的监听器。
【EventBus】事件通信框架 ( 发送事件 | 根据事件类型获取订阅者 | 调用订阅方法 )
【EventBus】事件通信框架 ( 发送事件 | 根据事件类型获取订阅者 | 调用订阅方法 )
146 0
【EventBus】事件通信框架 ( 订阅方法注册 | 注册 事件类型 - 订阅类 + 订阅方法 到指定集合 | 取消注册 数据准备 )
【EventBus】事件通信框架 ( 订阅方法注册 | 注册 事件类型 - 订阅类 + 订阅方法 到指定集合 | 取消注册 数据准备 )
131 0
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(二)
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(二)
124 0
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(一)
【EventBus】事件通信框架 ( 取消注册 | 获取事件参数类型 | 根据事件类型获取订阅者 | 移除相关订阅者 )(一)
147 0
|
缓存
【EventBus】事件通信框架 ( 订阅方法注册 | 检查订阅方法缓存 | 反射获取订阅类中的订阅方法 )(一)
【EventBus】事件通信框架 ( 订阅方法注册 | 检查订阅方法缓存 | 反射获取订阅类中的订阅方法 )(一)
123 0
|
缓存
【EventBus】事件通信框架 ( 订阅方法注册 | 检查订阅方法缓存 | 反射获取订阅类中的订阅方法 )(二)
【EventBus】事件通信框架 ( 订阅方法注册 | 检查订阅方法缓存 | 反射获取订阅类中的订阅方法 )(二)
144 0