&

C#版本websocket及時(shí)通信協(xié)議實(shí)現(xiàn)（教程示例）

當(dāng)前位置：點(diǎn)晴教程→知識管理交流 →『技術(shù)文檔交流』

admin

2019年11月12日 18:15 本文熱度 4235

1：Websocket有java、nodejs、python、PHP、等版本，我現(xiàn)在使用的是C3版本，服務(wù)器端是Fleck?？蛻舳撕头?wù)器端來使用websocket的，下面開始講解如何使用：

2：在開始之前我們先來看看哪些瀏覽器支持websocket:

Websocket服務(wù)器支持：

3：接下來我們使用的是C#控制臺程序來實(shí)現(xiàn)客戶端直接通信的實(shí)施推送第一步服務(wù)器端：

打開VS2015 創(chuàng)建項(xiàng)目Webshoufa（如下圖）

服務(wù)器端示例展示：

打開主程序入庫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】我們此次實(shí)例中服務(wù)端使用的是Fleck如下解釋：

Fleck是C＃中的一個(gè)WebSocket服務(wù)器實(shí)現(xiàn)。從Nugget項(xiàng)目分支出來，F(xiàn)leck不需要繼承，容器或其他引用。代碼示例如下（以下是一個(gè)將回顯給客戶端的例子。），在實(shí)現(xiàn)之前.NET平臺必須是在4.5之上才能運(yùn)行，

上面開始已經(jīng)提到。例子中定義引用WebSocketServer服務(wù)寫入端口路勁，格式方法是固定的。參照寫入即可。

實(shí)例代碼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);

});

實(shí)例代碼2如下（安全秘鑰版）

var server = new WebSocketServer（“ wss：//0.0.0.0：8431 ”）;

server.Certificate = new X509Certificate2（“ MyCert.pfx ”）;

server.Start（socket =>

{

// ...用法正常

}）;

開始觸發(fā)server.Start業(yè)務(wù)輸出代碼，以上兩部分實(shí)例代碼輸出一樣的區(qū)別在于啟用安全連接需要兩件事情：使用該方案wss代替ws，并將Fleck指向包含公鑰和私鑰的x509證書。詳細(xì)可以參考官網(wǎng)API：https://github.com/statianzo/Fleck

接下來寫入觸發(fā)鍵盤響應(yīng)代碼:如下所示

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ā)生。

在此完成服務(wù)器端示例開發(fā)。

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

1：新建客戶端項(xiàng)目，以web頁面或者webform頁面均可。

2：我的示例是以webform來創(chuàng)建如下圖展示：

在此，我們只實(shí)現(xiàn)數(shù)據(jù)實(shí)時(shí)交互展示，如需要數(shù)據(jù)存儲業(yè)務(wù)，需要在進(jìn)行后臺編碼。

3：前段代碼展示：

JS詳解部分

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

// 當(dāng)數(shù)據(jù)從服務(wù)器服務(wù)中心發(fā)送后，繼續(xù)向下運(yùn)行過程

ws.onmessage = function (evt) {

inc.innerHTML += evt.data + ''<br/>'';

};

// 當(dāng)鏈接對象找到服務(wù)端成功對接后，提示正常打開

ws.onopen = function () {

inc.innerHTML += ''.. connection open<br/>'';

};

// 當(dāng)鏈接對象未找找到服務(wù)端成功對接后，提示打開失敗，別切單項(xiàng)關(guān)閉

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關(guān)鍵定義。

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

并使用window.onload = start;函數(shù)。

注意：

一. 將腳本代碼放在網(wǎng)頁的底端，這樣在運(yùn)行腳本代碼的時(shí)候，可以確保要操作的對象已經(jīng)加載完成。
二.通過window.onload來執(zhí)行腳本代碼。

有需要了解window.onload在JS中函數(shù)中的用法詳細(xì)可參考：

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

第二段代碼：調(diào)用控件實(shí)體進(jìn)行事件觸發(fā)：

<body>

</form>

</body>

以上是客戶端web頁面訪問進(jìn)行實(shí)施數(shù)據(jù)推送的頁面開發(fā)完成。

好了，到了這里將兩個(gè)項(xiàng)目生成無誤之后逐個(gè)啟動(dòng)不分順序，注意需要都啟動(dòng)方可進(jìn)行測試驗(yàn)證：如下圖效果。

啟動(dòng)客戶端頁面和控制臺程序（然后刷新下客戶端頁面即可）

在客戶端和服務(wù)器端交互時(shí)輸入：你好，高峰或者XXXX信息，幾乎在零誤差時(shí)間內(nèi)服務(wù)器端收到數(shù)據(jù)。然后也可在服務(wù)器端窗口輸入信息，例如：你是不是要去阿拉善出差？

成功了，呵呵，是不是很神奇，現(xiàn)在可以添加自己喜歡的接口業(yè)務(wù)邏輯在里面了，是不是覺得前后臺通信變得簡單了？強(qiáng)不強(qiáng)大？爽不爽?。。。?/span>

Ok，到此我們就結(jié)束了這里的教程，此次重點(diǎn)講述了以下兩點(diǎn)開發(fā)組套，大家在開發(fā)過程中尤為重視：

1：.NET 4.5 添加了WebSocket

2：服務(wù)端：
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，感謝大家看完小示例，有不足之處還請大家多多指教，共同探討，以下將實(shí)例代碼程序上傳進(jìn)來供大家參考，完善。

該文章在 2019/11/12 18:15:31 編輯過

關(guān)鍵字查詢

版本

實(shí)現(xiàn)

及時(shí)

相關(guān)文章

正在查詢...

點(diǎn)晴ERP是一款針對中小制造業(yè)的專業(yè)生產(chǎn)管理軟件系統(tǒng),系統(tǒng)成熟度和易用性得到了國內(nèi)大量中小企業(yè)的青睞。

點(diǎn)晴PMS碼頭管理系統(tǒng)主要針對港口碼頭集裝箱與散貨日常運(yùn)作、調(diào)度、堆場、車隊(duì)、財(cái)務(wù)費(fèi)用、相關(guān)報(bào)表等業(yè)務(wù)管理，結(jié)合碼頭的業(yè)務(wù)特點(diǎn)，圍繞調(diào)度、堆場作業(yè)而開發(fā)的。集技術(shù)的先進(jìn)性、管理的有效性于一體，是物流碼頭及其他港口類企業(yè)的高效ERP管理信息系統(tǒng)。

點(diǎn)晴WMS倉儲管理系統(tǒng)提供了貨物產(chǎn)品管理,銷售管理,采購管理,倉儲管理,倉庫管理,保質(zhì)期管理,貨位管理,庫位管理,生產(chǎn)管理,WMS管理系統(tǒng),標(biāo)簽打印,條形碼,二維碼管理,批號管理軟件。

點(diǎn)晴免費(fèi)OA是一款軟件和通用服務(wù)都免費(fèi)，不限功能、不限時(shí)間、不限用戶的免費(fèi)OA協(xié)同辦公管理系統(tǒng)。