SignalR是一個.NET Core/.NET Framework的實時通訊的框架，一般應用在ASP.NET上，當然也可以應用在Winform上實作服務端和客戶端的訊息通訊，本篇隨筆主要基于SignalR的構建一個基于Winform的服務端和客戶端的通訊處理案例，介紹其中的處理程序，
1、SignalR基礎知識
SignalR是一個.NET Core/.NET Framework的開源實時框架. SignalR的可使用Web Socket, Server Sent Events 和 Long Polling作為底層傳輸方式，
SignalR基于這三種技術構建, 抽象于它們之上, 它讓你更好的關注業務問題而不是底層傳輸技術問題，
SignalR將整個資訊的交換封裝起來，客戶端和服務器都是使用JSON來溝通的，在服務端宣告的所有Hub資訊，都會生成JavaScript輸出到客戶端，.NET則依賴Proxy來生成代理物件，而Proxy的內部則是將JSON轉換成物件，
RPC
RPC (Remote Procedure Call). 它的優點就是可以像呼叫本地方法一樣呼叫遠程服務.
SignalR采用RPC范式來進行客戶端與服務器端之間的通信.
SignalR利用底層傳輸來讓服務器可以呼叫客戶端的方法, 反之亦然, 這些方法可以帶引數, 引數也可以是復雜物件, SignalR負責序列化和反序列化.
Hub
Hub是SignalR的一個組件, 它運行在ASP.NET Core應用里. 所以它是服務器端的一個類.
Hub使用RPC接受從客戶端發來的訊息, 也能把訊息發送給客戶端. 所以它就是一個通信用的Hub.
在ASP.NET Core里, 自己創建的Hub類需要繼承于基類Hub，在Hub類里面, 我們就可以呼叫所有客戶端上的方法了. 同樣客戶端也可以呼叫Hub類里的方法.
SignalR可以將引數序列化和反序列化. 這些引數被序列化的格式叫做Hub 協議, 所以Hub協議就是一種用來序列化和反序列化的格式.
Hub協議的默認協議是JSON, 還支持另外一個協議是MessagePack，MessagePack是二進制格式的, 它比JSON更緊湊, 而且處理起來更簡單快速, 因為它是二進制的.
此外, SignalR也可以擴展使用其它協議，
2、基于SignalR構建的Winform服務端和客戶端案例
服務單界面效果如下所示，主要功能為啟動服務、停止服務，廣播訊息和查看連接客戶端資訊，
客戶端主要就是實時獲取在線用戶串列，以及發送、應答訊息，訊息可以群發，也可以針對特定的客戶端進行訊息一對一發送，
客戶端1：
客戶端2：
構建的專案工程，包括服務端、客戶端和兩個之間的通訊物件類，如下所示，
服務端參考
客戶端參考
服務端啟動代碼，想要定義一個Startup類，用來承載SignalR的入口處理，
[assembly: OwinStartup(typeof(SignalRServer.Startup))]namespace SignalRServer{ public class Startup { public void Configuration(IAppBuilder app) { var config = new HubConfiguration(); config.EnableDetailedErrors = true; //設定可以跨域訪問 app.UseCors(Microsoft.Owin.Cors.CorsOptions.AllowAll); //映射到默認的管理 app.MapSignalR(config); } }}
我們前面介紹過，服務端使用Winform程式來處理它的啟動，停止的，如下所示，
因此界面上通過按鈕事件進行啟動，啟動服務的代碼如下所示，
private void btnStart_Click(object sender, EventArgs e) { this.btnStart.Enabled = false; WriteToInfo("正在連接中...."); Task.Run(() => { ServerStart(); }); }
這里通過啟動另外一個執行緒的處理，通過WebApp.Start啟動入口類，并傳入配置好的埠連接地址，
/// <summary> /// 開啟服務 /// </summary> private void ServerStart() { try { //開啟服務 signalR = WebApp.Start<Startup>(serverUrl); InitControlState(true); } catch (Exception ex) { //服務失敗時的處理 WriteToInfo("服務開啟失敗,原因:" + ex.Message); InitControlState(false); return; } WriteToInfo("服務開啟成功 : " + serverUrl); }
連接地址我們配置在xml檔案里面，其中的 serverUrl 就是指向下面的鍵url, 配置的url如下所示：
<?xml version="1.0" encoding="utf-8"?><configuration> <startup> <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.6.2"/> </startup> <appSettings> <add key="url" value="http://localhost:17284"/> </appSettings>
停止服務代碼如下所示，通過一個異步操作停止服務，
/// <summary> /// 停止服務 /// </summary> /// <returns></returns> private async Task StopServer() { if (signalR != null) { //向客戶端廣播訊息 hubContext = GlobalHost.ConnectionManager.GetHubContext<SignalRHub>(); await hubContext.Clients.All.SendClose("服務端已關閉"); //釋放物件 signalR.Dispose(); signalR = null; WriteToInfo("服務端已關閉"); } }
服務端對SignalR客戶端的管理是通過一個繼承于Hub的類SignalRHub進行管理，這個就是整個SignalR的核心了，它主要有幾個函式需要重寫，如OnConnected、OnDisconnected、OnReconnected、以及一個通用的訊息發送AddMessage函式，
客戶端有接入的時候，我們會通過引數獲取連接客戶端的資訊，并統一廣播當前客戶的狀態資訊，如下所示是服務端對于接入客戶端的管理代碼，
/// <summary> /// 在連接上時 /// </summary> public override Task OnConnected() { var client = JsonConvert.DeserializeObject<ClientModel>(Context.QueryString.Get("Param")); if (client != null) { client.ConnId = Context.ConnectionId; //將客戶端連接加入串列 if (!Portal.gc.ClientList.Exists(e => e.ConnId == client.ConnId)) { Portal.gc.ClientList.Add(client); } Groups.Add(client.ConnId, "Client"); //向服務端寫入一些資料 Portal.gc.MainForm.WriteToInfo("客戶端連接ID:" + Context.ConnectionId); Portal.gc.MainForm.WriteToInfo(string.Format("客戶端 【{0}】接入: {1} , IP地址: {2} \n 客戶端總數: {3}", client.Name, Context.ConnectionId, client.IPAddress, Portal.gc.ClientList.Count)); //先所有連接客戶端廣播連接客戶狀態 var imcp = new StateMessage() { Client = client, MsgType = MsgType.State, FromConnId = client.ConnId, Success = true }; var jsonStr = JsonConvert.SerializeObject(imcp); Clients.Group("Client", new string[0]).addMessage(jsonStr); return base.OnConnected(); } return Task.FromResult(0); }
客戶端的接入，需要對相應的HubConnection事件進行處理，并初始化相關資訊，如下代碼所示，
/// <summary> /// 初始化服務連接 /// </summary> private void InitHub() { ，，，，，， //連接的時候傳遞引數Param var param = new Dictionary<string, string> { { "Param", JsonConvert.SerializeObject(client) } }; //創建連接物件，并實作相關事件 Connection = new HubConnection(serverUrl, param); ，，，，，，//實作相關事件 Connection.Closed += HubConnection_Closed; Connection.Received += HubConnection_Received; Connection.Reconnected += HubConnection_Succeed; Connection.TransportConnectTimeout = new TimeSpan(3000); //系結一個集線器 hubProxy = Connection.CreateHubProxy("SignalRHub"); AddProtocal(); }
private async Task StartConnect() { try { //開始連接 await Connection.Start(); await hubProxy.Invoke<CommonResult>("CheckLogin", this.txtUser.Text); HubConnection_Succeed();//處理連接后的初始化 ，，，，，， } catch (Exception ex) { Console.WriteLine(ex.StackTrace); this.richTextBox.AppendText("服務器連接失敗：" + ex.Message); InitControlStatus(false); return; } }
客戶端根據收到的不同協議資訊，進行不同的事件處理，如下代碼所示，
/// <summary> /// 對各種協議的事件進行處理 /// </summary> private void AddProtocal() { //接收實時資訊 hubProxy.On<string>("AddMessage", DealMessage); //連接上觸發connected處理 hubProxy.On("logined", () => this.Invoke((Action)(() => { this.Text = string.Format("當前用戶:{0}", this.txtUser.Text); richTextBox.AppendText(string.Format("以名稱【" + this.txtUser.Text + "】連接成功!" + Environment.NewLine)); InitControlStatus(true); })) ); //服務端拒絕的處理 hubProxy.On("rejected", () => this.Invoke((Action)(() => { richTextBox.AppendText(string.Format("無法使用名稱【" + this.txtUser.Text + "】進行連接!" + Environment.NewLine)); InitControlStatus(false); CloseHub(); })) ); //客戶端收到服務關閉訊息 hubProxy.On("SendClose", () => { CloseHub(); }); }
例如我們對收到的文本資訊，如一對一的發送訊息或者廣播訊息，統一進行展示處理，
/// <summary> /// 處理文本訊息 /// </summary> /// <param name="data"></param> /// <param name="basemsg"></param> private void DealText(string data, BaseMessage basemsg) { //JSON轉換為文本訊息 var msg = JsonConvert.DeserializeObject<TextMessage>(data); var ownerClient = ClientList.FirstOrDefault(f => f.ConnId == basemsg.FromConnId); var ownerName = ownerClient == null ? "系統廣播" : ownerClient.Name; this.Invoke(new Action(() => { richTextBox.AppendText(string.Format("{0} - {1}:\n {2}" + Environment.NewLine, DateTime.Now, ownerName, msg.Message)); richTextBox.ScrollToCaret(); })); }
客戶端對訊息的處理界面
而客戶端發送訊息，則是統一通過呼叫Hub的AddMessage方法進行發送即可，如下代碼所示，
private void BtnSendMessage_Click(object sender, EventArgs e) { if (txtMessage.Text.Length == 0) return; var message = new TextMessage() { MsgType = MsgType.Text, FromConnId = client.ConnId, ToConnId = this.toId, Message = txtMessage.Text, Success = true }; hubProxy.Invoke("AddMessage", JsonConvert.SerializeObject(message)); txtMessage.Text = string.Empty; txtMessage.Focus(); }
其中的hubProxy是我們前面連接服務端的時候，構造出的一個代理物件
hubProxy = Connection.CreateHubProxy("SignalRHub");
客戶端關閉的時候，我們銷毀相關的物件即可，
private void Form1_FormClosing(object sender, FormClosingEventArgs e) { if (Connection != null) { Connection.Stop(); Connection.Dispose(); } }
以上就是SignalR的服務端和客戶端的相互配合，相互通訊程序，
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/1714.html
標籤：WinForm