一、基本信息(轉載自百度百科 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、此為基礎用法,服務端可以一對多,暫未配置
參考:
