C#版本websocket及時通訊協議實現（教程示例）

時間 2019-11-17

標籤 c# 版本 websocket 及時通訊協議實現教程示例欄目 C# 简体版

原文原文鏈接

1：Websocket有java、nodejs、python、PHP、等版本，我如今使用的是C3版本，服務器端是Fleck。客戶端和服務器端來使用websocket的，下面開始講解如何使用：javascript

2：在開始以前咱們先來看看哪些瀏覽器支持websocket:php

Websocket服務器支持：java

3：接下來咱們使用的是C#控制檯程序來實現客戶端直接通訊的實施推送第一步服務器端：node

打開VS2015 建立項目Webshoufa（以下圖）python

服務器端示例展現：

打開主程序入庫Program.CSgit

寫入主要連接推送代碼以下展現github

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));

                };

            });

View Code

以上代碼：尤其重要的注意【Fleck】咱們這次實例中服務端使用的是Fleck以下解釋：web

Fleck是C＃中的一個WebSocket服務器實現。從Nugget項目分支出來，Fleck不須要繼承，容器或其餘引用。代碼示例以下（如下是一個將回顯給客戶端的例子。），在實現以前.NET平臺必須是在4.5之上才能運行，瀏覽器

上面開始已經提到。例子中定義引用WebSocketServer服務寫入端口路勁，格式方法是固定的。參照寫入便可。安全

實例代碼1以下

1 var server = new WebSocketServer("ws://localhost:7181");
2 server.Start(socket =>
3   {
4     socket.OnOpen = () => Console.WriteLine("Open!");
5     socket.OnClose = () => Console.WriteLine("Close!");
6     socket.OnMessage = message => socket.Send(message);
7   });

View Code

實例代碼2以下（安全祕鑰版）

ar  server = new  WebSocketServer（「 wss：//0.0.0.0：8431 」）;
server.Certificate = new X509Certificate2（「 MyCert.pfx 」）;
server.Start（socket =>
{
  // ...用法正常 
}）;

View Code

開始觸發server.Start業務輸出代碼，以上兩部分實例代碼輸出同樣的區別在於啓用安全鏈接須要兩件事情：使用該方案wss代替ws，並將Fleck指向包含公鑰和私鑰的x509證書。詳細能夠參考官網API：https://github.com/statianzo/Fleck

接下來寫入觸發鍵盤響應代碼:以下所示

var input = Console.ReadLine();
            while (input != "exit")
            {
                foreach (var socket in allSockets.ToList())
                {
                    socket.Send(input);
                }
                input = Console.ReadLine();
            }

View Code

代碼解析：上述定義input =Console.ReadLine();由第一段輸出參數

在input不爲空的狀況下給予下一次事件發生。

在此完成服務器端示例開發。

客戶端頁面請求端展現（瀏覽器端）

1：新建客戶端項目，以web頁面或者webform頁面都可。

2：個人示例是以webform來建立以下圖展現：

在此，咱們只實現數據實時交互展現，如須要數據存儲業務，須要在進行後臺編碼。

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/>";

            // 建立新的websocket新鏈接端口爲7181
            window.ws = new wsImpl('ws://localhost:7181/');

            // 當數據從服務器服務中心發送後，繼續向下運行過程
            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>

View Code

注意以上示例代碼片斷中window.ws = new wsImpl('ws://localhost:7181/');中ws關鍵定義。

啓用安全鏈接須要兩件事情：使用該方案wss代替ws，並將Fleck指向包含公鑰和私鑰的x509證書。

並使用window.onload = start;函數。

注意：

一. 將腳本代碼放在網頁的底端，這樣在運行腳本代碼的時候，能夠確保要操做的對象已經加載完成。
二.經過window.onload來執行腳本代碼。

有須要瞭解window.onload在JS中函數中的用法詳細可參考：

http://www.softwhy.com/forum.php?mod=viewthread&tid=6191

第二段代碼：調用控件實體進行事件觸發：

<body>

    <form id="sendForm">

        <input id="sendText" placeholder="Text to send" />

    </form>

    <pre id="incomming"></pre>

</body>

View Code

以上是客戶端web頁面訪問進行實施數據推送的頁面開發完成。

好了，到了這裏將兩個項目生成無誤以後逐個啓動不分順序，注意須要都啓動方可進行測試驗證：以下圖效果。

啓動客戶端頁面和控制檯程序（而後刷新下客戶端頁面便可）

在客戶端和服務器端交互時輸入：你好，高峯或者XXXX信息，幾乎在零偏差時間內服務器端收到數據。而後也可在服務器端窗口輸入信息，例如：你是否是要去阿拉善出差？

成功了，呵呵，是否是很神奇，如今能夠添加本身喜歡的接口業務邏輯在裏面了，是否是以爲先後臺通訊變得簡單了？強不強大？爽不爽！！！！

Ok，到此咱們就結束了這裏的教程，這次重點講述瞭如下兩點開發組套，你們在開發過程當中尤其重視：

1：.NET 4.5 添加了WebSocket
2：服務端：
var listener = new HttpListener();
listener.Prefixes.Add("http://*:8080/");
listener.Start();
var context = await listener.GetContextAsync();
var wsContext = await context.AcceptWebSocketAsync(null);
var ws = wsContext.WebSocket;
3：客戶端：
var ws = new ClientWebSocket();
await ws.ConnectAsync(new Uri("ws://127.0.0.1:8080"),CancellationToken.None);

Ok，感謝你們看完小示例，有不足之處還請你們多多指教，共同探討，如下將實例代碼程序上傳進來供你們參考，完善。

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。