一、基本信息(轉載自百度百科 https://baike.baidu.com/item/WebSocket/1953845?fr=aladdin)
WebSocket是一種在單個TCP連接上進行全雙工通信的協議。WebSocket使得客戶端和服務器之間的數據交換變得更加簡單,允許服務端主動向客戶端推送數據。在WebSocket API中,瀏覽器和服務器只需要完成一次握手,兩者之間就直接可以創建持久性的連接,並進行雙向數據傳輸。
特點:
- 較少的控制開銷。在連接創建后,服務器和客戶端之間交換數據時,用於協議控制的數據包頭部相對較小。在不包含擴展的情況下,對於服務器到客戶端的內容,此頭部大小只有2至10字節(和數據包長度有關);對於客戶端到服務器的內容,此頭部還需要加上額外的4字節的掩碼。相對於HTTP請求每次都要攜帶完整的頭部,此項開銷顯著減少了。
- 更強的實時性。由於協議是全雙工的,所以服務器可以隨時主動給客戶端下發數據。相對於HTTP請求需要等待客戶端發起請求服務端才能響應,延遲明顯更少;即使是和Comet等類似的長輪詢比較,其也能在短時間內更多次地傳遞數據。
- 保持連接狀態。與HTTP不同的是,Websocket需要先創建連接,這就使得其成為一種有狀態的協議,之后通信時可以省略部分狀態信息。而HTTP請求可能需要在每個請求都攜帶狀態信息(如身份認證等)。
- 更好的二進制支持。Websocket定義了二進制幀,相對HTTP,可以更輕松地處理二進制內容。
- 可以支持擴展。Websocket定義了擴展,用戶可以擴展協議、實現部分自定義的子協議。如部分瀏覽器支持壓縮等。
- 更好的壓縮效果。相對於HTTP壓縮,Websocket在適當的擴展支持下,可以沿用之前內容的上下文,在傳遞類似的數據時,可以顯著地提高壓縮率
二、服務端
var allSockets = new List<IWebSocketConnection>(); //啟動WEBSocket 實例,該地址為客戶端鏈接地址,即服務端開啟的地址 var server = new WebSocketServer("ws://192.168.79.6:1001"); //啟動服務 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)); }; }); var input = Console.ReadLine(); while (input != "exit") { //服務端向客戶端發送消息 foreach (var socket in allSockets.ToList()) { socket.Send(input); } input = Console.ReadLine(); }
三、客戶端
(1) html 實現
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN"> <html> <head> <title>websocket client</title> <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/>"; // create a new websocket and connect window.ws = new wsImpl('ws://192.168.79.6:1001/'); // when data is comming from the server, this metod is called ws.onmessage = function (evt) { inc.innerHTML += evt.data + '<br/>'; }; // when the connection is established, this method is called ws.onopen = function () { inc.innerHTML += '.. connection open<br/>'; }; // when the connection is closed, this method is called 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> </head> <body> <form id="sendForm"> <input id="sendText" placeholder="Text to send" /> </form> <pre id="incomming"></pre> </body> </html>
輸入 window.ws = new wsImpl 修改內容為服務端配置地址,輸入框輸入發送內容回車即可向服務端發送數據
(2)C# 實現
//啟動WebSocket實例 var ws = new WebSocket("ws://192.168.79.6:1001"); //WebSocket.onmessage 屬性是一個當收到來自服務器的消息時被調用的 event handler。它由一個 ws.OnMessage += (sender, e) => Console.WriteLine("Laputa says: " + e.Data); //鏈接服務端 ws.Connect(); Console.WriteLine("服務端鏈接成功"); //給服務端發送數據 var input = Console.ReadLine(); while (input != "exit") { //服務端向客戶端發送消息 ws.Send(input); input = Console.ReadLine(); } //關閉服務端鏈接 //ws.Close();
注意:
1、客戶端啟動之前需要啟動服務端
2、引用包WebSocketSharp-netstandard ,環境.NET CORE 3.1
3、WebSocket 屬性服務端和客戶端地址需一致
4、此為基礎用法,服務端可以一對多,暫未配置
參考: