SignalR Self Host+MVC等多端消息推送服務 ...
一、概述
由於項目需要，最近公司項目里有個模塊功能，需要使用到即時獲得審批通知；原本的設計方案是使用ajax對伺服器進行定時輪詢查詢，剛剛開始數據量和使用量不大的時候還好，後來使用量的增加和系統中各種業務的複雜度增加，伺服器的壓力也越來越大，於是我想使用消息推送的方式替換掉ajax輪詢查詢，當有審批提交時，調用推送方法，將消息推送到下一審批人那，這樣就減低了伺服器的壓力。
Signal 是微軟支持的一個運行在.NET平臺上的 html websocket 框架。它出現的主要目的是實現伺服器主動推送消息到客戶端頁面，這樣客戶端就不必重新發送請求或使用輪詢技術來獲取消息。而且SignalR的相容性也是很強大的，這裡不在多言。既然選擇了SignalR，那麼就開始乾吧！
我的想法是將SignalR做成一個自托管的服務，和我們的b/s項目分離出來，這樣的好處是，1、推送服務不依賴於iis，就算iis掛了，我們的推送服務還可以正常運行；2、我們可以多平臺調用這個推送服務，多個項目都可以同時使用；
二、創建服務端
廢話不多說了，我也是第一次寫博客，介紹完業務場景和構思，我們就開始擼碼吧。
1、用VS創建一個名為 "SignalRProject" 的解決方案;
2、在 SignalRProject解決方案下新建一個名為Server的控制台
3、在程式包管理器控制台,輸入如下命令
Install-Package Microsoft.AspNet.SignalR.SelfHostView Code
4、輸入如下命令:
Install-Package Microsoft.Owin.CorsView Code
5、在Server控制臺中添加UserInfo類，代碼如下
using System;
namespace Server
{
public class UserInfo
{
public string ConnectionId { get; set; }
public string UserName { get; set; }
public DateTime LastLoginTime { get; set; }
}
}
View Code
6、在Server控制臺中添加ChatHub類，代碼如下
using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Hubs;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Server
{
[HubName("IMHub")]
public class ChatHub : Hub
{
// 靜態屬性
public static List OnlineUsers = new List(); // 線上用戶列表
///
/// 登錄連線
///
///用戶Id
///用戶名
public void Register(string userName)
{
var connnectId = Context.ConnectionId;
if (OnlineUsers.Count(x => x.ConnectionId == connnectId) == 0)
{
if (OnlineUsers.Any(x => x.UserName == userName))
{
var items = OnlineUsers.Where(x => x.UserName == userName).ToList();
foreach (var item in items)
{
Clients.AllExcept(connnectId).onUserDisconnected(item.ConnectionId, item.UserName);
}
OnlineUsers.RemoveAll(x => x.UserName == userName);
}
//添加線上人員
OnlineUsers.Add(new UserInfo
{
ConnectionId = connnectId,
UserName = userName,
LastLoginTime = DateTime.Now
});
}
// 所有客戶端同步線上用戶
Clients.All.onConnected(connnectId, userName, OnlineUsers);
}
///
/// 發送私聊
///
///接收方用戶連接ID
///內容
public void SendPrivateMessage(string toUserName, string message)
{
var fromConnectionId = Context.ConnectionId;
var toUser = OnlineUsers.FirstOrDefault(x => x.UserName == toUserName);
var fromUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == fromConnectionId);
if (toUser != null )
{
Clients.Client(toUser.ConnectionId).receivePrivateMessage(fromUser.UserName, message);
Clients.Client(toUser.ConnectionId).receivePrivateMessage(message);
}
else
{
//表示對方不線上
Clients.Caller.absentSubscriber();
}
}
public void Send(string name, string message)
{
//Clients.All { get; } // 代表所有客戶端
//Clients.AllExcept(params string[] excludeConnectionIds); // 除了參數中的所有客戶端
//Clients.Client(string connectionId); // 特定的客戶端，這個方法也就是我們實現端對端聊天的關鍵
//Clients.Clients(IList connectionIds); // 參數中的客戶端
//Clients.Group(string groupName, params string[] excludeConnectionIds); // 指定客戶端組，這個也是實現群聊的關鍵所在
//Clients.Groups(IList groupNames, params string[] excludeConnectionIds);參數中的客戶端組
//Clients.User(string userId); // 特定的用戶
//Clients.Users(IList userIds); // 參數中的用戶
Console.WriteLine("ConnectionId:{0}, InvokeMethod:{1}", Context.ConnectionId, "Send");
Clients.All.addMessage(name, message);
}
///
/// 連線時調用
///
///
public override Task OnConnected()
{
Console.WriteLine("客戶端連接，連接ID是:{0},當前線上人數為{1}", Context.ConnectionId, OnlineUsers.Count+1);
return base.OnConnected();
}
///
/// 斷線時調用
///
///
///
public override Task OnDisconnected(bool stopCalled)
{
var user = OnlineUsers.FirstOrDefault(u => u.ConnectionId == Context.ConnectionId);
// 判斷用戶是否存在,存在則刪除
if (user == null)
{
return base.OnDisconnected(stopCalled);
}
Clients.All.onUserDisconnected(user.ConnectionId, user.UserName); //調用客戶端用戶離線通知
// 刪除用戶
OnlineUsers.Remove(user);
Console.WriteLine("客戶端斷線，連接ID是:{0},當前線上人數為{1}", Context.ConnectionId, OnlineUsers.Count);
return base.OnDisconnected(stopCalled);
}
public override Task OnReconnected()
{
return base.OnReconnected();
}
}
}
View Code
7、在Server控制臺中添加Startup類，代碼如下
using Microsoft.Owin.Cors;
using Owin;
namespace Server
{
public class Startup
{
public void Configuration(IAppBuilder app)
{
//允許CORS跨域
app.UseCors(CorsOptions.AllowAll);
app.MapSignalR();
}
}
}
View Code
8、修改Server控制臺中添加Program類，代碼如下
using Microsoft.Owin.Hosting;
using System;
namespace Server
{
class Program
{
static void Main(string[] args)
{
string url = "http://localhost:10086";//設定 SignalR Hub Server 對外的介面
using (WebApp.Start(url))//啟動 SignalR Hub Server
{
Console.WriteLine("Server running on {0}", url);
Console.ReadLine();
}
}
}
}
View Code
9、F5運行起來
然後瀏覽器中訪問http://localhost:10086/signalr/hubs
結果如下：
見上圖內容就基本完成了，今天先講到著，時間不早了，先休息了，後續有時間再將後面的文章補上
