查看: 2177|回复: 0

[.NET源码] SignalR Self Host+MVC等多端消息推送服务(一)

发表于 2018-1-1 08:00:00

一、概述

由于项目需要,最近公司项目里有个模块功能,需要使用到即时获得审批通知;原本的设计方案是使用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. namespace Server
  3. {
  4. public class UserInfo
  5. {
  6. public string ConnectionId { get; set; }
  7. public string UserName { get; set; }
  8. public DateTime LastLoginTime { get; set; }
  9. }
  10. }
复制代码

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

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

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

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

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

9、F5运行起来

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

结果如下:

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

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持程序员之家。



回复

使用道具 举报