在Asp.net core項目中使用WebSocket

今天小試了一下在Asp.net core中使用websocket，這里記錄一下：

在 Startup 類的 Configure 方法中添加 WebSocket 中間件。

app.UseWebSockets();

它也可以傳入一些參數

app.UseWebSockets(new WebSocketOptions(){    KeepAliveInterval = TimeSpan.FromSeconds(120),    ReceiveBufferSize = 4 * 1024});

添加WebSocket中間件的處理函數：

async Task WebSocketMiddleware(HttpContext context, Func<Task> next){    //這里監聽的是 /ws 作為地址    if (context.Request.Path != "/ws")    {await next();return;    }        if (!context.WebSockets.IsWebSocketRequest)    {context.Response.StatusCode = 400;return;    }    WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();    await Echo(context, webSocket);}

在Startup 類的 Configure函數中應用該中間件。

app.Use(WebSocketMiddleware);

最后再來完成我們的WebScoket功能函數Echo

async Task Echo(HttpContext context, WebSocket webSocket){    var buffer = new byte[1024 * 4];    WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);    while (!result.CloseStatus.HasValue)    {await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), 　　　　　　　　　　result.MessageType, result.EndOfMessage, CancellationToken.None);result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);    }    await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);}

到此一個簡單的websocket應用就完成了，我們可以隨便找一個測試webscoket的程序或在線網頁測試一下了。

最后需要說明一下的時，本身asp.net core的websocket是可以在win7下跑的（來自于Kestrel內核的支持），但win7下的iis是不支持websocket反向代理的，因此如果在win7下開發或測試的時候，不要用iis來反向代理asp.net core程序。

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對的支持。如果你想了解更多相關內容請查看下面相關鏈接