.Net WebSocket學習之旅(一)
阿新 • • 發佈:2019-02-14
原生Websocket在.Net環境的實現
我使用原生的websocket做了個簡單的demo,適合初學的知道怎麼個實現。
我參考的是網上的,部分雷同,見諒
(聊天室功能可以在此基礎上加工,我後面會在SignalR框架中實現)
下面是大致的程式碼框架,實現是加上自己的業務的,我會在後面提供我的原始碼,豐富了框架,一個簡單的demo
一、前端Html中的Js
var socket;//建立websocket物件
$(document).ready(function(){
//建立連結,開啟連線。使用ws協議,如果報錯注意IIS版本,至少IIS8(我不太確定)
socket = new WebSocket('ws://' + window.location.hostname + ':' + window.location.port + '/App/webSocketHandler.ashx');
socket.onopen = function (event) {
//監控websocket開啟的方法
}
socket.onclose = function (event) {
//瀏覽器關閉時、url跳轉時,伺服器會接收到當前websocket關閉的通知//監控伺服器關閉websocket的方法
}
socket.onerror = function (event) {
//監控websocket關閉的方法} socket.onmessage = function (event) { //接收到伺服器訊息,具體資訊是json格式,在event的data中。 }
})
function sendMsg(msg){//傳送訊息到伺服器if (socket.readyState == WebSocket.OPEN) {
socket.send(msg);
}
}
二、前端Html中的html、css,略,看我原始碼
三、後臺處理程式
public class webSocketHandler : IHttpHandler
{
//獲取Dal層的websocket列表,當前每個請求視為一個websocket物件,進來儲存,離開移除。
public static List<WebSocket> lstWs = WebSocketHelper.lstWs;
public void ProcessRequest(HttpContext context)
{
if (context.IsWebSocketRequest)
{
context.AcceptWebSocketRequest(ProcessChat);
}
}
//一個非同步執行緒
private async Task ProcessChat(AspNetWebSocketContext context)
{
string rspMsg = string.Empty;
WebSocket socket = context.WebSocket;//獲取當前的websocket物件
lstWs.Add(socket);//加入當前的websocket物件
//while不會進入死迴圈
while (true)
{
if (socket.State == WebSocketState.Open)
{
ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);
WebSocketReceiveResult result = await socket.ReceiveAsync(buffer, CancellationToken.None);
//當接收到瀏覽器關閉、url跳轉、報錯等問題,伺服器會接收到websocket關閉通知
if (result.MessageType == WebSocketMessageType.Close)
{
//非同步關閉websocket連線
await socket.CloseAsync(WebSocketCloseStatus.Empty, string.Empty, CancellationToken.None);
lstWs.Remove(socket);
break;
}
//這裡打斷點除錯,你會發現while程式不會死迴圈,直到下面的方法收到資訊,或者上面接收到關閉
string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);
rspMsg = DateTime.Now.ToLongTimeString() + " 你傳送了:" + userMsg;
buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(rspMsg));
//傳送到當前使用者的客戶端
await socket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
}
else
{
break;
}
}
}
//DAL層的程式
public class WebSocketHelper
{
public static List<WebSocket> lstWs = new List<WebSocket>();
/// <summary>
/// 封裝推送訊息,然後傳送給每位線上的
/// </summary>
/// <param name="json">json格式推送內容</param>
public void Push2EveryOne(string json = "")
{
//封裝推送訊息,然後傳送給每位線上的
ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[2048]);
buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(json));
foreach (WebSocket socket in lstWs)
{
socket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
}
}
}
我做了個簡單的demo,看下截圖,裡面稍微豐富了下,有興趣下載原始碼(MVC4.5)