SignalR Self Host+MVC等多端消息推送服務(wù)(一)
一、概述
由于項(xiàng)目需要,最近公司項(xiàng)目里有個(gè)模塊功能,需要使用到即時(shí)獲得審批通知;原本的設(shè)計(jì)方案是使用ajax對(duì)服務(wù)器進(jìn)行定時(shí)輪詢查詢,剛剛開始數(shù)據(jù)量和使用量不大的時(shí)候還好,后來使用量的增加和系統(tǒng)中各種業(yè)務(wù)的復(fù)雜度增加,服務(wù)器的壓力也越來越大,于是我想使用消息推送的方式替換掉ajax輪詢查詢,當(dāng)有審批提交時(shí),調(diào)用推送方法,將消息推送到下一審批人那,這樣就減低了服務(wù)器的壓力。
Signal 是微軟支持的一個(gè)運(yùn)行在.NET平臺(tái)上的 html websocket 框架。它出現(xiàn)的主要目的是實(shí)現(xiàn)服務(wù)器主動(dòng)推送消息到客戶端頁面,這樣客戶端就不必重新發(fā)送請(qǐng)求或使用輪詢技術(shù)來獲取消息。而且SignalR的兼容性也是很強(qiáng)大的,這里不在多言。既然選擇了SignalR,那么就開始干吧!
我的想法是將SignalR做成一個(gè)自托管的服務(wù),和我們的b/s項(xiàng)目分離出來,這樣的好處是,1、推送服務(wù)不依賴于iis,就算iis掛了,我們的推送服務(wù)還可以正常運(yùn)行;2、我們可以多平臺(tái)調(diào)用這個(gè)推送服務(wù),多個(gè)項(xiàng)目都可以同時(shí)使用;
二、創(chuàng)建服務(wù)端
廢話不多說了,我也是第一次寫博客,介紹完業(yè)務(wù)場景和構(gòu)思,我們就開始擼碼吧。
1、用VS創(chuàng)建一個(gè)名為 "SignalRProject" 的解決方案;
2、在 SignalRProject解決方案下新建一個(gè)名為Server的控制臺(tái)
3、在程序包管理器控制臺(tái),輸入如下命令
Install-Package Microsoft.AspNet.SignalR.SelfHost
4、輸入如下命令:
Install-Package Microsoft.Owin.Cors
5、在Server控制臺(tái)中添加UserInfo類,代碼如下
using System; namespace Server { public class UserInfo { public string ConnectionId { get; set; } public string UserName { get; set; } public DateTime LastLoginTime { get; set; } } }
6、在Server控制臺(tái)中添加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 { // 靜態(tài)屬性 public static List<UserInfo> OnlineUsers = new List<UserInfo>(); // 在線用戶列表 /// <summary> /// 登錄連線 /// </summary> /// <param name="userId">用戶Id</param> /// <param name="userName">用戶名</param> 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); } /// <summary> /// 發(fā)送私聊 /// </summary> /// <param name="toUserId">接收方用戶連接ID</param> /// <param name="message">內(nèi)容</param> 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 { //表示對(duì)方不在線 Clients.Caller.absentSubscriber(); } } public void Send(string name, string message) { //Clients.All { get; } // 代表所有客戶端 //Clients.AllExcept(params string[] excludeConnectionIds); // 除了參數(shù)中的所有客戶端 //Clients.Client(string connectionId); // 特定的客戶端,這個(gè)方法也就是我們實(shí)現(xiàn)端對(duì)端聊天的關(guān)鍵 //Clients.Clients(IList<string> connectionIds); // 參數(shù)中的客戶端 //Clients.Group(string groupName, params string[] excludeConnectionIds); // 指定客戶端組,這個(gè)也是實(shí)現(xiàn)群聊的關(guān)鍵所在 //Clients.Groups(IList<string> groupNames, params string[] excludeConnectionIds);參數(shù)中的客戶端組 //Clients.User(string userId); // 特定的用戶 //Clients.Users(IList<string> userIds); // 參數(shù)中的用戶 Console.WriteLine("ConnectionId:{0}, InvokeMethod:{1}", Context.ConnectionId, "Send"); Clients.All.addMessage(name, message); } /// <summary> /// 連線時(shí)調(diào)用 /// </summary> /// <returns></returns> public override Task OnConnected() { Console.WriteLine("客戶端連接,連接ID是:{0},當(dāng)前在線人數(shù)為{1}", Context.ConnectionId, OnlineUsers.Count+1); return base.OnConnected(); } /// <summary> /// 斷線時(shí)調(diào)用 /// </summary> /// <param name="stopCalled"></param> /// <returns></returns> 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); //調(diào)用客戶端用戶離線通知 // 刪除用戶 OnlineUsers.Remove(user); Console.WriteLine("客戶端斷線,連接ID是:{0},當(dāng)前在線人數(shù)為{1}", Context.ConnectionId, OnlineUsers.Count); return base.OnDisconnected(stopCalled); } public override Task OnReconnected() { return base.OnReconnected(); } } }
7、在Server控制臺(tái)中添加Startup類,代碼如下
using Microsoft.Owin.Cors; using Owin; namespace Server { public class Startup { public void Configuration(IAppBuilder app) { //允許CORS跨域 app.UseCors(CorsOptions.AllowAll); app.MapSignalR(); } } }
8、修改Server控制臺(tái)中添加Program類,代碼如下
using Microsoft.Owin.Hosting; using System; namespace Server { class Program { static void Main(string[] args) { string url = "http://localhost:10086";//設(shè)定 SignalR Hub Server 對(duì)外的接口 using (WebApp.Start(url))//啟動(dòng) SignalR Hub Server { Console.WriteLine("Server running on {0}", url); Console.ReadLine(); } } } }
9、F5運(yùn)行起來
然后瀏覽器中訪問http://localhost:10086/signalr/hubs
結(jié)果如下:
見上圖內(nèi)容就基本完成了,今天先講到著,時(shí)間不早了,先休息了,后續(xù)有時(shí)間再將后面的文章補(bǔ)上
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 基于SignalR的消息推送與二維碼掃描登錄實(shí)現(xiàn)代碼
- Asp.NET MVC中使用SignalR實(shí)現(xiàn)推送功能
- 使用SignalR推送服務(wù)在Android的實(shí)現(xiàn) SignalA
- asp.net mvc實(shí)現(xiàn)簡單的實(shí)時(shí)消息推送
- ASP.NET實(shí)現(xiàn)推送文件到瀏覽器的方法
- .net平臺(tái)推送ios消息的實(shí)現(xiàn)方法
- .net 通過URL推送POST數(shù)據(jù)具體實(shí)現(xiàn)
- SignalR Self Host+MVC等多端消息推送服務(wù)(二)
- SignalR Self Host+MVC等多端消息推送服務(wù)(三)
相關(guān)文章
深入理解__doPostBack 客戶端調(diào)用服務(wù)端事件
__doPostBack是一個(gè)純粹并且是非常簡單的javascript函數(shù),大部分的頁面PostBack都是由它觸發(fā)的。2008-08-08動(dòng)態(tài)改變ASP.net頁面標(biāo)題和動(dòng)態(tài)指定頁面樣式表的方法
動(dòng)態(tài)改變ASP.net頁面標(biāo)題和動(dòng)態(tài)指定頁面樣式表的方法...2007-04-04ASP.NET實(shí)現(xiàn)圖書管理系統(tǒng)的步驟詳解
這篇文章主要介紹了ASP.NET圖書管理系統(tǒng)簡單實(shí)現(xiàn)步驟,本文通過實(shí)例截圖展示的形式給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2019-12-12ASP.NET MVC實(shí)現(xiàn)批量文件上傳
這篇文章主要為大家詳細(xì)介紹了ASP.NET MVC實(shí)現(xiàn)批量文件上傳,簡單介紹單文件上傳的實(shí)現(xiàn)方法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-09-09Repeater的FooterTemplate顯示某列總計(jì)思路與代碼
在Repeater的FooterTemplate顯示某列總計(jì),接下來與大家分享詳細(xì)的實(shí)現(xiàn)方案,感興趣的各位可以參考下哈2013-03-03ASP.NET Core使用微軟官方類庫實(shí)現(xiàn)漢字轉(zhuǎn)拼音
這篇文章主要為大家詳細(xì)介紹了ASP.NET Core使用微軟官方類庫實(shí)現(xiàn)漢字轉(zhuǎn)拼音,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-05-05