在 Asp.NET MVC 中使用 SignalR 实现推送功能
一,简介
Signal 是微软支持的一个运行在 Dot NET 平台上的 html websocket 框架。它出现的主要目的是实现服务器主动推送(Push)消息到客户端页面,这样客户端就不必重新发送请求或使用轮询技术来获取消息。
二,实现机制
SignalR 的实现机制与 .NET WCF 或 Remoting 是相似的,都是使用远程代理来实现。在具体使用上,有两种不同目的的接口:PersistentConnection 和 Hubs,其中 PersistentConnection 是实现了长时间的 Javascript 轮询(类似于 Comet),Hub 是用来解决实时信息交换问题,它是利用 Javascript 动态载入执行方法实现的。SignalR 将整个连接,信息交换过程封装得非常漂亮,客户端与服务器端全部使用 JSON 来交换数据。
下面就 Hubs 接口的使用来讲讲整个流程:
1,在服务器端定义对应的 hub class;
2,在客户端定义 hub class 所对应的 proxy 类;
3,在客户端与服务器端建立连接(connection);
4,然后客户端就可以调用 proxy 对象的方法来调用服务器端的方法,也就是发送 request 给服务器端;
5,服务器端接收到 request 之后,可以针对某个/组客户端或所有客户端(广播)发送消息。
三,Hub 示例教程
1,工具准备
SignalR 运行在 .NET 4.5 平台上,所以需要安装 .NET 4.5。为了方便演示,本示例使用 ASP.NET MVC 在 Win 7 系统来实现。这需要安装 ASP.NET MVC 3 或 ASP.NET MVC 4。
2,建立工程
打开 VS2010/VS2012 新建名为 SignalRTutorial 的 ASP.NET MVC 3 Web Application 工程,选择 Internet Application 模板, Razor 视图引擎以及勾选 Use HTMl 5 标签。
3,安装 SignalR
打开 NuGet 的 package manager console(Tools->Library package manager),输入:install-package SignalR.Sample,回车安装。如图所示:
4,实现 Hub 服务器端代码
向工程中新建 SignalR 目录,在其中添加 ChatHub.cs 文件,内容如下:
namespace SignalTutorial.SignalR {[HubName("chat")]public class Chat : Hub{public void Send(string clientName, string message){//var toSelfinfo = "You had sent message " + message;//Caller.addSomeMessage(clientName, toSelfinfo);// Call the addMessage method on all clients Clients.addSomeMessage(clientName, message);//Clients[Context.ConnectionId].addSomeMessage(clientName, data); }} }
在上面的代码中:
1),HubName 这个特性是为了让客户端知道如何建立与服务器端对应服务的代理对象,如果没有设定该属性,则以服务器端的服务类名字作为 HubName 的缺省值;
2),Chat 继承自 Hub,从下面 Hub 的接口图可以看出:Hub 支持向发起请求者(Caller),所有客户端(Clients),特定组(Group) 推送消息。
3),public void Send(string clientName, string message) 这个接口是被客户端通过代理对象调用的;
4),Clients 是 Hub 的属性,表示所有链接的客户端页面,它和 Caller 一样是 dynamic,因为要直接对应到 Javascript 对象;
5),Clients.addSomeMessage(clientName, message); 表示服务器端调用客户端的 addSomeMessage 方法,这是一个 Javascript 方法,从而给客户端推送消息。
6),总结:这里实现的服务很简单,就是当一个客户端调用 Send 方法向服务器发送 message 后,服务器端负责将该 message 广播给所有的客户端(也可以给特定组或特定客户端,见屏蔽代码),以实现聊天室的功能。
5,实现 Hub 客户端代码
1),引用 SignalR Javascript
为了简化引用 SignalR 脚本操作,我直接在 View/Shared/_Layout.cshtml 中引入 SignalR 及其他脚本:
<head><meta charset="utf-8" /><title>@ViewBag.Title</title><link href="@Url.Content("~/Content/Site.css")" rel="stylesheet" type="text/css" /><script src="@Url.Content("~/Scripts/jquery-1.5.1.min.js")" type="text/javascript"></script><script src="@Url.Content("~/Scripts/jquery-1.6.4.js")" type="text/javascript"></script><script src="@Url.Content("~/Scripts/jquery-ui-1.8.24.js")" type="text/javascript"></script><script src="@Url.Content("~/Scripts/jquery.signalR-0.5.3.js")" type="text/javascript"></script><script src="@Url.Content("~/Scripts/modernizr-1.7.min.js")" type="text/javascript"></script><script src="@Url.Content("~/signalr/hubs")" type="text/javascript"></script></head>
注意:signalR 依赖于 jquery,所以 signalR 必须放在 jquery 之后,而 hubs 又必须放在 signalR 之后。
然后在 body 部分加入 HubChat Tab:
<li>@Html.ActionLink("HubChat", "HubChat", "Home")</li>
2),生成访问页面
在 HomeController 中添加如下方法:
public ActionResult HubChat() {ViewBag.ClientName = "用户-" + Rnd.Next(10000, 99999);return View(); }
这里由服务器根据随机数来设定客户端的名字,不够严谨,因为随机数生成的名字不是唯一的的,在这里仅为简化演示,实际应用中应该使用 GUID 。
然后生成对应的 View:HubChat.cshtml
@model dynamic@{ViewBag.Title = "title"; }<script src="@Url.Content("~/Scripts/hubDemo.js")" type="text/javascript"></script> <script type="text/javascript">$(document).ready(function () {}); </script><h2>Hub Chat</h2><div><input type="text" id="Placeholder" value="@ViewBag.ClientName" hidden="true"/><input type="text" id="msg" /><input type="button" id="broadcast" value="广播" /><br /><br /><h3>消息记录: (你是:<span id="MyClientName">@ViewBag.ClientName</span>):</h3><ul id="messages"></ul> </div>
在上面的页面代码中,我添加了名为 hubDemo.js 的脚本,这将在下面介绍;此外还有一个id 为 Placeholder 的隐藏 input 控件,这是为了向 Javascript 中传递客户端的名字。
3),编写 Javascript
向 Scripts 目录添加新的 Javescript 脚本:hubDemo.js。其内容如下:
$(function () {var myClientName = $('#Placeholder').val();// Proxy created on the flyvar chat = $.connection.chat;// Declare a function on the chat hub so the server can invoke itchat.addSomeMessage = function (clientName, message) {writeEvent('<b>' + clientName + '</b> 对大家说: ' + message, 'event-message');};$("#broadcast").click(function () {// Call the chat method on the serverchat.send(myClientName, $('#msg').val()).done(function () {console.log('Sent message success!');}).fail(function (e) {console.warn(e);});});// Start the connection $.connection.hub.start();//A function to write events to the pagefunction writeEvent(eventLog, logClass) {var now = new Date();var nowStr = now.getHours() + ':' + now.getMinutes() + ':' + now.getSeconds();$('#messages').prepend('<li class=" + logClass + "><b>' + nowStr + '</b> ' + eventLog + '.</li>');} });
上面代码有详细的注释,下面再讲讲关键之处:
1,首先获取客户端页面的名字;
2,然后通过 $.connection.chat 建立对应服务器端 Hub 类的代理对象 chat;
3,定义客户端的 Javascript 方法 addSomeMessage ,服务器通过 dynamic 方式调用客户端的该方法以实现推送功能。在这里每当收到服务器推送来的消息,就在客户端页面的 messages 列表表头插入该消息。
4,当点击广播按钮时,客户端通过代理对象调用服务器端的 send 方法以实现向服务器发送消息。
5,通过 $.connection.hub.start(); 语句打开链接。
6),编译运行 Hub 示例
在多个浏览器窗口打开页面,效果如下:
四,Persistent Connection 示例教程
1,实现服务器端代码
1),编写服务器 PersistentConnection 代码
向工程中 SignalR 目录中添加 PersistentConnection.cs 文件,内容如下:
using System; using System.Collections.Generic; using System.Threading.Tasks; using SignalR;namespace SignalTutorial.SignalR {public class MyConnection : PersistentConnection{protected override Task OnConnectedAsync(IRequest request, string connectionId){return Connection.Broadcast("Connection " + connectionId + " connected");}protected override Task OnReconnectedAsync(IRequest request, IEnumerable<string> groups, string clientId){return Connection.Broadcast("Client " + clientId + " re-connected");}protected override Task OnReceivedAsync(IRequest request, string connectionId, string data){var info = data + ". ConnectionId is [" + connectionId + "]";// return Connection.Send(connectionId, info); // Broadcast data to all clientsreturn Connection.Broadcast(info); }protected override Task OnDisconnectAsync(string connectionId){return Connection.Broadcast("Connection " + connectionId + " disconncted");}protected override Task OnErrorAsync(Exception error){return Connection.Broadcast("Error ocurred " + error);}} }
在上面的代码中:
1,MyConnection 继承自 PersistentConnection,这样我们就能在客户端连接,重连接,断开连接,发送消息以及连接出错的情况下进行相关的处理。从下面的 PersistentConnection 接口中可以看到,PersistentConnection 同样支持组进行推送。
2,推送消息由 PersistentConnection 的属性 Connection 来提供,它继承自 IConnection 接口,该接口提供两个函数来实现对特定客户端的推送和广播功能。
System.Threading.Tasks.Task Send(string signal, object value) System.Threading.Tasks.Task Broadcast(object value)
2),配置访问路由
为了支持客户端访问,需要在路由表中进行配置。打开 Global.asax.cs ,修改 Application_Start() 函数如下:
protected void Application_Start() {AreaRegistration.RegisterAllAreas();RouteTable.Routes.MapConnection<MyConnection>("echo", "echo/{*operation}");RegisterGlobalFilters(GlobalFilters.Filters);RegisterRoutes(RouteTable.Routes);// Make connections wait 50s maximum for any response. After// 50s are up, trigger a timeout command and make the client reconnect.GlobalHost.Configuration.ConnectionTimeout = TimeSpan.FromSeconds(50);//DisconnectTimeout//HeartBeatInterval//KeepAlive }
在上面的代码中,我将 echo 及其子路径的访问映射到 MyConnection 上,并设置连接超时时间为 50 s。在这里还可以设置其他的一些参数,如断连超时时间,心跳间隔等。
2,实现客户端代码
1),生成访问页面
在前面三 Hub 示例教程的基础上,我们向该工程加入使用 Persistent Connection 的演示。和前面一样,向 _Layout.cshtml 中加入 PersistentChat Tab:
<li>@Html.ActionLink("PersistentChat", "PersistentChat", "Home")</li>
然后在 HomeController 中添加如下方法:
public ActionResult PersistentChat() {ViewBag.ClientName = "用户-" + Rnd.Next(10000, 99999);return View(); }
这里由服务器根据随机数来设定客户端的名字,不够严谨,因为随机数生成的名字不是唯一的的,在这里仅为简化演示,实际应用中应该使用 GUID 。
然后生成对应的 页面: PersistentChat.cshtml:
@model dynamic@{ViewBag.Title = "title"; }<script src="@Url.Content("~/Scripts/persistent.js")" type="text/javascript"></script><h2>Persistent Chat</h2><div><input type="text" id="Placeholder" value="@ViewBag.ClientName" hidden="true"/><input type="text" id="msg" /><input type="button" id="broadcast" value="广播" /><br /><br /><h3>消息记录: (你是:<span id="MyClientName">@ViewBag.ClientName</span>):</h3><ul id="messages"></ul></div>
在上面的页面代码中,我添加了名为 persistent.js 的脚本,这将在下面介绍;此外还有一个id 为 Placeholder 的隐藏 input 控件,这是为了向 Javascript 中传递客户端的名字。
2),编写 Javascript
向 Scripts 目录添加新的 Javescript 脚本:persistent.js。其内容如下:
$(function () {var myClientName = $('#Placeholder').val();var connection = $.connection('/echo');connection.received(function (data) {var msg = new String(data);var index = msg.indexOf("#");var clientName = msg.substring(0, index);var content = msg.substring(index + 1);if (clientName == null || clientName == "") {writeEvent('<b>' + "系统消息" + '</b>: ' + content, 'event-message');}else {writeEvent('<b>' + clientName + '</b> 对大家说: ' + content, 'event-message');}});connection.start();$("#broadcast").click(function () {var msg = myClientName + "#" + $('#msg').val();connection.send(msg);});//A function to write events to the pagefunction writeEvent(eventLog, logClass) {var now = new Date();var nowStr = now.getHours() + ':' + now.getMinutes() + ':' + now.getSeconds();$('#messages').prepend('<li class=" + logClass + "><b>' + nowStr + '</b> ' + eventLog + '.</li>');} });
上面的代码基本与前面的 Hub 实现相同,在此就不再一一讲述。有两点值得说明:
1,创建连接时,指定路径为 "/echo",该路径在服务器端的路由映射表被映射为 MyConnection,因而这个连接就被指向前面提供的 MyConnection。
2,将 clientName 信息放入 message 中,并用 # 将 clientName 和消息内容连接成一个 msg。
3,编译运行 Persistent 示例
在 Asp.NET MVC 中使用 SignalR 实现推送功能相关推荐
- 使用 SignalR 实现推送功能
百度搜索:使用 SignalR 实现推送功能 转载于:https://www.cnblogs.com/Tpf386/p/6758056.html
- 通过源代码研究ASP.NET MVC中的Controller和View(二)
通过源代码研究ASP.NET MVC中的Controller和View(一) 在开始之前,先来温习下上一篇文章中的结论(推论): IView是所有HTML视图的抽象 ActionResult是Cont ...
- 在Asp.Net MVC中实现RequiredIf标签对Model中的属性进行验证
在Asp.Net MVC中可以用继承ValidationAttribute的方式,自定制实现RequiredIf标签对Model中的属性进行验证 具体场景为:某一属性是否允许为null的验证,要根据另 ...
- ASP.NET MVC中你必须知道的13个扩展点
ScottGu在其最新的博文中推荐了Simone Chiaretta的文章13 ASP.NET MVC extensibility points you have to know,该文章为我 ...
- Asp.net mvc中的Ajax处理
在Asp.net MVC中的使用Ajax, 可以使用通用的Jquery提供的ajax方法,也可以使用MVC中的AjaxHelper. 这篇文章不对具体如何使用做详细说明,只对于在使用Ajax中的一些需 ...
- 在 ASP.NET MVC 中使用 Chart 控件
在 .NET 3.5 的时候,微软就提供了一个 Chart 控件,网络上有大量的关于在 VS2008 中使用这个控件的文章,在 VS2010 中,这个控件已经被集成到 ASP.NET 4.0 中,可以 ...
- 在ASP.NET MVC中使用IIS级别的URL Rewrite
在ASP.NET MVC中使用IIS级别的URL Rewrite 原文 在ASP.NET MVC中使用IIS级别的URL Rewrite 大约一年半前,我在博客上写过一系列关于URL Rewrite的 ...
- ASP.NET MVC中实现多个按钮提交的几种方法
有时候会遇到这种情况:在一个表单上需要多个按钮来完成不同的功能,比如一个简单的审批功能. 如果是用webform那不需要讨论,但asp.net mvc中一个表单只能提交到一个Action处理,相对比较 ...
- 在asp.net mvc中使用PartialView返回部分HTML段
问题链接: MVC怎样实现异步调用输出HTML页面 该问题是个常见的 case, 故写篇文章用于提示新人. 在asp.net mvc中返回View时使用的是ViewResult,它继承自ViewRes ...
最新文章
- 用或非门构造D型触发器
- oracle拆分字段为多行,一句话实现字段拆分成多行
- OSPF从Down到Full的七个状态
- HttpClient 4 API –获取状态代码-getStatusLine()。getStatusCode()示例
- toj 3616 Add number (没想到啊~~)
- oracle循环异常跳过,oracle异常处理00103 loop异常继续循环 异常处理选点
- SpringMvc-HandlerMapping/RequestCondition
- 买彩票中奖的概率是多少?
- vue-router: $router.push遇到的问题
- Linux学习笔记之实现黑客帝国炫酷效果
- edem颗粒替换_Altair EDEM Professional 2020.2安装教程(附替换补丁)
- 三种交换方式:电路交换、分组交换、报文交换
- autocomplete触发事件_如何防止onSelect事件在DevBridge jQuery Autocomplete中触发两次
- android webp格式的图片,Android使用webp格式图片的步骤
- 你是否还记得自己的手机号在哪些网站上面注册过呢?
- 喜报云报销与携程商旅达成战略合作 联手打造一站式差旅管理服务
- 基于支持向量机的谐波分析研究与实现
- 手动进行释放内存的API
- 大学生求职简历如何制作?
- [A Top-Down Approach][第一章 计算机网络和因特网]
热门文章
- 人员梯度培养_关键人才的梯队培养
- PlayMaker的特殊事件FINISHED
- Web应用程序指纹识别工具BlindElephant
- 破解加密PDF文件pdfcrack
- mysql 添加多条数据类型_向数据库添加多条数据类型
- python读取数据的函数详解_你了解文件缓存机制吗?磁盘文件如何读写?Python中open函数详解...
- BCI里程碑!脑机接口首次让患者输出完整句子
- 可以通过无线充电的软脑植入物来控制大脑中的脑细胞
- 使用游戏测试干式EEG传感器的有效性
- 统计学习方法笔记(七)-线性支持向量机原理及python实现