GitHub Demo
解决方案
- SignalR.IM 即时通讯
- SignalR.Notify 消息通知
- SignalR.Monitor 剥离业务场景，监控数据变化
- SignalR.MonitorViewTest 监控数据变化的测试页面
SignalR.IM 即时通讯
1. 添加NuGet引用
Install-Package Microsoft.AspNet.SignalR
2. 添加Startup.cs
[assembly: OwinStartup(typeof(SignalR.Notify.App_Start.Startup))]
namespace SignalR.IM.App_Start
{
public class Startup
{
public void Configuration(IAppBuilder app)
{
// 注册SignalR
app.MapSignalR();
}
}
}
3. Hubs文件的命名
注意使用驼峰命名法，否则会报错。在未指定类名和方法名的情况下，生成hubs脚本的时候会自动将帕斯卡命名法改成驼峰命名法。
4. 添加Hubs文件
[HubMethodName("send")]
public void Send(string name, string content)
{
//回调前端JS函数
Clients.All.sendMessage(name, content);
}
5. 引用js文件
<script src="~/Scripts/jquery.signalR-2.2.3.min.js"></script>
<script src="~/signalr/hubs"></script>
6. 前端js获取消息
// 定义IM.Hub对象
var im = $.connection.imHub;
// 连接IM.Hub对象
$.connection.hub.start()；
// 定义IMHub.sendMessage的回调函数
im.client.sendMessage = function (name, message) {
// 处理脚本
}
$('#send').click(function () {
// 调用后台Hub方法
im.server.send($('#username').val(), $('#message').val());
});
SignalR.Notify 消息通知
1. 添加NuGet引用
Install-Package Microsoft.AspNet.SignalR
2. 添加Startup.cs
[assembly: OwinStartup(typeof(SignalR.Notify.App_Start.Startup))]
namespace SignalR.Notify.App_Start
{
public class Startup
{
public void Configuration(IAppBuilder app)
{
// 注册SignalR
app.MapSignalR();
}
}
}
3. Hubs文件的命名
注意使用驼峰命名法，否则会报错。在未指定类名和方法名的情况下，生成hubs脚本的时候会自动将帕斯卡命名法改成驼峰命名法。
4. 添加Hubs文件
[HubMethodName("flyPlanNotify")]
public static void FlyPlanNotify()
{
context.Clients.All.flyNotify("Here is fly plan notify.");
}
5. 引用js文件
<script src="~/Scripts/jquery.signalR-2.2.3.min.js"></script>
<script src="~/signalr/hubs"></script>
6. 前端js获取消息
// 定义NotifyHub对象
var hub = $.connection.notifyHub;
// 连接NotifyHub对象
$.connection.hub.start()；
// 定义IMHub.sendMessage的回调函数
im.client.flyNotify = function (name, message) {
// 处理脚本
}
$('#send').click(function () {
// 调用后台Hub方法
im.server.flyPlanNotify($('#username').val(), $('#message').val());
});
7. 前端和后端调用Hub的区别
后端待用要使用静态方法，但是前端js调用不能获取静态方法的脚本，所以两种调用方法要区分开。
SignalR.Monitor 剥离业务场景，监控数据变化
1. 添加NuGet引用
Install-Package Microsoft.AspNet.SignalR
2. 数据库开启代理
// 设置某个数据库代理的回滚
ALTER DATABASE [DBName] SET NEW_BROKER WITH ROLLBACK IMMEDIATE;
// 设置某个数据库的代理
ALTER DATABASE [DBName] SET ENABLE_BROKER;
// 查询某个数据库是否已经启动了代理
// is_broker_enabled 为0表示未启动代理
// is_broker_enabled 为1表示已启动代理
SELECT is_broker_enabled FROM sys.databases WHERE name = '[DBName]'
3. MonitorInit
添加对应表的监控代码
// 添加SqlDependency进行数据监控
var dependency = new SqlDependency(sqlCommand);
dependency.OnChange += new OnChangeEventHandler(SignalData_OnChange);
添加数据变化事件
/// <summary>
/// 监控到数据发生改变
/// </summary>
public static void SignalData_OnChange(object sender, SqlNotificationEventArgs e)
{
// 调用SignalR进行广播
Hubs.DataMonitor.MonitorSignalData();
}
4. 添加Hubs文件
/// <summary>
/// 方法定义规则
/// 方法名：Monitor+需要监控的数据库表名
/// CallBack函数：方法名+CallBack
/// </summary>
namespace SignalR.Monitor.Hubs
{
[HubName("dataMonitor")]
public class DataMonitor : Hub
{
private static IHubContext context = GlobalHost.ConnectionManager.GetHubContext<DataMonitor>();
[HubMethodName("monitorConnection")]
public void MonitorConnection()
{
// 添加对数据表SignalData的监控
MonitorInit.SignalData();
context.Clients.All.monitorConnectionCallBack("Monitor Connection Success.");
}
[HubMethodName("monitorSignalData")]
public static void MonitorSignalData()
{
// 对定义了回调函数的应用进行广播
context.Clients.All.monitorSignalDataCallBack();
// 继续监控
MonitorInit.SignalData();
}
}
}
5. 应用调用监控的方法
Global.asax添加对SqlDependency的支持
protected void Application_Start()
{
// 启动SqlDependency数据监控
SqlDependency.Start(DataAccess.DB.Connect);
}
protected void Application_End()
{
// 关闭SqlDependency数据监控
SqlDependency.Stop(DataAccess.DB.Connect);
}
其余Nuget引用、Startup添加、前端js回调函数等应用和前面IM，Notify的一致，这里就不重复了。
