SignalR Self Host+MVC等多端消息推送服务(1)

一、概述

由于项目需要,最近公司项目里有个模块功能,需要使用到即时获得审批通知;原本的设计方案是使用ajax对服务器进行定时轮询查询,刚刚开始数据量和使用量不大的时候还好,后来使用量的增加和系统中各种业务的复杂度增加,服务器的压力也越来越大,于是我想使用消息推送的方式替换掉ajax轮询查询,当有审批提交时,调用推送方法,将消息推送到下一审批人那,这样就减低了服务器的压力。

Signal 是微软支持的一个运行在.NET平台上的 html websocket 框架。它出现的主要目的是实现服务器主动推送消息到客户端页面,这样客户端就不必重新发送请求或使用轮询技术来获取消息。而且SignalR的兼容性也是很强大的,这里不在多言。既然选择了SignalR,那么就开始干吧!

我的想法是将SignalR做成一个自托管的服务,和我们的b/s项目分离出来,这样的好处是,1、推送服务不依赖于iis,就算iis挂了,我们的推送服务还可以正常运行;2、我们可以多平台调用这个推送服务,多个项目都可以同时使用;

二、创建服务端

废话不多说了,我也是第一次写博客,介绍完业务场景和构思,我们就开始撸码吧。

1、用VS创建一个名为 "SignalRProject" 的解决方案;

2、在 SignalRProject解决方案下新建一个名为Server的控制台

3、在程序包管理器控制台,输入如下命令

1 Install-Package Microsoft.AspNet.SignalR.SelfHost 

4、输入如下命令:

1 Install-Package Microsoft.Owin.Cors

5、在Server控制台中添加UserInfo类,代码如下

 1 using System;
 2
 3 namespace Server
 4 {
 5     public class UserInfo
 6     {
 7         public string ConnectionId { get; set; }
 8         public string UserName { get; set; }
 9         public DateTime LastLoginTime { get; set; }
10     }
11 }  

6、在Server控制台中添加ChatHub类,代码如下

  1 using Microsoft.AspNet.SignalR;
  2 using Microsoft.AspNet.SignalR.Hubs;
  3 using System;
  4 using System.Collections.Generic;
  5 using System.Linq;
  6 using System.Threading.Tasks;
  7
  8 namespace Server
  9 {
 10     [HubName("IMHub")]
 11     public class ChatHub : Hub
 12     {
 13         // 静态属性
 14         public static List<UserInfo> OnlineUsers = new List<UserInfo>(); // 在线用户列表
 15
 16         /// <summary>
 17         /// 登录连线
 18         /// </summary>
 19         /// <param name="userId">用户Id</param>
 20         /// <param name="userName">用户名</param>
 21         public void Register(string userName)
 22         {
 23             var connnectId = Context.ConnectionId;
 24
 25             if (OnlineUsers.Count(x => x.ConnectionId == connnectId) == 0)
 26             {
 27                 if (OnlineUsers.Any(x => x.UserName == userName))
 28                 {
 29                     var items = OnlineUsers.Where(x => x.UserName == userName).ToList();
 30                     foreach (var item in items)
 31                     {
 32                         Clients.AllExcept(connnectId).onUserDisconnected(item.ConnectionId, item.UserName);
 33                     }
 34                     OnlineUsers.RemoveAll(x => x.UserName == userName);
 35                 }
 36
 37                 //添加在线人员
 38                 OnlineUsers.Add(new UserInfo
 39                 {
 40                     ConnectionId = connnectId,
 41                     UserName = userName,
 42                     LastLoginTime = DateTime.Now
 43                 });
 44             }
 45
 46             // 所有客户端同步在线用户
 47             Clients.All.onConnected(connnectId, userName, OnlineUsers);
 48         }
 49
 50         /// <summary>
 51         /// 发送私聊
 52         /// </summary>
 53         /// <param name="toUserId">接收方用户连接ID</param>
 54         /// <param name="message">内容</param>
 55         public void SendPrivateMessage(string toUserName, string message)
 56         {
 57             var fromConnectionId = Context.ConnectionId;
 58
 59             var toUser = OnlineUsers.FirstOrDefault(x => x.UserName == toUserName);
 60             var fromUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == fromConnectionId);
 61
 62             if (toUser != null )
 63             {
 64                 Clients.Client(toUser.ConnectionId).receivePrivateMessage(fromUser.UserName, message);
 65                 Clients.Client(toUser.ConnectionId).receivePrivateMessage(message);
 66             }
 67             else
 68             {
 69                 //表示对方不在线
 70                 Clients.Caller.absentSubscriber();
 71             }
 72         }
 73
 74         public void Send(string name, string message)
 75         {
 76             //Clients.All { get; } // 代表所有客户端
 77             //Clients.AllExcept(params string[] excludeConnectionIds); // 除了参数中的所有客户端
 78             //Clients.Client(string connectionId); // 特定的客户端,这个方法也就是我们实现端对端聊天的关键
 79             //Clients.Clients(IList<string> connectionIds); // 参数中的客户端
 80             //Clients.Group(string groupName, params string[] excludeConnectionIds); // 指定客户端组,这个也是实现群聊的关键所在
 81             //Clients.Groups(IList<string> groupNames, params string[] excludeConnectionIds);参数中的客户端组
 82             //Clients.User(string userId);  // 特定的用户
 83             //Clients.Users(IList<string> userIds); // 参数中的用户
 84
 85             Console.WriteLine("ConnectionId:{0}, InvokeMethod:{1}", Context.ConnectionId, "Send");
 86             Clients.All.addMessage(name, message);
 87         }
 88
 89         /// <summary>
 90         /// 连线时调用
 91         /// </summary>
 92         /// <returns></returns>
 93         public override Task OnConnected()
 94         {
 95             Console.WriteLine("客户端连接,连接ID是:{0},当前在线人数为{1}", Context.ConnectionId, OnlineUsers.Count+1);
 96             return base.OnConnected();
 97         }
 98
 99
100         /// <summary>
101         /// 断线时调用
102         /// </summary>
103         /// <param name="stopCalled"></param>
104         /// <returns></returns>
105         public override Task OnDisconnected(bool stopCalled)
106         {
107             var user = OnlineUsers.FirstOrDefault(u => u.ConnectionId == Context.ConnectionId);
108
109             // 判断用户是否存在,存在则删除
110             if (user == null)
111             {
112                 return base.OnDisconnected(stopCalled);
113             }
114
115             Clients.All.onUserDisconnected(user.ConnectionId, user.UserName);   //调用客户端用户离线通知
116             // 删除用户
117             OnlineUsers.Remove(user);
118             Console.WriteLine("客户端断线,连接ID是:{0},当前在线人数为{1}", Context.ConnectionId, OnlineUsers.Count);
119             return base.OnDisconnected(stopCalled);
120         }
121
122         public override Task OnReconnected()
123         {
124             return base.OnReconnected();
125         }
126     }
127 }

7、在Server控制台中添加Startup类,代码如下

 1 using Microsoft.Owin.Cors;
 2 using Owin;
 3
 4 namespace Server
 5 {
 6     public class Startup
 7     {
 8         public void Configuration(IAppBuilder app)
 9         {
10             //允许CORS跨域
11             app.UseCors(CorsOptions.AllowAll);
12             app.MapSignalR();
13         }
14     }
15 }

8、修改Server控制台中添加Program类,代码如下

 1 using Microsoft.Owin.Hosting;
 2 using System;
 3
 4 namespace Server
 5 {
 6     class Program
 7     {
 8         static void Main(string[] args)
 9         {
10             string url = "http://localhost:10086";//设定 SignalR Hub Server 对外的接口
11             using (WebApp.Start(url))//启动 SignalR Hub Server
12             {
13                 Console.WriteLine("Server running on {0}", url);
14                 Console.ReadLine();
15             }
16         }
17     }
18 }

9、F5运行起来

然后浏览器中访问http://localhost:10086/signalr/hubs

结果如下:

见上图内容就基本完成了,今天先讲到着,时间不早了,先休息了,后续有时间再将后面的文章补上

时间: 2024-11-05 18:57:23

SignalR Self Host+MVC等多端消息推送服务(1)的相关文章

SignalR Self Host+MVC等多端消息推送服务(2)

一.概述 上次的文章中我们简单的实现了SignalR自托管的服务端,今天我们来实现控制台程序调用SignalR服务端来实现推送信息,由于之前我们是打算做审批消息推送,所以我们的demo方向是做指定人发送信息,至于做聊天消息和全局广播,这里就不在进行演示了. 二.创建控制台客户端 1.在SignalRProject解决方案下新建一个名为Clinet的控制台 2.在程序包管理控制台中输入以下命令 1 Install-Package Microsoft.AspNet.SignalR.Client 3.

SignalR Self Host+MVC等多端消息推送服务(4)

由于工作太忙,一直没时间更新博客,之前有很多朋友一直问我什么时候将后续的代码发上来,一直没时间,今天就长话短说,不写文章了,直接上demo,里面将正式项目中用到的一些敏感信息修改了,要使用的话下载后自行修改. Demo:https://github.com/landonzeng/SignalRBusService

Asp.net SignalR 实现服务端消息推送到Web端

原文:http://www.cnblogs.com/wintersun/p/4148223.html 之前的文章介绍过Asp.net SignalR,  ASP .NET SignalR是一个ASP .NET 下的类库,可以在ASP .NET 的Web项目中实现实时通信.  今天我们来实现服务端消息推送到Web端,   首先回顾一下它抽象层次图是这样的: 实际上 Asp.net SignalR 2 实现 服务端消息推送到Web端, 更加简单. 为了获取更好的可伸缩性, 我们引入消息队列, 看如下

java后端IM消息推送服务开发——协议

最近在一家saas企业使用Mqtt开发IM消息推送服务,把开发中的一些问题记录下来,项目仍在商用中,完整的消息服务包括4个模块---协议protocol,信令Signal,规则Rule,状态Status,这个主题主要是协议protocol部分. 主要技术涉及到MongoDB,webservice,httpclient,Mqtt等 protocol分为四个模块类来实现,当然这是为了以后的扩展性比较好 首先看一下我们的主类,主要是mqtt基础方法的一个框架 public class MqttProt

消息推送服务

消息推送服务 服务器推送目前流行就是私信.发布/订阅等模式,基本上都是基于会话映射,消息对列等技术实现的:高性能.分布式可以如下解决:会话映射可采用redis cluster等技术实现,消息对列可使用kafka等分布式消息队列方案实现. APM.Server基于简单 1 static ConcurrentDictionary<string, Session> _sessionDic = new ConcurrentDictionary<string, Session>(); 和 1

asp.net使用signalr实现集群集群下面的消息推送

1.选用Signalr的原因 Signalr内部给我们做了很多封装.当服务器或者浏览器不支持websoket协议的时候就使用长连接方式  不支持长连接再选用轮询的方式获取消息 websoket:与服务器保持长连接 服务器和客户端可以进行双工通讯而不用建立新的链接 长连接:服务器与客户端保持长连接 .每隔一段时间客户端询问服务器  而不用建立新连接 轮询:客户端定期向服务器发送请求询问 每次都会建立新的链接(建立新的链接使非常耗时的) 2.集群情况下的遇到的难点 当一个一台服务器的给某个用户发送了

基于Qt移动应用的消息推送服务原理与应用

说到移动应用,大家都觉得移动嘛,当然是Java和Object-c来做啦,什么推送啊,各种系统调用啊,其实不然?如果你了解Qt, 你就知道我说的不然,也有所道理. 说道几点 一.目前Android的移动的消息.通知推送 1)轮询(Pull)方式:应用程序应当阶段性的与服务器进行连接并查询是否有新的消息到达,你必须自己实现与服务器之间的通信,例如消息排队等.而且你还要考虑轮询的频率,如果太慢可能导致某些消息的延迟,如果太快,则会大量消耗网络带宽和电池. 2)SMS(Push)方式:在Android平

java后端IM消息推送服务开发——规则

这一部分主要是负责智能消息推送,根据不同公司的不同产品的不同页面的不同事件的不同用户推送不同的消息,这也是整个业务逻辑的核心 技术主要涉及到Mysql,文件读取,dbutils,beanutils,mqtt,C3P0连接池 memcache package net.engyne.mqqt; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.List; import net.engyne.

网页端消息推送之推与拉

需求之缘由 用户A在网页段登陆,系统或其他用户的某些操作会导致在网页显示消息,用以提醒用户.实现方式大致有三种. 轮询拉取 建立长连接 HTTP长轮询 消息通知之发送方和处理方 发送方 系统发给A的"系统通知",可能对实时性要求没这么高 用户发给A的"聊天消息",有对实时性要求比较高,越实时越好 处理方 有服务对消息进行逻辑处理 有数据库对数据进行落地 有缓存对数据进行加速 方式之一_轮询拉取 轮询拉取,是最容易想到的实现方式: 发送方发送了消息,先入队列 网页端起