溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這期內容當中小編將會給大家帶來有關怎么在C#中利用websocket實現一個及時通信協議，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。
傳統“長輪詢”實現Web端即時通訊的問題
WebSocket出現之前，Web端為了實現即時通訊，所用的技術都是Ajax輪詢(polling)。輪詢是在特定的的時間間隔（如每1秒），由瀏覽器對服務器發出HTTP request，然后由服務器返回最新的數據給客服端的瀏覽器。這種傳統的HTTP request 的模式帶來很明顯的缺點 – 瀏覽器需要不斷的向服務器發出請求，然而HTTP request 的header是非常長的，里面包含的數據可能只是一個很小的值，這樣會占用很多的帶寬。
而比較新的技術去做輪詢的效果是Comet , 但這種技術雖然可達到全雙工通信，依然需要發出請求。
WebSocket 技術概覽
在 WebSocket API，瀏覽器和服務器只需要要做一個握手的動作，然后，瀏覽器和服務器之間就形成了一條快速通道。兩者之間就直接可以數據互相傳送，改變了原有的B/S模式。
WebSocket技術應用的典型架構：
WebSocket的技術原理：
介紹了基礎知識，下面開始本文的正文內容：
C# websocket及時通信協議的實現
1：Websocket有java、nodejs、python、PHP、等版本 ，我現在使用的是C3版本，服務器端是Fleck。客戶端和服務器端來使用websocket的，下面開始講解如何使用：
2：在開始之前我們先來看看哪些瀏覽器支持websocket:
Websocket服務器支持：
3：接下來我們使用的是C#控制臺程序來實現客戶端直接通信的實施推送第一步服務器端：
打開VS2015 創建項目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服務器實現。從Nugget項目分支出來，Fleck不需要繼承，容器或其他引用。代碼示例如下（以下是一個將回顯給客戶端的例子。），在實現之前.NET平臺必須是在4.5之上才能運行，
上面開始已經提到。例子中定義引用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如下（安全秘鑰版）
ar server = new WebSocketServer（“ wss：//0.0.0.0：8431 ”）;
server.Certificate = new X509Certificate2（“ MyCert.pfx ”）;
server.Start（socket =>
{
// ...用法正常
}）;開始觸發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();
}代碼解析：上述定義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>注意：以上示例代碼片段中window.ws = new wsImpl('ws://localhost:7181/');中ws關鍵定義。
啟用安全連接需要兩件事情：使用該方案wss代替ws，并將Fleck指向包含公鑰和私鑰的x509證書。
并使用window.onload = start;函數。
注意：
一.將腳本代碼放在網頁的底端，這樣在運行腳本代碼的時候，可以確保要操作的對象已經加載完成。
二.通過window.onload來執行腳本代碼。
有需要了解window.onload在JS中函數中的用法詳細可參考：
https://www.jb51.net/article/72172.htm
第二段代碼：調用控件實體進行事件觸發：
<body> <form id="sendForm"> <input id="sendText" placeholder="Text to send" /> </form> <pre id="incomming"></pre> </body>
以上是客戶端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);上述就是小編為大家分享的怎么在C#中利用websocket實現一個及時通信協議了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
