C#版本websocket及時通信協(xié)議實現(xiàn)(教程示例)
當前位置:點晴教程→知識管理交流
→『 技術文檔交流 』
1:Websocket有java、nodejs、python、PHP、等版本 ,我現(xiàn)在使用的是C3版本,服務器端是Fleck??蛻舳撕头掌鞫藖硎褂脀ebsocket的,下面開始講解如何使用: 2:在開始之前我們先來看看哪些瀏覽器支持websocket: Websocket服務器支持: 3:接下來我們使用的是C#控制臺程序來實現(xiàn)客戶端直接通信的實施推送第一步服務器端: 打開VS2015 創(chuàng)建項目Webshoufa(如下圖) 服務器端示例展示:打開主程序入庫Program.CS 寫入主要鏈接推送代碼如下展示 FleckLog.Level = LogLevel.Debug; var allSockets = new List<IWebSocketConnection>(); var server = new WebSocketServer("ws://0.0.0.0:7181"); server.Start(socket => { socket.OnOpen = () => { Console.WriteLine("Open!"); allSockets.Add(socket); }; socket.OnClose = () => { Console.WriteLine("Close!"); allSockets.Remove(socket); }; socket.OnMessage = message => { Console.WriteLine(message); allSockets.ToList().ForEach(s => s.Send("Echo: " + message)); }; }); 以上代碼:尤為重要的注意【Fleck】我們此次實例中服務端使用的是Fleck如下解釋: Fleck是C#中的一個WebSocket服務器實現(xiàn)。從Nugget項目分支出來 ,F(xiàn)leck不需要繼承,容器或其他引用。代碼示例如下(以下是一個將回顯給客戶端的例子。),在實現(xiàn)之前.NET平臺必須是在4.5之上才能運行, 上面開始已經(jīng)提到。例子中定義引用WebSocketServer服務寫入端口路勁,格式方法是固定的。參照寫入即可。
實例代碼1如下 var server = new WebSocketServer("ws://localhost:7181"); server.Start(socket => { socket.OnOpen = () => Console.WriteLine("Open!"); socket.OnClose = () => Console.WriteLine("Close!"); socket.OnMessage = message => socket.Send(message); }); 實例代碼2如下(安全秘鑰版) var server = new WebSocketServer(“ wss://0.0.0.0:8431 ”); server.Certificate = new X509Certificate2(“ MyCert.pfx ”); server.Start(socket => { // ...用法正常 }); 開始觸發(fā)server.Start業(yè)務輸出代碼,以上兩部分實例代碼輸出一樣的區(qū)別在于啟用安全連接需要兩件事情:使用該方案wss代替ws,并將Fleck指向包含公鑰和私鑰的x509證書。詳細可以參考官網(wǎng)API:https://github.com/statianzo/Fleck
接下來寫入觸發(fā)鍵盤響應代碼:如下所示 var input = Console.ReadLine(); while (input != "exit") { foreach (var socket in allSockets.ToList()) { socket.Send(input); } input = Console.ReadLine(); } 代碼解析:上述定義input =Console.ReadLine();由第一段輸出參數(shù) 在input不為空的情況下給予下一次事件發(fā)生。 在此完成服務器端示例開發(fā)。 客戶端頁面請求端展示(瀏覽器端)1:新建客戶端項目,以web頁面或者webform頁面均可。 2:我的示例是以webform來創(chuàng)建如下圖展示: 在此,我們只實現(xiàn)數(shù)據(jù)實時交互展示,如需要數(shù)據(jù)存儲業(yè)務,需要在進行后臺編碼。 3:前段代碼展示: JS詳解部分 <script type="text/javascript"> var start = function () { var inc = document.getElementById(''incomming''); var wsImpl = window.WebSocket || window.MozWebSocket; var form = document.getElementById(''sendForm''); var input = document.getElementById(''sendText''); inc.innerHTML += "connecting to server ..<br/>"; // 創(chuàng)建新的websocket新連接端口為7181 window.ws = new wsImpl(''ws://localhost:7181/''); // 當數(shù)據(jù)從服務器服務中心發(fā)送后,繼續(xù)向下運行過程 ws.onmessage = function (evt) { inc.innerHTML += evt.data + ''<br/>''; }; // 當鏈接對象找到服務端成功對接后,提示正常打開 ws.onopen = function () { inc.innerHTML += ''.. connection open<br/>''; }; // 當鏈接對象未找找到服務端成功對接后,提示打開失敗,別切單項關閉 ws.onclose = function () { inc.innerHTML += ''.. connection closed<br/>''; } form.addEventListener(''submit'', function (e) { e.preventDefault(); var val = input.value; ws.send(val); input.value = ""; }); } window.onload = start; </script> 注意以上示例代碼片段中window.ws = new wsImpl(''ws://localhost:7181/'');中ws關鍵定義。 啟用安全連接需要兩件事情:使用該方案wss代替ws,并將Fleck指向包含公鑰和私鑰的x509證書。 并使用window.onload = start;函數(shù)。 注意: 一. 將腳本代碼放在網(wǎng)頁的底端,這樣在運行腳本代碼的時候,可以確保要操作的對象已經(jīng)加載完成。 有需要了解window.onload在JS中函數(shù)中的用法詳細可參考: http://www.softwhy.com/forum.php?mod=viewthread&tid=6191 第二段代碼:調(diào)用控件實體進行事件觸發(fā): <body> <form id="sendForm"> <input id="sendText" placeholder="Text to send" /> </form> <pre id="incomming"></pre> </body> 以上是客戶端web頁面訪問進行實施數(shù)據(jù)推送的頁面開發(fā)完成。 好了,到了這里將兩個項目生成無誤之后逐個啟動不分順序,注意需要都啟動方可進行測試驗證:如下圖效果。
啟動客戶端頁面和控制臺程序(然后刷新下客戶端頁面即可)
在客戶端和服務器端交互時輸入:你好,高峰或者XXXX信息,幾乎在零誤差時間內(nèi)服務器端收到數(shù)據(jù)。然后也可在服務器端窗口輸入信息,例如:你是不是要去阿拉善出差? 成功了,呵呵,是不是很神奇,現(xiàn)在可以添加自己喜歡的接口業(yè)務邏輯在里面了,是不是覺得前后臺通信變得簡單了?強不強大?爽不爽!?。?! Ok,到此我們就結束了這里的教程,此次重點講述了以下兩點開發(fā)組套,大家在開發(fā)過程中尤為重視: 1:.NET 4.5 添加了WebSocket
Ok,感謝大家看完小示例,有不足之處還請大家多多指教,共同探討,以下將實例代碼程序上傳進來供大家參考,完善。 該文章在 2019/11/12 18:15:31 編輯過 |
關鍵字查詢
相關文章
正在查詢... |