C# .net core web socket 基礎用法


一、基本信息(轉載自百度百科 https://baike.baidu.com/item/WebSocket/1953845?fr=aladdin

  WebSocket是一種在單個TCP連接上進行全雙工通信的協議。WebSocket使得客戶端和服務器之間的數據交換變得更加簡單,允許服務端主動向客戶端推送數據。在WebSocket API中,瀏覽器和服務器只需要完成一次握手,兩者之間就直接可以創建持久性的連接,並進行雙向數據傳輸。

  特點:

  1. 較少的控制開銷。在連接創建后,服務器和客戶端之間交換數據時,用於協議控制的數據包頭部相對較小。在不包含擴展的情況下,對於服務器到客戶端的內容,此頭部大小只有2至10字節(和數據包長度有關);對於客戶端到服務器的內容,此頭部還需要加上額外的4字節的掩碼。相對於HTTP請求每次都要攜帶完整的頭部,此項開銷顯著減少了。
  2. 更強的實時性。由於協議是全雙工的,所以服務器可以隨時主動給客戶端下發數據。相對於HTTP請求需要等待客戶端發起請求服務端才能響應,延遲明顯更少;即使是和Comet等類似的長輪詢比較,其也能在短時間內更多次地傳遞數據。
  3. 保持連接狀態。與HTTP不同的是,Websocket需要先創建連接,這就使得其成為一種有狀態的協議,之后通信時可以省略部分狀態信息。而HTTP請求可能需要在每個請求都攜帶狀態信息(如身份認證等)。
  4. 更好的二進制支持。Websocket定義了二進制幀,相對HTTP,可以更輕松地處理二進制內容。
  5. 可以支持擴展。Websocket定義了擴展,用戶可以擴展協議、實現部分自定義的子協議。如部分瀏覽器支持壓縮等。
  6. 更好的壓縮效果。相對於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、此為基礎用法,服務端可以一對多,暫未配置

參考:

https://www.cnblogs.com/swjian/p/10553689.html

http://www.zzvips.com/article/217148.html


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM