asp.net core系列 70 即時通迅-WebSocket+Redis釋出訂閱
一.概述
在asp.net core 中可以用WebSocket 或asp.net core SignalR來開發即時通迅。在專案中由於開發前後端分離,對於SignalR前端技術人員不想依賴juqery和SignalR.js包,後端確定使用WebSocket 來實現。對於asp.net core有自帶的app.UseWebSockets()中介軟體,但是使用IIs做為web代理伺服器時,需要在windows系統新增程式iis配置websocket才能使用websocket通訊。於是專案引用了一個開源包Fleck。
Fleck是對C#Websocket的實現,程式內部使用了System.Net.Sockets類來實現Websocket,不依賴於任何目標框架。 Fleck使用介紹 :https://github.com/statianzo/Fleck
下面是msdn文件原話:
對於大多數應用程式,我們建議使用 SignalR,而不是原始 Websocket。 SignalR 可為 Websocket 不可用的環境提供傳輸回退。 它還可提供簡單的遠端過程呼叫應用模型。 並且在大多數情況下,與使用原始 Websocket 相比,SignalR 沒有顯著的效能缺點。
WebSocket客戶端支援:
瀏覽器 |
支援情況 |
Chrome |
Chrome version 4+支援 |
Firefox |
Firefox version 5+支援 |
IE |
IE version 10+支援 |
Safari |
IOS 5+支援 |
Android Brower |
Android 4.5+支援 |
二.專案中即時通迅實現架構
在我業務專案中實現的流程是:第三方介面傳送資料過來,使用redis進行釋出訊息, 在web端進行訊息訂閱, 把訂閱的訊息通過websocket傳送到前端站點,前端介面進行區域性資料重新整理展示,已解決前端即時訊息的展示。
三. 專案實現
3.1相關包
(1) 釋出訂閱redis包:Install-Package StackExchange.Redis -Version 2.0.601
3.2 fleck案例
關於fleck的websocket的參考如下:https://github.com/statianzo/Fleck/tree/master/src/Samples/ConsoleApp
3.3 專案中演示效果
(1) 使用web來做websocket宿主,websocket地址為:ws://127.0.0.1:8181,如下所示websocket服務已啟動
(2) 啟動前端介面,下圖可以看到websocket已連線
前端頁面連線websocket服務關鍵程式碼: window.ws = new wsImpl('ws://127.0.0.1:8181',"FootballGoalScore"); 具體參考fleck的websocket示例。
(3) 控制檯程式使用redis模擬釋出資訊, web端redis訂閱訊息,再通過websocket服務推送訊息到前端頁面,通過下圖可以看到訊息已即時傳到
public void FootballScore(IWebSocketConnection websocke) { //redis先訂閱訊息 _subscriber.Subscribe("queue2", (msg) => { //websocket服務推送訊息 websocke.Send(msg); _lLogger.Debug("訊息已傳送!"); });
下面是模擬第三方介面訊息達到後,使用redis來發布訊息,釋出後web端redis自動訂閱。
static void Main(string[] args) { ISubscriber subscriber = new GFRedisSubscriber(); //足球比分 subscriber.Publish("queue2", "1:0"); //即時歐指 subscriber.Publish("queue1", "1.69|3.30|3.78"); Console.ReadLine(); }
參考文獻:
ASP.NET Core 中的 WebSocket 支援
ASP.NET Core SignalR 簡介
WebSocket